cascading.flow.stream
Class Duct<Incoming,Outgoing>
java.lang.Object
cascading.flow.stream.Duct<Incoming,Outgoing>
- Direct Known Subclasses:
- CloseReducingDuct, Fork, Gate, OpenDuct, OpenReducingDuct, Stage
public abstract class Duct<Incoming,Outgoing>
- extends Object
next
protected Duct<Outgoing,?> next
getNext
public Duct getNext()
bind
public void bind(StreamGraph streamGraph)
getNextFor
protected Duct getNextFor(StreamGraph streamGraph)
initialize
public void initialize()
- Called immediately after bind
prepare
public void prepare()
receiveFirst
public final void receiveFirst(Incoming incoming)
start
public void start(Duct previous)
receive
public abstract void receive(Duct previous,
Incoming incoming)
complete
public void complete(Duct previous)
cleanup
public void cleanup()
toString
public String toString()
- Overrides:
toString
in class Object
Copyright © 2007-2015 Concurrent, Inc. All Rights Reserved.