Constructor and Description |
---|
AbstractPythonFunctionRunner(String taskName,
org.apache.beam.sdk.fn.data.FnDataReceiver<byte[]> resultReceiver,
PythonEnvironmentManager environmentManager,
org.apache.beam.runners.fnexecution.state.StateRequestHandler stateRequestHandler,
Map<String,String> jobOptions,
FlinkMetricContainer flinkMetricContainer) |
Modifier and Type | Class and Description |
---|---|
class |
ProcessPythonEnvironmentManager
The ProcessPythonEnvironmentManager is used to prepare the working dir of python UDF worker and
create ProcessEnvironment object of Beam Fn API.
|
Modifier and Type | Method and Description |
---|---|
protected PythonEnvironmentManager |
AbstractPythonFunctionOperator.createPythonEnvironmentManager() |
Modifier and Type | Method and Description |
---|---|
protected PythonEnvironmentManager |
AbstractPythonStatelessFunctionFlatMap.createPythonEnvironmentManager() |
Modifier and Type | Method and Description |
---|---|
abstract PythonFunctionRunner<UDFIN> |
AbstractStatelessFunctionOperator.createPythonFunctionRunner(org.apache.beam.sdk.fn.data.FnDataReceiver<byte[]> resultReceiver,
PythonEnvironmentManager pythonEnvironmentManager,
Map<String,String> jobOptions) |
Modifier and Type | Method and Description |
---|---|
PythonFunctionRunner<RowData> |
RowDataPythonScalarFunctionOperator.createPythonFunctionRunner(org.apache.beam.sdk.fn.data.FnDataReceiver<byte[]> resultReceiver,
PythonEnvironmentManager pythonEnvironmentManager,
Map<String,String> jobOptions) |
PythonFunctionRunner<Row> |
PythonScalarFunctionOperator.createPythonFunctionRunner(org.apache.beam.sdk.fn.data.FnDataReceiver<byte[]> resultReceiver,
PythonEnvironmentManager pythonEnvironmentManager,
Map<String,String> jobOptions) |
Modifier and Type | Method and Description |
---|---|
PythonFunctionRunner<RowData> |
RowDataArrowPythonScalarFunctionOperator.createPythonFunctionRunner(org.apache.beam.sdk.fn.data.FnDataReceiver<byte[]> resultReceiver,
PythonEnvironmentManager pythonEnvironmentManager,
Map<String,String> jobOptions) |
PythonFunctionRunner<Row> |
ArrowPythonScalarFunctionOperator.createPythonFunctionRunner(org.apache.beam.sdk.fn.data.FnDataReceiver<byte[]> resultReceiver,
PythonEnvironmentManager pythonEnvironmentManager,
Map<String,String> jobOptions) |
Modifier and Type | Method and Description |
---|---|
PythonFunctionRunner<RowData> |
RowDataPythonTableFunctionOperator.createPythonFunctionRunner(org.apache.beam.sdk.fn.data.FnDataReceiver<byte[]> resultReceiver,
PythonEnvironmentManager pythonEnvironmentManager,
Map<String,String> jobOptions) |
PythonFunctionRunner<Row> |
PythonTableFunctionOperator.createPythonFunctionRunner(org.apache.beam.sdk.fn.data.FnDataReceiver<byte[]> resultReceiver,
PythonEnvironmentManager pythonEnvironmentManager,
Map<String,String> jobOptions) |
Constructor and Description |
---|
AbstractPythonStatelessFunctionRunner(String taskName,
org.apache.beam.sdk.fn.data.FnDataReceiver<byte[]> resultReceiver,
PythonEnvironmentManager environmentManager,
RowType inputType,
RowType outputType,
String functionUrn,
Map<String,String> jobOptions,
FlinkMetricContainer flinkMetricContainer) |
Constructor and Description |
---|
AbstractGeneralPythonScalarFunctionRunner(String taskName,
org.apache.beam.sdk.fn.data.FnDataReceiver<byte[]> resultReceiver,
PythonFunctionInfo[] scalarFunctions,
PythonEnvironmentManager environmentManager,
RowType inputType,
RowType outputType,
Map<String,String> jobOptions,
FlinkMetricContainer flinkMetricContainer) |
AbstractPythonScalarFunctionRunner(String taskName,
org.apache.beam.sdk.fn.data.FnDataReceiver<byte[]> resultReceiver,
PythonFunctionInfo[] scalarFunctions,
PythonEnvironmentManager environmentManager,
RowType inputType,
RowType outputType,
Map<String,String> jobOptions,
FlinkMetricContainer flinkMetricContainer) |
PythonScalarFunctionRunner(String taskName,
org.apache.beam.sdk.fn.data.FnDataReceiver<byte[]> resultReceiver,
PythonFunctionInfo[] scalarFunctions,
PythonEnvironmentManager environmentManager,
RowType inputType,
RowType outputType,
Map<String,String> jobOptions,
FlinkMetricContainer flinkMetricContainer) |
RowDataPythonScalarFunctionRunner(String taskName,
org.apache.beam.sdk.fn.data.FnDataReceiver<byte[]> resultReceiver,
PythonFunctionInfo[] scalarFunctions,
PythonEnvironmentManager environmentManager,
RowType inputType,
RowType outputType,
Map<String,String> jobOptions,
FlinkMetricContainer flinkMetricContainer) |
Constructor and Description |
---|
AbstractArrowPythonScalarFunctionRunner(String taskName,
org.apache.beam.sdk.fn.data.FnDataReceiver<byte[]> resultReceiver,
PythonFunctionInfo[] scalarFunctions,
PythonEnvironmentManager environmentManager,
RowType inputType,
RowType outputType,
int maxArrowBatchSize,
Map<String,String> jobOptions,
FlinkMetricContainer flinkMetricContainer) |
ArrowPythonScalarFunctionRunner(String taskName,
org.apache.beam.sdk.fn.data.FnDataReceiver<byte[]> resultReceiver,
PythonFunctionInfo[] scalarFunctions,
PythonEnvironmentManager environmentManager,
RowType inputType,
RowType outputType,
int maxArrowBatchSize,
Map<String,String> jobOptions,
FlinkMetricContainer flinkMetricContainer) |
RowDataArrowPythonScalarFunctionRunner(String taskName,
org.apache.beam.sdk.fn.data.FnDataReceiver<byte[]> resultReceiver,
PythonFunctionInfo[] scalarFunctions,
PythonEnvironmentManager environmentManager,
RowType inputType,
RowType outputType,
int maxBatchSize,
Map<String,String> jobOptions,
FlinkMetricContainer flinkMetricContainer) |
Constructor and Description |
---|
AbstractPythonTableFunctionRunner(String taskName,
org.apache.beam.sdk.fn.data.FnDataReceiver<byte[]> resultReceiver,
PythonFunctionInfo tableFunction,
PythonEnvironmentManager environmentManager,
RowType inputType,
RowType outputType,
Map<String,String> jobOptions,
FlinkMetricContainer flinkMetricContainer) |
PythonTableFunctionRunner(String taskName,
org.apache.beam.sdk.fn.data.FnDataReceiver<byte[]> resultReceiver,
PythonFunctionInfo tableFunction,
PythonEnvironmentManager environmentManager,
RowType inputType,
RowType outputType,
Map<String,String> jobOptions,
FlinkMetricContainer flinkMetricContainer) |
RowDataPythonTableFunctionRunner(String taskName,
org.apache.beam.sdk.fn.data.FnDataReceiver<byte[]> resultReceiver,
PythonFunctionInfo tableFunction,
PythonEnvironmentManager environmentManager,
RowType inputType,
RowType outputType,
Map<String,String> jobOptions,
FlinkMetricContainer flinkMetricContainer) |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.