public class MemoryHashJoinGate extends MemorySpliceGate
GroupingSpliceGate.DelegatedTuple
Modifier and Type | Field and Description |
---|---|
protected java.util.concurrent.CountDownLatch |
latch |
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 |
---|
MemoryHashJoinGate(FlowProcess flowProcess,
HashJoin join) |
Modifier and Type | Method and Description |
---|---|
void |
bind(StreamGraph streamGraph) |
void |
complete(Duct previous) |
protected void |
countDownLatch() |
protected boolean |
isBlockingStreamed() |
void |
prepare() |
void |
receive(Duct previous,
int ordinal,
TupleEntry incomingEntry) |
protected void |
waitOnLatch() |
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, start
protected java.util.concurrent.CountDownLatch latch
public MemoryHashJoinGate(FlowProcess flowProcess, HashJoin join)
public void bind(StreamGraph streamGraph)
bind
in class MemorySpliceGate
public void prepare()
prepare
in class MemorySpliceGate
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>>
protected void waitOnLatch()
protected void countDownLatch()
protected boolean isBlockingStreamed()
isBlockingStreamed
in class MemorySpliceGate
Copyright © 2007-2015 Xplenty, Inc. All Rights Reserved.