cascading.flow.stream
Class EachStage

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<TupleEntry>
                  extended by cascading.flow.stream.EachStage
All Implemented Interfaces:
ElementDuct, Mapping
Direct Known Subclasses:
FilterEachStage, FunctionEachStage, ValueAssertionEachStage

public abstract class EachStage
extends OperatorStage<TupleEntry>
implements Mapping


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
EachStage(FlowProcess flowProcess, Each each)
           
 
Method Summary
 Operator getOperator()
           
protected  Fields getOutgoingSelector()
           
 
Methods inherited from class cascading.flow.stream.OperatorStage
cleanup, complete, createArgumentsBuilder, createOutgoingBuilder, getIncomingArgumentsFields, getIncomingPassThroughFields, getOperationDeclaredFields, initialize, 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.Stage
receive
 
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

EachStage

public EachStage(FlowProcess flowProcess,
                 Each each)
Method Detail

getOperator

public Operator getOperator()
Specified by:
getOperator in class OperatorStage<TupleEntry>

getOutgoingSelector

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


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