@Internal public class PlanUnwrappingReduceGroupOperator<IN,OUT,K> extends GroupReduceOperatorBase<Tuple2<K,IN>,OUT,GroupReduceFunction<Tuple2<K,IN>,OUT>>
Modifier and Type | Class and Description |
---|---|
static class |
PlanUnwrappingReduceGroupOperator.TupleUnwrappingGroupCombinableGroupReducer<IN,OUT,K> |
static class |
PlanUnwrappingReduceGroupOperator.TupleUnwrappingNonCombinableGroupReducer<IN,OUT,K> |
input
broadcastInputs, userFunction
compilerHints, name, operatorInfo, parameters
Constructor and Description |
---|
PlanUnwrappingReduceGroupOperator(GroupReduceFunction<IN,OUT> udf,
Keys.SelectorFunctionKeys<IN,K> key,
String name,
TypeInformation<OUT> outType,
TypeInformation<Tuple2<K,IN>> typeInfoWithKey,
boolean combinable) |
executeOnCollections, getCustomPartitioner, getGroupOrder, isCombinable, setCombinable, setCustomPartitioner, setGroupOrder
accept, addInput, addInput, clearInputs, getInput, getKeyColumns, getNumberOfInputs, getOperatorInfo, getSemanticProperties, setInput, setInput, setInputs, setSemanticProperties
asArray, emptyClassArray, getBroadcastInputs, getUserCodeWrapper, setBroadcastVariable, setBroadcastVariables
createUnionCascade, createUnionCascade, createUnionCascade, getCompilerHints, getName, getParallelism, getParameters, setName, setParallelism, setParameter, setParameter, setParameter, toString
public PlanUnwrappingReduceGroupOperator(GroupReduceFunction<IN,OUT> udf, Keys.SelectorFunctionKeys<IN,K> key, String name, TypeInformation<OUT> outType, TypeInformation<Tuple2<K,IN>> typeInfoWithKey, boolean combinable)
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.