@Internal public class BaseRowPythonScalarFunctionRunner extends AbstractPythonScalarFunctionRunner<BaseRow,BaseRow>
PythonFunctionRunner
used to execute Python ScalarFunction
s.
It takes BaseRow
as the input and output type.LOG
Constructor and Description |
---|
BaseRowPythonScalarFunctionRunner(String taskName,
org.apache.beam.sdk.fn.data.FnDataReceiver<BaseRow> resultReceiver,
PythonFunctionInfo[] scalarFunctions,
PythonEnvironmentManager environmentManager,
RowType inputType,
RowType outputType) |
Modifier and Type | Method and Description |
---|---|
BaseRowSerializer |
getInputTypeSerializer()
Returns the TypeSerializer for input elements.
|
BaseRowSerializer |
getOutputTypeSerializer()
Returns the TypeSerializer for execution results.
|
createExecutableStage, getInputType, getOutputType, getUserDefinedFunctionsProto
close, createJobBundleFactory, createPythonExecutionEnvironment, finishBundle, open, processElement, startBundle
public BaseRowPythonScalarFunctionRunner(String taskName, org.apache.beam.sdk.fn.data.FnDataReceiver<BaseRow> resultReceiver, PythonFunctionInfo[] scalarFunctions, PythonEnvironmentManager environmentManager, RowType inputType, RowType outputType)
public BaseRowSerializer getInputTypeSerializer()
AbstractPythonFunctionRunner
getInputTypeSerializer
in class AbstractPythonFunctionRunner<BaseRow,BaseRow>
public BaseRowSerializer getOutputTypeSerializer()
AbstractPythonFunctionRunner
getOutputTypeSerializer
in class AbstractPythonFunctionRunner<BaseRow,BaseRow>
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.