|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object cascading.flow.stream.Duct<Incoming,Outgoing> cascading.flow.stream.Gate<cascading.tuple.TupleEntry,cascading.flow.stream.Grouping<cascading.tuple.TupleEntry,cascading.tuple.TupleEntryIterator>> cascading.flow.stream.SpliceGate cascading.flow.stream.MemorySpliceGate cascading.flow.stream.MemoryHashJoinGate cascading.flow.hadoop.stream.HadoopMemoryJoinGate
public class HadoopMemoryJoinGate
Nested Class Summary | |
---|---|
static class |
HadoopMemoryJoinGate.Spill
|
Nested classes/interfaces inherited from class cascading.flow.stream.MemorySpliceGate |
---|
cascading.flow.stream.MemorySpliceGate.DelegatedTuple |
Nested classes/interfaces inherited from class cascading.flow.stream.SpliceGate |
---|
cascading.flow.stream.SpliceGate.Role |
Field Summary |
---|
Fields inherited from class cascading.flow.stream.MemoryHashJoinGate |
---|
latch |
Fields inherited from class cascading.flow.stream.MemorySpliceGate |
---|
closure, count, groupComparators, groupHasher, keys, keyValues, nullsAreNotEqual, numIncomingPaths, posMap, valueComparators |
Fields inherited from class cascading.flow.stream.SpliceGate |
---|
flowProcess, grouping, incomingScopes, keyBuilder, keyEntry, keyFields, orderedPrevious, outgoingScopes, role, sortBuilder, sortFields, splice, tupleEntryIterator, valuesBuilder, valuesFields |
Fields inherited from class cascading.flow.stream.Gate |
---|
allPrevious |
Fields inherited from class cascading.flow.stream.Duct |
---|
next |
Constructor Summary | |
---|---|
HadoopMemoryJoinGate(cascading.flow.FlowProcess<JobConf> flowProcess,
cascading.pipe.HashJoin join)
|
Method Summary | |
---|---|
protected void |
countDownLatch()
|
protected Set<cascading.tuple.Tuple> |
createKeySet()
|
protected Map<cascading.tuple.Tuple,Collection<cascading.tuple.Tuple>> |
createTupleMap()
|
protected void |
waitOnLatch()
|
Methods inherited from class cascading.flow.stream.MemoryHashJoinGate |
---|
bind, complete, isBlockingStreamed, prepare, receive |
Methods inherited from class cascading.flow.stream.MemorySpliceGate |
---|
createDefaultNarrowBuilder, createKeyValuesArray, getDelegatedTuple, getKeyComparator, initialize |
Methods inherited from class cascading.flow.stream.SpliceGate |
---|
addIncomingScope, addOutgoingScope, cleanup, createNarrowBuilder, createNulledBuilder, equals, getBranchNames, getFlowElement, getIncomingScopes, getOutgoingScopes, handleException, handleReThrowableException, hashCode, hasTrapHandler, makePosMap, orderDucts, setBranchNames, setTrapHandler, toString |
Methods inherited from class cascading.flow.stream.Gate |
---|
getAllPreviousFor |
Methods inherited from class cascading.flow.stream.Duct |
---|
getNext, getNextFor, receiveFirst, start |
Methods inherited from class java.lang.Object |
---|
clone, finalize, getClass, notify, notifyAll, wait, wait, wait |
Constructor Detail |
---|
public HadoopMemoryJoinGate(cascading.flow.FlowProcess<JobConf> flowProcess, cascading.pipe.HashJoin join)
Method Detail |
---|
protected Set<cascading.tuple.Tuple> createKeySet()
createKeySet
in class cascading.flow.stream.MemorySpliceGate
protected Map<cascading.tuple.Tuple,Collection<cascading.tuple.Tuple>> createTupleMap()
createTupleMap
in class cascading.flow.stream.MemorySpliceGate
protected void waitOnLatch()
waitOnLatch
in class cascading.flow.stream.MemoryHashJoinGate
protected void countDownLatch()
countDownLatch
in class cascading.flow.stream.MemoryHashJoinGate
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |