cascading.flow.stream
Class AggregatorEveryStage

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.AggregatorEveryStage
All Implemented Interfaces:
ElementDuct, Reducing<TupleEntry,TupleEntry>

public class AggregatorEveryStage
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
AggregatorEveryStage(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

AggregatorEveryStage

public AggregatorEveryStage(FlowProcess flowProcess,
                            Every every)
Method Detail

initialize

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

Overrides:
initialize in class OperatorStage<TupleEntry>

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>

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.