cascading.flow.stream
Class GroupAssertionEveryStage

java.lang.Object
  extended by cascading.flow.stream.Duct<Incoming,Outgoing>
      extended by cascading.flow.stream.Stage<Incoming,Outgoing>
          extended by cascading.flow.stream.ElementStage<Incoming,TupleEntry>
              extended by cascading.flow.stream.OperatorStage<Incoming>
                  extended by cascading.flow.stream.EveryStage<TupleEntry>
                      extended by cascading.flow.stream.GroupAssertionEveryStage
All Implemented Interfaces:
ElementDuct, Reducing<TupleEntry,TupleEntry>

public class GroupAssertionEveryStage
extends EveryStage<TupleEntry>
implements Reducing<TupleEntry,TupleEntry>


Field Summary
 
Fields inherited from class cascading.flow.stream.OperatorStage
argumentsBuilder, argumentsEntry, argumentsSelector, incomingEntry, operationCall, outgoingBuilder, outgoingEntry, outgoingSelector, outputCollector, remainderFields, RETAIN_COLLECTOR
 
Fields inherited from class cascading.flow.stream.ElementStage
branchNames, flowElement, flowProcess, incomingScopes, outgoingScopes, trapHandler
 
Fields inherited from class cascading.flow.stream.Duct
next
 
Constructor Summary
GroupAssertionEveryStage(FlowProcess flowProcess, Every every)
           
 
Method Summary
 void completeGroup(Duct previous, TupleEntry incomingEntry)
           
protected  Fields getIncomingArgumentsFields()
           
protected  Fields getIncomingPassThroughFields()
           
protected  Fields getOutgoingSelector()
           
 void initialize()
          Called immediately after bind
 void receive(Duct previous, TupleEntry tupleEntry)
           
 void startGroup(Duct previous, TupleEntry groupEntry)
           
 
Methods inherited from class cascading.flow.stream.EveryStage
getOperator
 
Methods inherited from class cascading.flow.stream.OperatorStage
cleanup, complete, createArgumentsBuilder, createOutgoingBuilder, getOperationDeclaredFields, prepare
 
Methods inherited from class cascading.flow.stream.ElementStage
addIncomingScope, addOutgoingScope, equals, getBranchNames, getFlowElement, getIncomingScopes, getOutgoingFields, getOutgoingScopes, handleException, handleReThrowableException, hashCode, hasTrapHandler, setBranchNames, setTrapHandler, toString
 
Methods inherited from class cascading.flow.stream.Duct
bind, getNext, getNextFor, receiveFirst, start
 
Methods inherited from class java.lang.Object
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
 

Constructor Detail

GroupAssertionEveryStage

public GroupAssertionEveryStage(FlowProcess flowProcess,
                                Every every)
Method Detail

getIncomingPassThroughFields

protected Fields getIncomingPassThroughFields()
Specified by:
getIncomingPassThroughFields in class OperatorStage<TupleEntry>

getIncomingArgumentsFields

protected Fields getIncomingArgumentsFields()
Specified by:
getIncomingArgumentsFields in class OperatorStage<TupleEntry>

getOutgoingSelector

protected Fields getOutgoingSelector()
Specified by:
getOutgoingSelector in class OperatorStage<TupleEntry>

initialize

public void initialize()
Description copied from class: Duct
Called immediately after bind

Overrides:
initialize in class OperatorStage<TupleEntry>

startGroup

public void startGroup(Duct previous,
                       TupleEntry groupEntry)
Specified by:
startGroup in interface Reducing<TupleEntry,TupleEntry>

receive

public void receive(Duct previous,
                    TupleEntry tupleEntry)
Overrides:
receive in class Stage<TupleEntry,TupleEntry>

completeGroup

public void completeGroup(Duct previous,
                          TupleEntry incomingEntry)
Specified by:
completeGroup in interface Reducing<TupleEntry,TupleEntry>


Copyright © 2007-2015 Concurrent, Inc. All Rights Reserved.