Constructor and Description |
---|
AbstractPythonFunctionRunner(String taskName,
org.apache.beam.sdk.fn.data.FnDataReceiver<OUT> resultReceiver,
PythonEnvironmentManager environmentManager,
org.apache.beam.runners.fnexecution.state.StateRequestHandler stateRequestHandler) |
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 |
---|---|
PythonFunctionRunner<BaseRow> |
BaseRowPythonScalarFunctionOperator.createPythonFunctionRunner(org.apache.beam.sdk.fn.data.FnDataReceiver<BaseRow> resultReceiver,
PythonEnvironmentManager pythonEnvironmentManager) |
PythonFunctionRunner<Row> |
PythonScalarFunctionOperator.createPythonFunctionRunner(org.apache.beam.sdk.fn.data.FnDataReceiver<Row> resultReceiver,
PythonEnvironmentManager pythonEnvironmentManager) |
abstract PythonFunctionRunner<UDFIN> |
AbstractPythonScalarFunctionOperator.createPythonFunctionRunner(org.apache.beam.sdk.fn.data.FnDataReceiver<UDFOUT> resultReceiver,
PythonEnvironmentManager pythonEnvironmentManager) |
Constructor and Description |
---|
AbstractPythonScalarFunctionRunner(String taskName,
org.apache.beam.sdk.fn.data.FnDataReceiver<OUT> resultReceiver,
PythonFunctionInfo[] scalarFunctions,
PythonEnvironmentManager environmentManager,
RowType inputType,
RowType outputType) |
BaseRowPythonScalarFunctionRunner(String taskName,
org.apache.beam.sdk.fn.data.FnDataReceiver<BaseRow> resultReceiver,
PythonFunctionInfo[] scalarFunctions,
PythonEnvironmentManager environmentManager,
RowType inputType,
RowType outputType) |
PythonScalarFunctionRunner(String taskName,
org.apache.beam.sdk.fn.data.FnDataReceiver<Row> resultReceiver,
PythonFunctionInfo[] scalarFunctions,
PythonEnvironmentManager environmentManager,
RowType inputType,
RowType outputType) |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.