org.apache.flink.table.runtime.runners.python.scalar

Class AbstractPythonScalarFunctionRunner<IN>

java.lang.Object

org.apache.flink.python.AbstractPythonFunctionRunner<IN>

org.apache.flink.table.runtime.runners.python.AbstractPythonStatelessFunctionRunner<IN>

org.apache.flink.table.runtime.runners.python.scalar.AbstractPythonScalarFunctionRunner<IN>

Type Parameters:

IN - Type of the input elements.

All Implemented Interfaces:

PythonFunctionRunner<IN>

Direct Known Subclasses:

AbstractArrowPythonScalarFunctionRunner, AbstractGeneralPythonScalarFunctionRunner

@Internal
public abstract class AbstractPythonScalarFunctionRunner<IN>
extends AbstractPythonStatelessFunctionRunner<IN>

Abstract PythonFunctionRunner used to execute Python ScalarFunctions.

Field Summary

Fields inherited from class org.apache.flink.python.AbstractPythonFunctionRunner

baos, baosWrapper, flinkMetricContainer, mainInputReceiver, resultReceiver

Constructor Summary

Constructors

Constructor and Description
AbstractPythonScalarFunctionRunner(String taskName, org.apache.beam.sdk.fn.data.FnDataReceiver<byte[]> resultReceiver, PythonFunctionInfo[] scalarFunctions, PythonEnvironmentManager environmentManager, RowType inputType, RowType outputType, Map<String,String> jobOptions, FlinkMetricContainer flinkMetricContainer)

Method Summary

Modifier and Type	Method and Description
FlinkFnApi.UserDefinedFunctions	getUserDefinedFunctionsProto() Gets the proto representation of the Python user-defined functions to be executed.

Methods inherited from class org.apache.flink.table.runtime.runners.python.AbstractPythonStatelessFunctionRunner

createExecutableStage, getInputOutputCoderUrn, getInputType, getOutputType, getUserDefinedFunctionProto

Methods inherited from class org.apache.flink.python.AbstractPythonFunctionRunner

close, createJobBundleFactory, createOutputReceiverFactory, createPythonExecutionEnvironment, finishBundle, open, startBundle

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.flink.python.PythonFunctionRunner

processElement

Constructor Detail

AbstractPythonScalarFunctionRunner

public AbstractPythonScalarFunctionRunner(String taskName,
                                          org.apache.beam.sdk.fn.data.FnDataReceiver<byte[]> resultReceiver,
                                          PythonFunctionInfo[] scalarFunctions,
                                          PythonEnvironmentManager environmentManager,
                                          RowType inputType,
                                          RowType outputType,
                                          Map<String,String> jobOptions,
                                          FlinkMetricContainer flinkMetricContainer)

Method Detail

getUserDefinedFunctionsProto

@VisibleForTesting
public FlinkFnApi.UserDefinedFunctions getUserDefinedFunctionsProto()

Gets the proto representation of the Python user-defined functions to be executed.

Specified by:

getUserDefinedFunctionsProto in class AbstractPythonStatelessFunctionRunner<IN>