Class SyncMergeStage

  extended by<Incoming,Outgoing>
      extended by<Incoming,Outgoing>
          extended by<TupleEntry,TupleEntry>
              extended by
                  extended by
All Implemented Interfaces:
Collapsing, ElementDuct

public class SyncMergeStage
extends MergeStage

A version of Merge that synchronizes the receives for local mode

Field Summary
Fields inherited from class
Fields inherited from class
branchNames, flowElement, flowProcess, incomingScopes, outgoingScopes, trapHandler
Fields inherited from class
Constructor Summary
SyncMergeStage(FlowProcess flowProcess, FlowElement flowElement)
Method Summary
 void receive(Duct previous, TupleEntry tupleEntry)
          synchronized, as by default, each source gets its turn, no concurrent threads.
Methods inherited from class
bind, complete, initialize, start
Methods inherited from class
addIncomingScope, addOutgoingScope, cleanup, equals, getBranchNames, getFlowElement, getIncomingScopes, getOutgoingFields, getOutgoingScopes, handleException, handleReThrowableException, hashCode, hasTrapHandler, setBranchNames, setTrapHandler, toString
Methods inherited from class
getNext, getNextFor, prepare, receiveFirst
Methods inherited from class java.lang.Object
clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail


public SyncMergeStage(FlowProcess flowProcess,
                      FlowElement flowElement)
Method Detail


public void receive(Duct previous,
                    TupleEntry tupleEntry)
synchronized, as by default, each source gets its turn, no concurrent threads. Except in local mode

receive in class Stage<TupleEntry,TupleEntry>
previous -
tupleEntry -

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