cascading.flow.stream
Class MergeStage
java.lang.Object
cascading.flow.stream.Duct<Incoming,Outgoing>
cascading.flow.stream.Stage<Incoming,Outgoing>
cascading.flow.stream.ElementStage<TupleEntry,TupleEntry>
cascading.flow.stream.MergeStage
- All Implemented Interfaces:
- Collapsing, ElementDuct
public class MergeStage
- extends ElementStage<TupleEntry,TupleEntry>
- implements Collapsing
Fields inherited from class cascading.flow.stream.Duct |
next |
Methods inherited from class cascading.flow.stream.ElementStage |
addIncomingScope, addOutgoingScope, cleanup, equals, getBranchNames, getFlowElement, getIncomingScopes, getOutgoingFields, getOutgoingScopes, handleException, handleReThrowableException, hashCode, hasTrapHandler, setBranchNames, setTrapHandler, toString |
Methods inherited from class cascading.flow.stream.Stage |
receive |
completeCount
protected final AtomicInteger completeCount
MergeStage
public MergeStage(FlowProcess flowProcess,
FlowElement flowElement)
bind
public void bind(StreamGraph streamGraph)
- Overrides:
bind
in class Duct<TupleEntry,TupleEntry>
initialize
public void initialize()
- Description copied from class:
Duct
- Called immediately after bind
- Overrides:
initialize
in class Duct<TupleEntry,TupleEntry>
start
public void start(Duct previous)
- Overrides:
start
in class Duct<TupleEntry,TupleEntry>
complete
public void complete(Duct previous)
- Overrides:
complete
in class Duct<TupleEntry,TupleEntry>
Copyright © 2007-2015 Concurrent, Inc. All Rights Reserved.