Modifier and Type | Class and Description |
---|---|
class |
AbstractPythonFunctionRunner<IN>
An base class for
PythonFunctionRunner . |
Modifier and Type | Method and Description |
---|---|
abstract PythonFunctionRunner<IN> |
AbstractPythonFunctionOperator.createPythonFunctionRunner()
Creates the
PythonFunctionRunner which is responsible for Python user-defined
function execution. |
Modifier and Type | Method and Description |
---|---|
abstract PythonFunctionRunner<Row> |
AbstractPythonStatelessFunctionFlatMap.createPythonFunctionRunner() |
PythonFunctionRunner<Row> |
PythonTableFunctionFlatMap.createPythonFunctionRunner() |
PythonFunctionRunner<Row> |
PythonScalarFunctionFlatMap.createPythonFunctionRunner() |
Modifier and Type | Method and Description |
---|---|
PythonFunctionRunner<Row> |
ArrowPythonScalarFunctionFlatMap.createPythonFunctionRunner() |
Modifier and Type | Method and Description |
---|---|
PythonFunctionRunner<IN> |
AbstractStatelessFunctionOperator.createPythonFunctionRunner() |
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) |
Modifier and Type | Class and Description |
---|---|
class |
AbstractPythonStatelessFunctionRunner<IN>
Abstract
PythonFunctionRunner used to execute Python stateless functions.. |
Modifier and Type | Class and Description |
---|---|
class |
AbstractGeneralPythonScalarFunctionRunner<IN>
Abstract
PythonFunctionRunner used to execute Python ScalarFunction s. |
class |
AbstractPythonScalarFunctionRunner<IN>
Abstract
PythonFunctionRunner used to execute Python ScalarFunction s. |
class |
PythonScalarFunctionRunner
A
PythonFunctionRunner used to execute Python ScalarFunction s. |
class |
RowDataPythonScalarFunctionRunner
A
PythonFunctionRunner used to execute Python ScalarFunction s. |
Modifier and Type | Class and Description |
---|---|
class |
AbstractArrowPythonScalarFunctionRunner<IN>
Abstract
PythonFunctionRunner used to execute Arrow Python ScalarFunction s. |
class |
ArrowPythonScalarFunctionRunner
A
PythonFunctionRunner used to execute Arrow Python ScalarFunction s. |
class |
RowDataArrowPythonScalarFunctionRunner
A
PythonFunctionRunner used to execute Arrow Python ScalarFunction s. |
Modifier and Type | Class and Description |
---|---|
class |
AbstractPythonTableFunctionRunner<IN>
Abstract
PythonFunctionRunner used to execute Python TableFunction . |
class |
PythonTableFunctionRunner
A
PythonFunctionRunner used to execute Python TableFunction . |
class |
RowDataPythonTableFunctionRunner
A
PythonFunctionRunner used to execute Python TableFunction . |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.