public abstract class HadoopGroupGate extends GroupingSpliceGate
GroupingSpliceGate.DelegatedTuple
Modifier and Type | Field and Description |
---|---|
protected HadoopGroupByClosure |
closure |
protected OutputCollector |
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 |
---|
HadoopGroupGate(FlowProcess flowProcess,
Splice splice,
IORole role) |
Modifier and Type | Method and Description |
---|---|
void |
accept(Tuple key,
java.util.Iterator<Tuple>[] values) |
void |
bind(StreamGraph streamGraph) |
void |
complete(Duct previous) |
protected abstract HadoopGroupByClosure |
createClosure() |
protected abstract OutputCollector |
createOutputCollector() |
void |
prepare() |
void |
receive(Duct previous,
int ordinal,
TupleEntry incomingEntry) |
void |
start(Duct previous) |
protected abstract Tuple |
unwrapGrouping(Tuple key) |
protected abstract void |
wrapGroupingAndCollect(Duct previous,
int ordinal,
Tuple valuesTuple,
Tuple groupKey) |
cleanup, createDefaultNarrowBuilder, createNarrowBuilder, createNulledBuilder, getDelegatedTuple, getKeyComparator, getNumDeclaredIncomingBranches, initComparators, initialize
equals, getBranchNames, getFlowElement, getIncomingScopes, getOutgoingScopes, getSplice, handleException, handleReThrowableException, hashCode, hasTrapHandler, setBranchNames, setTrapHandler, toString
getNext, getNextFor, receiveFirst
protected HadoopGroupByClosure closure
protected OutputCollector collector
public HadoopGroupGate(FlowProcess flowProcess, Splice splice, IORole role)
public void bind(StreamGraph streamGraph)
bind
in class Duct<TupleEntry,Grouping<TupleEntry,TupleEntryIterator>>
public void prepare()
prepare
in class Duct<TupleEntry,Grouping<TupleEntry,TupleEntryIterator>>
protected abstract OutputCollector createOutputCollector()
public void start(Duct previous)
start
in class Duct<TupleEntry,Grouping<TupleEntry,TupleEntryIterator>>
public void receive(Duct previous, int ordinal, TupleEntry incomingEntry)
receive
in class Duct<TupleEntry,Grouping<TupleEntry,TupleEntryIterator>>
public void complete(Duct previous)
complete
in class Duct<TupleEntry,Grouping<TupleEntry,TupleEntryIterator>>
protected abstract HadoopGroupByClosure createClosure()
protected abstract void wrapGroupingAndCollect(Duct previous, int ordinal, Tuple valuesTuple, Tuple groupKey) throws java.io.IOException
java.io.IOException
protected abstract Tuple unwrapGrouping(Tuple key)
Copyright © 2007-2015 Xplenty, Inc. All Rights Reserved.