Uses of Class
org.apache.flink.table.runtime.runners.python.beam.BeamTablePythonFunctionRunner

Packages that use BeamTablePythonFunctionRunner

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

Uses of BeamTablePythonFunctionRunner in org.apache.flink.table.runtime.runners.python.beam

Methods in org.apache.flink.table.runtime.runners.python.beam that return BeamTablePythonFunctionRunner

Modifier and Type	Method	Description
static BeamTablePythonFunctionRunner	BeamTablePythonFunctionRunner.stateful(String taskName, ProcessPythonEnvironmentManager environmentManager, String functionUrn, com.google.protobuf.GeneratedMessageV3 userDefinedFunctionProto, FlinkMetricContainer flinkMetricContainer, org.apache.flink.runtime.state.KeyedStateBackend<?> keyedStateBackend, org.apache.flink.api.common.typeutils.TypeSerializer<?> keySerializer, org.apache.flink.api.common.typeutils.TypeSerializer<?> namespaceSerializer, org.apache.flink.runtime.memory.MemoryManager memoryManager, double managedMemoryFraction, FlinkFnApi.CoderInfoDescriptor inputCoderDescriptor, FlinkFnApi.CoderInfoDescriptor outputCoderDescriptor)
static BeamTablePythonFunctionRunner	BeamTablePythonFunctionRunner.stateless(String taskName, ProcessPythonEnvironmentManager environmentManager, String functionUrn, com.google.protobuf.GeneratedMessageV3 userDefinedFunctionProto, FlinkMetricContainer flinkMetricContainer, org.apache.flink.runtime.memory.MemoryManager memoryManager, double managedMemoryFraction, FlinkFnApi.CoderInfoDescriptor inputCoderDescriptor, FlinkFnApi.CoderInfoDescriptor outputCoderDescriptor)