public class TezGroupByGate extends TezGroupGate
GroupingSpliceGate.DelegatedTuple
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
flowProcess, incomingScopes, outgoingScopes, role, splice
Constructor and Description |
---|
TezGroupByGate(FlowProcess flowProcess,
GroupBy groupBy,
IORole role,
org.apache.tez.runtime.api.LogicalOutput logicalOutput) |
TezGroupByGate(FlowProcess flowProcess,
GroupBy groupBy,
IORole role,
SortedListMultiMap<Integer,org.apache.tez.runtime.api.LogicalInput> logicalInputs) |
Modifier and Type | Method and Description |
---|---|
protected HadoopGroupByClosure |
createClosure() |
protected Throwable |
reduce() |
protected Tuple |
unwrapGrouping(Tuple key) |
createOutputCollector, initialize, prepare, run, wrapGroupingAndCollect
accept, bind, complete, receive, start
cleanup, createDefaultNarrowBuilder, createNarrowBuilder, createNulledBuilder, getDelegatedTuple, getKeyComparator, getNumDeclaredIncomingBranches, initComparators
equals, getBranchNames, getFlowElement, getIncomingScopes, getOutgoingScopes, getSplice, handleException, handleReThrowableException, hashCode, hasTrapHandler, setBranchNames, setTrapHandler, toString
getNext, getNextFor, receiveFirst
protected TimedIterator[] timedIterators
public TezGroupByGate(FlowProcess flowProcess, GroupBy groupBy, IORole role, org.apache.tez.runtime.api.LogicalOutput logicalOutput)
public TezGroupByGate(FlowProcess flowProcess, GroupBy groupBy, IORole role, SortedListMultiMap<Integer,org.apache.tez.runtime.api.LogicalInput> logicalInputs)
protected Throwable reduce() throws Exception
reduce
in class TezGroupGate
Exception
protected HadoopGroupByClosure createClosure()
createClosure
in class HadoopGroupGate
protected Tuple unwrapGrouping(Tuple key)
unwrapGrouping
in class HadoopGroupGate
Copyright © 2007-2015 Xplenty, Inc. All Rights Reserved.