public class SyncMergeStage extends MergeStage
completeCount
branchNames, flowElement, flowProcess, incomingScopes, outgoingScopes, trapHandler
Constructor and Description |
---|
SyncMergeStage(FlowProcess flowProcess,
FlowElement flowElement) |
Modifier and Type | Method and Description |
---|---|
void |
receive(Duct previous,
TupleEntry tupleEntry)
synchronized, as by default, each source gets its turn, no concurrent threads.
|
bind, complete, initialize, start
cleanup, equals, getBranchNames, getFlowElement, getIncomingScopes, getOutgoingFields, getOutgoingScopes, handleException, handleReThrowableException, hashCode, hasTrapHandler, setBranchNames, setTrapHandler, toString
getNext, getNextFor, prepare, receiveFirst
public SyncMergeStage(FlowProcess flowProcess, FlowElement flowElement)
public void receive(Duct previous, TupleEntry tupleEntry)
receive
in class Stage<TupleEntry,TupleEntry>
previous
- tupleEntry
- Copyright © 2007-2015 Concurrent, Inc. All Rights Reserved.