@Internal public class PythonScalarFunctionFlatMap extends AbstractPythonScalarFunctionFlatMap
RichFlatMapFunction
used to invoke Python ScalarFunction
functions for the
old planner.scalarFunctions
bais, baisWrapper, forwardedInputQueue, forwardedInputSerializer, inputType, jobOptions, outputType, resultCollector, userDefinedFunctionInputType, userDefinedFunctionOutputType, userDefinedFunctionResultQueue, userDefinedFunctionTypeSerializer
Constructor and Description |
---|
PythonScalarFunctionFlatMap(Configuration config,
PythonFunctionInfo[] scalarFunctions,
RowType inputType,
RowType outputType,
int[] udfInputOffsets,
int[] forwardedFields) |
Modifier and Type | Method and Description |
---|---|
PythonFunctionRunner<Row> |
createPythonFunctionRunner() |
void |
emitResults() |
bufferInput, getForwardedFieldsCount, getPythonEnv, open
close, createPythonEnvironmentManager, flatMap, getFlinkMetricContainer, getProducedType, getPythonConfig
getIterationRuntimeContext, getRuntimeContext, setRuntimeContext
public PythonScalarFunctionFlatMap(Configuration config, PythonFunctionInfo[] scalarFunctions, RowType inputType, RowType outputType, int[] udfInputOffsets, int[] forwardedFields)
public PythonFunctionRunner<Row> createPythonFunctionRunner() throws IOException
createPythonFunctionRunner
in class AbstractPythonStatelessFunctionFlatMap
IOException
public void emitResults() throws IOException
emitResults
in class AbstractPythonStatelessFunctionFlatMap
IOException
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.