T
- Input tuple typeR
- Output tuple type@Internal public class PlanProjectOperator<T,R extends Tuple> extends MapOperatorBase<T,R,MapFunction<T,R>>
input
broadcastInputs, userFunction
compilerHints, name, operatorInfo, parameters
Constructor and Description |
---|
PlanProjectOperator(int[] fields,
String name,
TypeInformation<T> inType,
TypeInformation<R> outType,
ExecutionConfig executionConfig) |
executeOnCollections
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 PlanProjectOperator(int[] fields, String name, TypeInformation<T> inType, TypeInformation<R> outType, ExecutionConfig executionConfig)
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.