Modifier and Type | Method and Description |
---|---|
protected FlinkMetricContainer |
AbstractPythonFunctionOperator.getFlinkMetricContainer() |
Constructor and Description |
---|
BeamDataStreamPythonFunctionRunner(String taskName,
PythonEnvironmentManager environmentManager,
TypeInformation inputType,
TypeInformation outputType,
String functionUrn,
FlinkFnApi.UserDefinedDataStreamFunction userDefinedDataStreamFunction,
String coderUrn,
Map<String,String> jobOptions,
FlinkMetricContainer flinkMetricContainer,
KeyedStateBackend stateBackend,
TypeSerializer keySerializer,
TypeSerializer namespaceSerializer,
MemoryManager memoryManager,
double managedMemoryFraction) |
BeamPythonFunctionRunner(String taskName,
PythonEnvironmentManager environmentManager,
String functionUrn,
Map<String,String> jobOptions,
FlinkMetricContainer flinkMetricContainer,
KeyedStateBackend keyedStateBackend,
TypeSerializer keySerializer,
TypeSerializer namespaceSerializer,
MemoryManager memoryManager,
double managedMemoryFraction,
FlinkFnApi.CoderParam.OutputMode outputMode) |
Modifier and Type | Method and Description |
---|---|
protected FlinkMetricContainer |
AbstractPythonStatelessFunctionFlatMap.getFlinkMetricContainer() |
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,
TypeSerializer namespaceSerializer,
MemoryManager memoryManager,
double managedMemoryFraction,
FlinkFnApi.CoderParam.OutputMode outputMode) |
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) |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.