cascading.flow.stream
Class Gate<Incoming,Outgoing>
java.lang.Object
cascading.flow.stream.Duct<Incoming,Outgoing>
cascading.flow.stream.Gate<Incoming,Outgoing>
- Direct Known Subclasses:
- SpliceGate
public abstract class Gate<Incoming,Outgoing>
- extends Duct<Incoming,Outgoing>
Fields inherited from class cascading.flow.stream.Duct |
next |
Constructor Summary |
Gate()
|
allPrevious
protected Duct[] allPrevious
Gate
public Gate()
bind
public void bind(StreamGraph streamGraph)
- Overrides:
bind
in class Duct<Incoming,Outgoing>
getAllPreviousFor
protected Duct[] getAllPreviousFor(StreamGraph streamGraph)
- the actual previous in this context, not necessarily the declared previous
- Parameters:
streamGraph
- of type StreamGraph
- Returns:
- of type Duct[]
Copyright © 2007-2015 Concurrent, Inc. All Rights Reserved.