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

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