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

Class BeamTableStatefulPythonFunctionRunner

java.lang.Object

org.apache.flink.streaming.api.runners.python.beam.BeamPythonFunctionRunner

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

All Implemented Interfaces:

PythonFunctionRunner

public class BeamTableStatefulPythonFunctionRunner
extends BeamPythonFunctionRunner

A BeamTableStatefulPythonFunctionRunner used to execute Python stateful functions.

Field Summary

Fields inherited from class org.apache.flink.streaming.api.runners.python.beam.BeamPythonFunctionRunner

LOG, mainInputReceiver, resultBuffer, resultTuple

Constructor Summary

Constructors

Constructor and Description

BeamTableStatefulPythonFunctionRunner(String taskName, PythonEnvironmentManager environmentManager, RowType inputType, RowType outputType, String functionUrn, FlinkFnApi.UserDefinedAggregateFunctions userDefinedFunctions, String coderUrn, Map<String,String> jobOptions, FlinkMetricContainer flinkMetricContainer, KeyedStateBackend keyedStateBackend, TypeSerializer keySerializer, MemoryManager memoryManager, double managedMemoryFraction)

Method Summary

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()

Methods inherited from class org.apache.flink.streaming.api.runners.python.beam.BeamPythonFunctionRunner

close, createJobBundleFactory, flush, open, pollResult, process, startBundle

Methods inherited from class java.lang.Object

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

Constructor Detail

BeamTableStatefulPythonFunctionRunner

public BeamTableStatefulPythonFunctionRunner(String taskName,
                                             PythonEnvironmentManager environmentManager,
                                             RowType inputType,
                                             RowType outputType,
                                             String functionUrn,
                                             FlinkFnApi.UserDefinedAggregateFunctions userDefinedFunctions,
                                             String coderUrn,
                                             Map<String,String> jobOptions,
                                             FlinkMetricContainer flinkMetricContainer,
                                             KeyedStateBackend keyedStateBackend,
                                             TypeSerializer keySerializer,
                                             MemoryManager memoryManager,
                                             double managedMemoryFraction)

Method Detail

getUserDefinedFunctionsProtoBytes

protected byte[] getUserDefinedFunctionsProtoBytes()

Specified by:

getUserDefinedFunctionsProtoBytes in class BeamPythonFunctionRunner

getInputCoderProto

protected org.apache.beam.model.pipeline.v1.RunnerApi.Coder getInputCoderProto()

Specified by:

getInputCoderProto in class BeamPythonFunctionRunner

getOutputCoderProto

protected org.apache.beam.model.pipeline.v1.RunnerApi.Coder getOutputCoderProto()

Specified by:

getOutputCoderProto in class BeamPythonFunctionRunner