IN
- The input type.OUT
- The result type.FT
- The type of the user-defined function.@Internal public class MapPartitionOperatorBase<IN,OUT,FT extends MapPartitionFunction<IN,OUT>> extends SingleInputOperator<IN,OUT,FT>
input
broadcastInputs, userFunction
compilerHints, name, operatorInfo, parameters
Constructor and Description |
---|
MapPartitionOperatorBase(Class<? extends FT> udf,
UnaryOperatorInformation<IN,OUT> operatorInfo,
String name) |
MapPartitionOperatorBase(FT udf,
UnaryOperatorInformation<IN,OUT> operatorInfo,
String name) |
MapPartitionOperatorBase(UserCodeWrapper<FT> udf,
UnaryOperatorInformation<IN,OUT> operatorInfo,
String name) |
Modifier and Type | Method and Description |
---|---|
protected List<OUT> |
executeOnCollections(List<IN> inputData,
RuntimeContext ctx,
ExecutionConfig executionConfig) |
accept, addInput, addInput, clearInputs, getInput, getKeyColumns, getNumberOfInputs, getOperatorInfo, getSemanticProperties, setInput, setInput, setInputs, setSemanticProperties
asArray, emptyClassArray, getBroadcastInputs, getUserCodeWrapper, setBroadcastVariable, setBroadcastVariables
createUnionCascade, createUnionCascade, createUnionCascade, getCompilerHints, getMinResources, getName, getParallelism, getParameters, getPreferredResources, setName, setParallelism, setParameter, setParameter, setParameter, setResources, toString
public MapPartitionOperatorBase(UserCodeWrapper<FT> udf, UnaryOperatorInformation<IN,OUT> operatorInfo, String name)
public MapPartitionOperatorBase(FT udf, UnaryOperatorInformation<IN,OUT> operatorInfo, String name)
protected List<OUT> executeOnCollections(List<IN> inputData, RuntimeContext ctx, ExecutionConfig executionConfig) throws Exception
executeOnCollections
in class SingleInputOperator<IN,OUT,FT extends MapPartitionFunction<IN,OUT>>
Exception
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.