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,
int ordinal,
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, int ordinal, TupleEntry tupleEntry)
receive
in class Stage<TupleEntry,TupleEntry>
previous
- ordinal
- tupleEntry
- Copyright © 2007-2015 Xplenty, Inc. All Rights Reserved.