Modifier and Type | Class and Description |
---|---|
class |
AbstractPythonFunctionRunner<IN,OUT>
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 |
---|---|
PythonFunctionRunner<IN> |
AbstractPythonScalarFunctionOperator.createPythonFunctionRunner() |
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) |
Modifier and Type | Class and Description |
---|---|
class |
AbstractPythonScalarFunctionRunner<IN,OUT>
Abstract
PythonFunctionRunner used to execute Python ScalarFunction s. |
class |
BaseRowPythonScalarFunctionRunner
A
PythonFunctionRunner used to execute Python ScalarFunction s. |
class |
PythonScalarFunctionRunner
A
PythonFunctionRunner used to execute Python ScalarFunction s. |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.