@Internal public class BeamTableStatelessPythonFunctionRunner extends BeamPythonFunctionRunner
BeamTableStatelessPythonFunctionRunner
used to execute Python stateless functions.LOG, mainInputReceiver, outputMode, resultBuffer, resultTuple
Constructor and Description |
---|
BeamTableStatelessPythonFunctionRunner(String taskName,
PythonEnvironmentManager environmentManager,
RowType inputType,
RowType outputType,
String functionUrn,
FlinkFnApi.UserDefinedFunctions userDefinedFunctions,
String coderUrn,
Map<String,String> jobOptions,
FlinkMetricContainer flinkMetricContainer,
MemoryManager memoryManager,
double managedMemoryFraction,
FlinkFnApi.CoderParam.OutputMode outputMode) |
Modifier and Type | Method and Description |
---|---|
protected org.apache.beam.model.pipeline.v1.RunnerApi.Coder |
getInputCoderProto() |
protected org.apache.beam.model.pipeline.v1.RunnerApi.Coder |
getOutputCoderProto() |
protected byte[] |
getUserDefinedFunctionsProtoBytes() |
close, createJobBundleFactory, flush, open, pollResult, process, startBundle
public BeamTableStatelessPythonFunctionRunner(String taskName, PythonEnvironmentManager environmentManager, RowType inputType, RowType outputType, String functionUrn, FlinkFnApi.UserDefinedFunctions userDefinedFunctions, String coderUrn, Map<String,String> jobOptions, FlinkMetricContainer flinkMetricContainer, MemoryManager memoryManager, double managedMemoryFraction, FlinkFnApi.CoderParam.OutputMode outputMode)
protected byte[] getUserDefinedFunctionsProtoBytes()
getUserDefinedFunctionsProtoBytes
in class BeamPythonFunctionRunner
protected org.apache.beam.model.pipeline.v1.RunnerApi.Coder getInputCoderProto()
getInputCoderProto
in class BeamPythonFunctionRunner
protected org.apache.beam.model.pipeline.v1.RunnerApi.Coder getOutputCoderProto()
getOutputCoderProto
in class BeamPythonFunctionRunner
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.