@Internal public class PythonTableFunctionRunner extends AbstractPythonTableFunctionRunner<Row>
PythonFunctionRunner
used to execute Python TableFunction
. It takes Row
as the input and outputs a byte array.baos, baosWrapper, flinkMetricContainer, mainInputReceiver, resultReceiver
Constructor and Description |
---|
PythonTableFunctionRunner(String taskName,
org.apache.beam.sdk.fn.data.FnDataReceiver<byte[]> resultReceiver,
PythonFunctionInfo tableFunction,
PythonEnvironmentManager environmentManager,
RowType inputType,
RowType outputType,
Map<String,String> jobOptions,
FlinkMetricContainer flinkMetricContainer) |
Modifier and Type | Method and Description |
---|---|
TypeSerializer<Row> |
getInputTypeSerializer()
Returns the TypeSerializer for input elements.
|
createOutputReceiverFactory, getInputOutputCoderUrn, getUserDefinedFunctionsProto, open, processElement
createExecutableStage, getInputType, getOutputType, getUserDefinedFunctionProto
close, createJobBundleFactory, createPythonExecutionEnvironment, finishBundle, startBundle
public PythonTableFunctionRunner(String taskName, org.apache.beam.sdk.fn.data.FnDataReceiver<byte[]> resultReceiver, PythonFunctionInfo tableFunction, PythonEnvironmentManager environmentManager, RowType inputType, RowType outputType, Map<String,String> jobOptions, FlinkMetricContainer flinkMetricContainer)
public TypeSerializer<Row> getInputTypeSerializer()
AbstractPythonTableFunctionRunner
getInputTypeSerializer
in class AbstractPythonTableFunctionRunner<Row>
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.