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

Class AbstractPythonStatelessFunctionRunner<IN>

java.lang.Object

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

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

Type Parameters:

IN - Type of the input elements.

All Implemented Interfaces:

PythonFunctionRunner<IN>

Direct Known Subclasses:

AbstractPythonScalarFunctionRunner, AbstractPythonTableFunctionRunner

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

Abstract PythonFunctionRunner used to execute Python stateless functions..

Field Summary

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

baos, baosWrapper, flinkMetricContainer, mainInputReceiver, resultReceiver

Constructor Summary

Constructors

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

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.
abstract String	getInputOutputCoderUrn()
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.UserDefinedFunction	getUserDefinedFunctionProto(PythonFunctionInfo pythonFunctionInfo)
abstract 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, 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

AbstractPythonStatelessFunctionRunner

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

Method Detail

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>

Throws:

Exception

getUserDefinedFunctionProto

public FlinkFnApi.UserDefinedFunction getUserDefinedFunctionProto(PythonFunctionInfo pythonFunctionInfo)

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.

getInputOutputCoderUrn

public abstract String getInputOutputCoderUrn()

getUserDefinedFunctionsProto

@VisibleForTesting
public abstract FlinkFnApi.UserDefinedFunctions getUserDefinedFunctionsProto()

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