cascading.pipe
Class Every.EveryAssertionHandler

java.lang.Object
  extended by cascading.pipe.Every.EveryHandler
      extended by cascading.pipe.Every.EveryAssertionHandler
Enclosing class:
Every

public class Every.EveryAssertionHandler
extends Every.EveryHandler


Field Summary
 
Fields inherited from class cascading.pipe.Every.EveryHandler
outgoingScope, outputCollector
 
Constructor Summary
Every.EveryAssertionHandler(Scope outgoingScope)
           
 
Method Summary
 void complete(FlowProcess flowProcess, TupleEntry groupEntry)
           
 void operate(FlowProcess flowProcess, TupleEntry groupEntry, TupleEntry inputEntry, TupleEntryIterator tupleEntryIterator)
           
 void start(FlowProcess flowProcess, TupleEntry groupEntry)
           
 
Methods inherited from class cascading.pipe.Every.EveryHandler
cleanup, getEvery, prepare, toString
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 

Constructor Detail

Every.EveryAssertionHandler

public Every.EveryAssertionHandler(Scope outgoingScope)
Method Detail

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.