public class TezGroupByGate extends TezGroupGate
Modifier and Type | Field and Description |
---|---|
protected TimedIterator[] |
timedIterators |
logicalInputs, logicalOutput
closure, collector
groupComparators, groupHasher, grouping, groupSortTuple, groupTuple, keyBuilder, keyEntry, keyFields, keyTuple, nullsAreNotEqual, sortBuilder, sortFields, tupleEntryIterator, valueComparators, valuesBuilder, valuesFields, valueTuple
Constructor and Description |
---|
TezGroupByGate(cascading.flow.FlowProcess flowProcess,
cascading.pipe.GroupBy groupBy,
cascading.flow.stream.graph.IORole role,
org.apache.tez.runtime.api.LogicalOutput logicalOutput) |
TezGroupByGate(cascading.flow.FlowProcess flowProcess,
cascading.pipe.GroupBy groupBy,
cascading.flow.stream.graph.IORole role,
cascading.util.SortedListMultiMap<java.lang.Integer,org.apache.tez.runtime.api.LogicalInput> logicalInputs) |
Modifier and Type | Method and Description |
---|---|
protected HadoopGroupByClosure |
createClosure() |
protected java.lang.Throwable |
reduce() |
protected cascading.tuple.Tuple |
unwrapGrouping(cascading.tuple.Tuple key) |
createOutputCollector, initialize, prepare, run, wrapGroupingAndCollect
accept, bind, complete, receive, start
cleanup, createDefaultNarrowBuilder, createNarrowBuilder, createNulledBuilder, getDelegatedTuple, getKeyComparator, getNumDeclaredIncomingBranches, initComparators
protected TimedIterator[] timedIterators
public TezGroupByGate(cascading.flow.FlowProcess flowProcess, cascading.pipe.GroupBy groupBy, cascading.flow.stream.graph.IORole role, org.apache.tez.runtime.api.LogicalOutput logicalOutput)
public TezGroupByGate(cascading.flow.FlowProcess flowProcess, cascading.pipe.GroupBy groupBy, cascading.flow.stream.graph.IORole role, cascading.util.SortedListMultiMap<java.lang.Integer,org.apache.tez.runtime.api.LogicalInput> logicalInputs)
protected java.lang.Throwable reduce() throws java.lang.Exception
reduce
in class TezGroupGate
java.lang.Exception
protected HadoopGroupByClosure createClosure()
createClosure
in class HadoopGroupGate
protected cascading.tuple.Tuple unwrapGrouping(cascading.tuple.Tuple key)
unwrapGrouping
in class HadoopGroupGate
Copyright © 2007-2015 Xplenty, Inc. All Rights Reserved.