Package | Description |
---|---|
org.apache.flink.table.runtime.operators.python | |
org.apache.flink.table.runtime.runners.python |
Modifier and Type | Field and Description |
---|---|
protected PythonFunctionInfo[] |
AbstractPythonScalarFunctionOperator.scalarFunctions
The Python
ScalarFunction s to be executed. |
Constructor and Description |
---|
BaseRowPythonScalarFunctionOperator(Configuration config,
PythonFunctionInfo[] scalarFunctions,
RowType inputType,
RowType outputType,
int[] udfInputOffsets,
int[] forwardedFields) |
PythonScalarFunctionOperator(Configuration config,
PythonFunctionInfo[] scalarFunctions,
RowType inputType,
RowType outputType,
int[] udfInputOffsets,
int[] forwardedFields) |
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.