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

Class AbstractPythonScalarFunctionRunner<IN,OUT>

java.lang.Object

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

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

Type Parameters:

IN - Type of the input elements.

OUT - Type of the execution results.

All Implemented Interfaces:

PythonFunctionRunner<IN>

Direct Known Subclasses:

BaseRowPythonScalarFunctionRunner, PythonScalarFunctionRunner

@Internal
public abstract class AbstractPythonScalarFunctionRunner<IN,OUT>
extends AbstractPythonFunctionRunner<IN,OUT>

Abstract PythonFunctionRunner used to execute Python ScalarFunctions.

Field Summary

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

LOG

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
org.apache.beam.runners.core.construction.graph.ExecutableStage	createExecutableStage() Creates a ExecutableStage which contains the Python user-defined functions to be executed and all the other information needed to execute them, such as the execution environment, the input and output coder, etc.
RowType	getInputType() Gets the logical type of the input elements of the Python user-defined functions.
RowType	getOutputType() Gets the logical type of the execution results of the Python user-defined functions.
FlinkFnApi.UserDefinedFunctions	getUserDefinedFunctionsProto() Gets the proto representation of the Python user-defined functions to be executed.

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

close, createJobBundleFactory, createPythonExecutionEnvironment, finishBundle, getInputTypeSerializer, getOutputTypeSerializer, open, processElement, startBundle

Methods inherited from class java.lang.Object

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

Constructor Detail

AbstractPythonScalarFunctionRunner

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

Method Detail

getInputType

public RowType getInputType()

Gets the logical type of the input elements of the Python user-defined functions.

getOutputType

public RowType getOutputType()

Gets the logical type of the execution results of the Python user-defined functions.

createExecutableStage

public org.apache.beam.runners.core.construction.graph.ExecutableStage createExecutableStage()
                                                                                      throws Exception

Description copied from class: AbstractPythonFunctionRunner

Creates a ExecutableStage which contains the Python user-defined functions to be executed and all the other information needed to execute them, such as the execution environment, the input and output coder, etc.

Specified by:

createExecutableStage in class AbstractPythonFunctionRunner<IN,OUT>

Throws:

Exception

getUserDefinedFunctionsProto

@VisibleForTesting
public FlinkFnApi.UserDefinedFunctions getUserDefinedFunctionsProto()

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