public abstract class TezGroupGate extends HadoopGroupGate implements InputSource
GroupingSpliceGate.DelegatedTuple
Modifier and Type | Field and Description |
---|---|
protected SortedListMultiMap<Integer,org.apache.tez.runtime.api.LogicalInput> |
logicalInputs |
protected org.apache.tez.runtime.library.output.OrderedPartitionedKVOutput |
logicalOutput |
closure, collector
groupComparators, groupHasher, grouping, groupSortTuple, groupTuple, keyBuilder, keyEntry, keyFields, keyTuple, nullsAreNotEqual, ordinalMap, sortBuilder, sortFields, tupleEntryIterator, valueComparators, valuesBuilder, valuesFields, valueTuple
flowProcess, incomingScopes, outgoingScopes, role, splice
Constructor and Description |
---|
TezGroupGate(FlowProcess flowProcess,
Splice splice,
IORole role,
org.apache.tez.runtime.api.LogicalOutput logicalOutput) |
TezGroupGate(FlowProcess flowProcess,
Splice splice,
IORole role,
SortedListMultiMap<Integer,org.apache.tez.runtime.api.LogicalInput> logicalInputs) |
Modifier and Type | Method and Description |
---|---|
protected OutputCollector |
createOutputCollector() |
void |
initialize() |
void |
prepare() |
protected abstract Throwable |
reduce() |
void |
run(Object input) |
protected void |
wrapGroupingAndCollect(Duct previous,
Tuple valuesTuple,
Tuple groupKey) |
accept, bind, complete, createClosure, receive, start, unwrapGrouping
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 org.apache.tez.runtime.library.output.OrderedPartitionedKVOutput logicalOutput
protected SortedListMultiMap<Integer,org.apache.tez.runtime.api.LogicalInput> logicalInputs
public TezGroupGate(FlowProcess flowProcess, Splice splice, IORole role, org.apache.tez.runtime.api.LogicalOutput logicalOutput)
public TezGroupGate(FlowProcess flowProcess, Splice splice, IORole role, SortedListMultiMap<Integer,org.apache.tez.runtime.api.LogicalInput> logicalInputs)
public void initialize()
initialize
in class GroupingSpliceGate
public void prepare()
prepare
in class HadoopGroupGate
public void run(Object input) throws Throwable
run
in interface InputSource
Throwable
protected void wrapGroupingAndCollect(Duct previous, Tuple valuesTuple, Tuple groupKey) throws IOException
wrapGroupingAndCollect
in class HadoopGroupGate
IOException
protected OutputCollector createOutputCollector()
createOutputCollector
in class HadoopGroupGate
Copyright © 2007-2015 Concurrent, Inc. All Rights Reserved.