public abstract class TezGroupGate extends HadoopGroupGate implements InputSource
GroupingSpliceGate.DelegatedTuple
Modifier and Type | Field and Description |
---|---|
protected SortedListMultiMap<java.lang.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, 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<java.lang.Integer,org.apache.tez.runtime.api.LogicalInput> logicalInputs) |
Modifier and Type | Method and Description |
---|---|
protected OutputCollector |
createOutputCollector() |
void |
initialize() |
void |
prepare() |
protected abstract java.lang.Throwable |
reduce() |
void |
run(java.lang.Object input) |
protected void |
wrapGroupingAndCollect(Duct previous,
int ordinal,
Tuple valuesTuple,
Tuple groupKey) |
accept, bind, complete, createClosure, receive, start, unwrapGrouping
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 org.apache.tez.runtime.library.output.OrderedPartitionedKVOutput logicalOutput
protected SortedListMultiMap<java.lang.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<java.lang.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(java.lang.Object input) throws java.lang.Throwable
run
in interface InputSource
java.lang.Throwable
protected abstract java.lang.Throwable reduce() throws java.lang.Exception
java.lang.Exception
protected void wrapGroupingAndCollect(Duct previous, int ordinal, Tuple valuesTuple, Tuple groupKey) throws java.io.IOException
wrapGroupingAndCollect
in class HadoopGroupGate
java.io.IOException
protected OutputCollector createOutputCollector()
createOutputCollector
in class HadoopGroupGate
Copyright © 2007-2015 Xplenty, Inc. All Rights Reserved.