@Internal public class PlanUnwrappingSortedGroupCombineOperator<IN,OUT,K1,K2> extends GroupCombineOperatorBase<Tuple3<K1,K2,IN>,OUT,GroupCombineFunction<Tuple3<K1,K2,IN>,OUT>>
input
broadcastInputs, userFunction
compilerHints, name, operatorInfo, parameters
Constructor and Description |
---|
PlanUnwrappingSortedGroupCombineOperator(GroupCombineFunction<IN,OUT> udf,
Keys.SelectorFunctionKeys<IN,K1> groupingKey,
Keys.SelectorFunctionKeys<IN,K2> sortingKey,
String name,
TypeInformation<OUT> outType,
TypeInformation<Tuple3<K1,K2,IN>> typeInfoWithKey) |
executeOnCollections, getGroupOrder, setGroupOrder
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 PlanUnwrappingSortedGroupCombineOperator(GroupCombineFunction<IN,OUT> udf, Keys.SelectorFunctionKeys<IN,K1> groupingKey, Keys.SelectorFunctionKeys<IN,K2> sortingKey, String name, TypeInformation<OUT> outType, TypeInformation<Tuple3<K1,K2,IN>> typeInfoWithKey)
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.