public class HadoopMemoryJoinGate extends MemoryHashJoinGate
Modifier and Type | Class and Description |
---|---|
static class |
HadoopMemoryJoinGate.Spill |
GroupingSpliceGate.DelegatedTuple
latch
closure, count, keys, keyValues, numIncomingEventingPaths
groupComparators, groupHasher, grouping, keyBuilder, keyEntry, keyFields, nullsAreNotEqual, ordinalMap, sortBuilder, sortFields, tupleEntryIterator, valueComparators, valuesBuilder, valuesFields
flowProcess, incomingScopes, outgoingScopes, role, splice
Constructor and Description |
---|
HadoopMemoryJoinGate(FlowProcess<? extends Configuration> flowProcess,
HashJoin join) |
Modifier and Type | Method and Description |
---|---|
protected void |
countDownLatch() |
protected Set<Tuple> |
createKeySet() |
protected Map<Tuple,Collection<Tuple>> |
createTupleMap() |
protected void |
waitOnLatch() |
bind, complete, isBlockingStreamed, prepare, receive
createDefaultNarrowBuilder, createKeyValuesArray, initialize
cleanup, createNarrowBuilder, createNulledBuilder, equals, getDelegatedTuple, getKeyComparator, getNumDeclaredIncomingBranches, hashCode, initComparators, setOrdinalMap, toString
getBranchNames, getFlowElement, getIncomingScopes, getOutgoingScopes, getSplice, handleException, handleReThrowableException, hasTrapHandler, setBranchNames, setTrapHandler
getNext, getNextFor, receiveFirst, start
public HadoopMemoryJoinGate(FlowProcess<? extends Configuration> flowProcess, HashJoin join)
protected Set<Tuple> createKeySet()
createKeySet
in class MemorySpliceGate
protected Map<Tuple,Collection<Tuple>> createTupleMap()
createTupleMap
in class MemorySpliceGate
protected void waitOnLatch()
waitOnLatch
in class MemoryHashJoinGate
protected void countDownLatch()
countDownLatch
in class MemoryHashJoinGate
Copyright © 2007-2015 Concurrent, Inc. All Rights Reserved.