cascading.flow.stream
Class Fork<Incoming,Outgoing>
java.lang.Object
cascading.flow.stream.Duct<Incoming,Outgoing>
cascading.flow.stream.Fork<Incoming,Outgoing>
public class Fork<Incoming,Outgoing>
- extends Duct<Incoming,Outgoing>
Fields inherited from class cascading.flow.stream.Duct |
next |
Constructor Summary |
Fork(Duct[] allNext)
|
allNext
protected final Duct[] allNext
Fork
public Fork(Duct[] allNext)
getNext
public Duct getNext()
- Overrides:
getNext
in class Duct<Incoming,Outgoing>
start
public void start(Duct previous)
- Overrides:
start
in class Duct<Incoming,Outgoing>
receive
public void receive(Duct previous,
Incoming incoming)
- Specified by:
receive
in class Duct<Incoming,Outgoing>
complete
public void complete(Duct previous)
- Overrides:
complete
in class Duct<Incoming,Outgoing>
Copyright © 2007-2015 Concurrent, Inc. All Rights Reserved.