cascading.flow.stream
Class MemoryHashJoinGate

java.lang.Object
  extended by cascading.flow.stream.Duct<Incoming,Outgoing>
      extended by cascading.flow.stream.Gate<TupleEntry,Grouping<TupleEntry,TupleEntryIterator>>
          extended by cascading.flow.stream.SpliceGate
              extended by cascading.flow.stream.MemorySpliceGate
                  extended by cascading.flow.stream.MemoryHashJoinGate
All Implemented Interfaces:
Collapsing, ElementDuct

public class MemoryHashJoinGate
extends MemorySpliceGate


Nested Class Summary
 
Nested classes/interfaces inherited from class cascading.flow.stream.MemorySpliceGate
MemorySpliceGate.DelegatedTuple
 
Nested classes/interfaces inherited from class cascading.flow.stream.SpliceGate
SpliceGate.Role
 
Field Summary
protected  CountDownLatch 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
MemoryHashJoinGate(FlowProcess flowProcess, HashJoin join)
           
 
Method Summary
 void bind(StreamGraph streamGraph)
           
 void complete(Duct previous)
           
protected  void countDownLatch()
           
protected  boolean isBlockingStreamed()
           
 void prepare()
           
 void receive(Duct previous, TupleEntry incomingEntry)
           
protected  void waitOnLatch()
           
 
Methods inherited from class cascading.flow.stream.MemorySpliceGate
createDefaultNarrowBuilder, createKeySet, createKeyValuesArray, createTupleMap, 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
 

Field Detail

latch

protected CountDownLatch latch
Constructor Detail

MemoryHashJoinGate

public MemoryHashJoinGate(FlowProcess flowProcess,
                          HashJoin join)
Method Detail

bind

public void bind(StreamGraph streamGraph)
Overrides:
bind in class MemorySpliceGate

prepare

public void prepare()
Overrides:
prepare in class MemorySpliceGate

receive

public void receive(Duct previous,
                    TupleEntry incomingEntry)
Specified by:
receive in class Duct<TupleEntry,Grouping<TupleEntry,TupleEntryIterator>>

complete

public void complete(Duct previous)
Overrides:
complete in class Duct<TupleEntry,Grouping<TupleEntry,TupleEntryIterator>>

waitOnLatch

protected void waitOnLatch()

countDownLatch

protected void countDownLatch()

isBlockingStreamed

protected boolean isBlockingStreamed()
Specified by:
isBlockingStreamed in class MemorySpliceGate


Copyright © 2007-2014 Concurrent, Inc. All Rights Reserved.