cascading.pipe
Class Every.EveryAggregatorHandler
java.lang.Object
cascading.pipe.Every.EveryHandler
cascading.pipe.Every.EveryAggregatorHandler
- Enclosing class:
- Every
public class Every.EveryAggregatorHandler
- extends Every.EveryHandler
Every.EveryAggregatorHandler
public Every.EveryAggregatorHandler(Scope outgoingScope)
start
public void start(FlowProcess flowProcess,
TupleEntry groupEntry)
- Specified by:
start
in class Every.EveryHandler
operate
public void operate(FlowProcess flowProcess,
TupleEntry groupEntry,
TupleEntry inputEntry,
TupleEntryIterator tupleEntryIterator)
- Specified by:
operate
in class Every.EveryHandler
complete
public void complete(FlowProcess flowProcess,
TupleEntry groupEntry)
- Specified by:
complete
in class Every.EveryHandler
Copyright © 2007-2010 Concurrent, Inc. All Rights Reserved.