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, groupSortTuple, groupTuple, keyBuilder, keyEntry, keyFields, keyTuple, nullsAreNotEqual, sortBuilder, sortFields, tupleEntryIterator, valueComparators, valuesBuilder, valuesFields, valueTuple
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 java.util.Set<Tuple> |
createKeySet() |
protected java.util.Map<Tuple,java.util.Collection<Tuple>> |
createTupleMap() |
protected void |
waitOnLatch() |
bind, complete, isBlockingStreamed, prepare, receive
createDefaultNarrowBuilder, createKeyValuesArray, 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
public HadoopMemoryJoinGate(FlowProcess<? extends Configuration> flowProcess, HashJoin join)
protected java.util.Set<Tuple> createKeySet()
createKeySet
in class MemorySpliceGate
protected java.util.Map<Tuple,java.util.Collection<Tuple>> createTupleMap()
createTupleMap
in class MemorySpliceGate
protected void waitOnLatch()
waitOnLatch
in class MemoryHashJoinGate
protected void countDownLatch()
countDownLatch
in class MemoryHashJoinGate
Copyright © 2007-2015 Xplenty, Inc. All Rights Reserved.