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