public class LocalGroupByGate extends MemorySpliceGate
GroupingSpliceGate.DelegatedTuple
closure, count, keys, keyValues, numIncomingEventingPaths
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 |
---|
LocalGroupByGate(FlowProcess flowProcess,
Splice splice) |
Modifier and Type | Method and Description |
---|---|
void |
complete(Duct previous) |
protected boolean |
isBlockingStreamed() |
void |
prepare() |
void |
receive(Duct previous,
int ordinal,
TupleEntry incomingEntry) |
void |
start(Duct previous) |
bind, createDefaultNarrowBuilder, createKeySet, createKeyValuesArray, createTupleMap, initialize
cleanup, createNarrowBuilder, createNulledBuilder, getDelegatedTuple, getKeyComparator, getNumDeclaredIncomingBranches, initComparators
equals, getBranchNames, getFlowElement, getIncomingScopes, getOutgoingScopes, getSplice, handleException, handleReThrowableException, hashCode, hasTrapHandler, setBranchNames, setTrapHandler, toString
getNext, getNextFor, receiveFirst
public LocalGroupByGate(FlowProcess flowProcess, Splice splice)
protected boolean isBlockingStreamed()
isBlockingStreamed
in class MemorySpliceGate
public void prepare()
prepare
in class MemorySpliceGate
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>>
Copyright © 2007-2017 Cascading Maintainers. All Rights Reserved.