Modifier and Type | Method and Description |
---|---|
protected FlinkMetricContainer |
AbstractPythonFunctionOperator.getFlinkMetricContainer() |
Constructor and Description |
---|
BeamDataStreamPythonFunctionRunner(String taskName,
PythonEnvironmentManager environmentManager,
String headOperatorFunctionUrn,
List<FlinkFnApi.UserDefinedDataStreamFunction> userDefinedDataStreamFunctions,
Map<String,String> jobOptions,
FlinkMetricContainer flinkMetricContainer,
KeyedStateBackend<?> stateBackend,
TypeSerializer<?> keySerializer,
TypeSerializer<?> namespaceSerializer,
TimerRegistration timerRegistration,
MemoryManager memoryManager,
double managedMemoryFraction,
FlinkFnApi.CoderInfoDescriptor inputCoderDescriptor,
FlinkFnApi.CoderInfoDescriptor outputCoderDescriptor,
FlinkFnApi.CoderInfoDescriptor timerCoderDescriptor) |
BeamPythonFunctionRunner(String taskName,
PythonEnvironmentManager environmentManager,
Map<String,String> jobOptions,
FlinkMetricContainer flinkMetricContainer,
KeyedStateBackend keyedStateBackend,
TypeSerializer keySerializer,
TypeSerializer namespaceSerializer,
TimerRegistration timerRegistration,
MemoryManager memoryManager,
double managedMemoryFraction,
FlinkFnApi.CoderInfoDescriptor inputCoderDescriptor,
FlinkFnApi.CoderInfoDescriptor outputCoderDescriptor) |
Modifier and Type | Method and Description |
---|---|
static BeamTablePythonFunctionRunner |
BeamTablePythonFunctionRunner.stateful(String taskName,
PythonEnvironmentManager environmentManager,
String functionUrn,
com.google.protobuf.GeneratedMessageV3 userDefinedFunctionProto,
Map<String,String> jobOptions,
FlinkMetricContainer flinkMetricContainer,
KeyedStateBackend<?> keyedStateBackend,
TypeSerializer<?> keySerializer,
TypeSerializer<?> namespaceSerializer,
MemoryManager memoryManager,
double managedMemoryFraction,
FlinkFnApi.CoderInfoDescriptor inputCoderDescriptor,
FlinkFnApi.CoderInfoDescriptor outputCoderDescriptor) |
static BeamTablePythonFunctionRunner |
BeamTablePythonFunctionRunner.stateless(String taskName,
PythonEnvironmentManager environmentManager,
String functionUrn,
com.google.protobuf.GeneratedMessageV3 userDefinedFunctionProto,
Map<String,String> jobOptions,
FlinkMetricContainer flinkMetricContainer,
MemoryManager memoryManager,
double managedMemoryFraction,
FlinkFnApi.CoderInfoDescriptor inputCoderDescriptor,
FlinkFnApi.CoderInfoDescriptor outputCoderDescriptor) |
Constructor and Description |
---|
BeamTablePythonFunctionRunner(String taskName,
PythonEnvironmentManager environmentManager,
String functionUrn,
com.google.protobuf.GeneratedMessageV3 userDefinedFunctionProto,
Map<String,String> jobOptions,
FlinkMetricContainer flinkMetricContainer,
KeyedStateBackend<?> keyedStateBackend,
TypeSerializer<?> keySerializer,
TypeSerializer<?> namespaceSerializer,
MemoryManager memoryManager,
double managedMemoryFraction,
FlinkFnApi.CoderInfoDescriptor inputCoderDescriptor,
FlinkFnApi.CoderInfoDescriptor outputCoderDescriptor) |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.