cascading.flow.stream
Class OpenDuct<Incoming,Outgoing>
java.lang.Object
cascading.flow.stream.Duct<Grouping<Incoming,Iterator<Incoming>>,Outgoing>
cascading.flow.stream.OpenDuct<Incoming,Outgoing>
- All Implemented Interfaces:
- OpenWindow
public class OpenDuct<Incoming,Outgoing>
- extends Duct<Grouping<Incoming,Iterator<Incoming>>,Outgoing>
- implements OpenWindow
Fields inherited from class cascading.flow.stream.Duct |
next |
OpenDuct
public OpenDuct(Duct<Outgoing,?> next)
start
public void start(Duct previous)
- Overrides:
start
in class Duct<Grouping<Incoming,Iterator<Incoming>>,Outgoing>
receive
public void receive(Duct previous,
Grouping<Incoming,Iterator<Incoming>> grouping)
- Specified by:
receive
in class Duct<Grouping<Incoming,Iterator<Incoming>>,Outgoing>
complete
public void complete(Duct previous)
- Overrides:
complete
in class Duct<Grouping<Incoming,Iterator<Incoming>>,Outgoing>
Copyright © 2007-2015 Concurrent, Inc. All Rights Reserved.