public abstract class MemorySpliceGate extends GroupingSpliceGate
GroupingSpliceGate.DelegatedTuple
Modifier and Type | Field and Description |
---|---|
protected MemoryCoGroupClosure |
closure |
protected AtomicInteger |
count |
protected Set<Tuple> |
keys |
protected Map<Tuple,Collection<Tuple>>[] |
keyValues |
protected int |
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 |
---|
MemorySpliceGate(FlowProcess flowProcess,
Splice splice) |
Modifier and Type | Method and Description |
---|---|
void |
bind(StreamGraph streamGraph) |
protected TupleBuilder |
createDefaultNarrowBuilder(Fields incomingFields,
Fields narrowFields) |
protected Set<Tuple> |
createKeySet() |
protected Map<Tuple,Collection<Tuple>>[] |
createKeyValuesArray()
This lets us just replace an old map and let the gc cleanup, vs clearing each map
|
protected Map<Tuple,Collection<Tuple>> |
createTupleMap() |
void |
initialize()
Called immediately after bind
|
protected abstract boolean |
isBlockingStreamed() |
void |
prepare() |
cleanup, createNarrowBuilder, createNulledBuilder, equals, getDelegatedTuple, getKeyComparator, getNumDeclaredIncomingBranches, hashCode, initComparators, setOrdinalMap, toString
getBranchNames, getFlowElement, getIncomingScopes, getOutgoingScopes, getSplice, handleException, handleReThrowableException, hasTrapHandler, setBranchNames, setTrapHandler
complete, getNext, getNextFor, receive, receiveFirst, start
protected Map<Tuple,Collection<Tuple>>[] keyValues
protected MemoryCoGroupClosure closure
protected int numIncomingEventingPaths
protected final AtomicInteger count
public MemorySpliceGate(FlowProcess flowProcess, Splice splice)
public void bind(StreamGraph streamGraph)
bind
in class GroupingSpliceGate
protected TupleBuilder createDefaultNarrowBuilder(Fields incomingFields, Fields narrowFields)
createDefaultNarrowBuilder
in class GroupingSpliceGate
public void initialize()
Duct
initialize
in class GroupingSpliceGate
public void prepare()
prepare
in class Duct<TupleEntry,Grouping<TupleEntry,TupleEntryIterator>>
protected Set<Tuple> createKeySet()
protected Map<Tuple,Collection<Tuple>>[] createKeyValuesArray()
protected Map<Tuple,Collection<Tuple>> createTupleMap()
protected abstract boolean isBlockingStreamed()
Copyright © 2007-2015 Concurrent, Inc. All Rights Reserved.