- All Implemented Interfaces:
- Collapsing, ElementDuct
public class SyncMergeStage
- extends MergeStage
A version of Merge that synchronizes the receives for local mode
|Fields inherited from class cascading.flow.stream.Duct
synchronized, as by default, each source gets its turn, no concurrent threads.
|Methods inherited from class cascading.flow.stream.ElementStage
addIncomingScope, addOutgoingScope, cleanup, equals, getBranchNames, getFlowElement, getIncomingScopes, getOutgoingFields, getOutgoingScopes, handleException, handleReThrowableException, hashCode, hasTrapHandler, setBranchNames, setTrapHandler, toString
public SyncMergeStage(FlowProcess flowProcess,
public void receive(Duct previous,
- synchronized, as by default, each source gets its turn, no concurrent threads. Except in local mode
receive in class
Copyright © 2007-2015 Concurrent, Inc. All Rights Reserved.