cascading.flow.stream
Class CloseReducingDuct<Group,Incoming,Outgoing>
java.lang.Object
cascading.flow.stream.Duct<Incoming,Outgoing>
cascading.flow.stream.CloseReducingDuct<Group,Incoming,Outgoing>
- All Implemented Interfaces:
- CloseWindow, Reducing<Group,Outgoing>
public class CloseReducingDuct<Group,Incoming,Outgoing>
- extends Duct<Incoming,Outgoing>
- implements CloseWindow, Reducing<Group,Outgoing>
Fields inherited from class cascading.flow.stream.Duct |
next |
CloseReducingDuct
public CloseReducingDuct(Duct<Outgoing,?> next)
receive
public void receive(Duct previous,
Incoming incoming)
- Specified by:
receive
in class Duct<Incoming,Outgoing>
startGroup
public void startGroup(Duct previous,
Group group)
- Specified by:
startGroup
in interface Reducing<Group,Outgoing>
completeGroup
public void completeGroup(Duct previous,
Outgoing outgoing)
- Specified by:
completeGroup
in interface Reducing<Group,Outgoing>
Copyright © 2007-2013 Concurrent, Inc. All Rights Reserved.