cascading.pipe
Class Every.EveryAssertionHandler
java.lang.Object
cascading.pipe.Every.EveryHandler
cascading.pipe.Every.EveryAssertionHandler
- Enclosing class:
- Every
public class Every.EveryAssertionHandler
- extends Every.EveryHandler
Every.EveryAssertionHandler
public Every.EveryAssertionHandler(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.