public abstract class HadoopGroupGate extends GroupingSpliceGate
GroupingSpliceGate.DelegatedTuple
Modifier and Type | Field and Description |
---|---|
protected HadoopGroupByClosure |
closure |
protected OutputCollector |
collector |
groupComparators, groupHasher, grouping, keyBuilder, keyEntry, keyFields, nullsAreNotEqual, ordinalMap, sortBuilder, sortFields, tupleEntryIterator, valueComparators, valuesBuilder, valuesFields
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,
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,
TupleEntry incomingEntry) |
void |
start(Duct previous) |
protected abstract Tuple |
unwrapGrouping(Tuple key) |
protected abstract void |
wrapGroupingAndCollect(Duct previous,
Tuple valuesTuple,
Tuple groupKey) |
cleanup, createDefaultNarrowBuilder, createNarrowBuilder, createNulledBuilder, equals, getDelegatedTuple, getKeyComparator, getNumDeclaredIncomingBranches, hashCode, initComparators, initialize, setOrdinalMap, toString
getBranchNames, getFlowElement, getIncomingScopes, getOutgoingScopes, getSplice, handleException, handleReThrowableException, hasTrapHandler, setBranchNames, setTrapHandler
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 GroupingSpliceGate
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, 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, Tuple valuesTuple, Tuple groupKey) throws IOException
IOException
protected abstract Tuple unwrapGrouping(Tuple key)
Copyright © 2007-2015 Concurrent, Inc. All Rights Reserved.