public class TezCoGroupGate extends TezGroupGate
GroupingSpliceGate.DelegatedTuple
Modifier and Type | Field and Description |
---|---|
protected TimedIterator<Tuple>[] |
timedIterators |
logicalInputs, logicalOutput
closure, collector
groupComparators, groupHasher, grouping, keyBuilder, keyEntry, keyFields, nullsAreNotEqual, ordinalMap, sortBuilder, sortFields, tupleEntryIterator, valueComparators, valuesBuilder, valuesFields
flowProcess, incomingScopes, outgoingScopes, role, splice
Constructor and Description |
---|
TezCoGroupGate(FlowProcess flowProcess,
CoGroup coGroup,
IORole role,
org.apache.tez.runtime.api.LogicalOutput logicalOutput) |
TezCoGroupGate(FlowProcess flowProcess,
CoGroup coGroup,
IORole role,
SortedListMultiMap<Integer,org.apache.tez.runtime.api.LogicalInput> logicalInputs) |
Modifier and Type | Method and Description |
---|---|
protected HadoopCoGroupClosure |
createClosure() |
protected Throwable |
reduce() |
protected Tuple |
unwrapGrouping(Tuple key) |
protected void |
wrapGroupingAndCollect(Duct previous,
Tuple valuesTuple,
Tuple groupKey) |
createOutputCollector, initialize, prepare, run
accept, bind, complete, receive, start
cleanup, createDefaultNarrowBuilder, createNarrowBuilder, createNulledBuilder, equals, getDelegatedTuple, getKeyComparator, getNumDeclaredIncomingBranches, hashCode, initComparators, setOrdinalMap, toString
getBranchNames, getFlowElement, getIncomingScopes, getOutgoingScopes, getSplice, handleException, handleReThrowableException, hasTrapHandler, setBranchNames, setTrapHandler
getNext, getNextFor, receiveFirst
protected TimedIterator<Tuple>[] timedIterators
public TezCoGroupGate(FlowProcess flowProcess, CoGroup coGroup, IORole role, org.apache.tez.runtime.api.LogicalOutput logicalOutput)
public TezCoGroupGate(FlowProcess flowProcess, CoGroup coGroup, IORole role, SortedListMultiMap<Integer,org.apache.tez.runtime.api.LogicalInput> logicalInputs)
protected Throwable reduce() throws Exception
reduce
in class TezGroupGate
Exception
protected HadoopCoGroupClosure createClosure()
createClosure
in class HadoopGroupGate
protected void wrapGroupingAndCollect(Duct previous, Tuple valuesTuple, Tuple groupKey) throws IOException
wrapGroupingAndCollect
in class HadoopGroupGate
IOException
protected Tuple unwrapGrouping(Tuple key)
unwrapGrouping
in class HadoopGroupGate
Copyright © 2007-2015 Concurrent, Inc. All Rights Reserved.