public class MergeStage extends ElementStage<TupleEntry,TupleEntry> implements Collapsing
Modifier and Type | Field and Description |
---|---|
protected java.util.concurrent.atomic.AtomicInteger |
completeCount |
branchNames, flowElement, flowProcess, incomingScopes, outgoingScopes, trapHandler
Constructor and Description |
---|
MergeStage(FlowProcess flowProcess,
FlowElement flowElement) |
Modifier and Type | Method and Description |
---|---|
void |
bind(StreamGraph streamGraph) |
void |
complete(Duct previous) |
void |
initialize()
Called immediately after bind
|
void |
start(Duct previous) |
cleanup, equals, getBranchNames, getFlowElement, getIncomingScopes, getOutgoingFields, getOutgoingScopes, handleException, handleReThrowableException, hashCode, hasTrapHandler, setBranchNames, setTrapHandler, toString
getNext, getNextFor, prepare, receiveFirst
protected final java.util.concurrent.atomic.AtomicInteger completeCount
public MergeStage(FlowProcess flowProcess, FlowElement flowElement)
public void bind(StreamGraph streamGraph)
bind
in class Duct<TupleEntry,TupleEntry>
public void initialize()
Duct
initialize
in class Duct<TupleEntry,TupleEntry>
public void start(Duct previous)
start
in class Duct<TupleEntry,TupleEntry>
public void complete(Duct previous)
complete
in class Duct<TupleEntry,TupleEntry>
Copyright © 2007-2015 Xplenty, Inc. All Rights Reserved.