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