public abstract class EachStage extends OperatorStage<TupleEntry>
argumentsBuilder, argumentsEntry, argumentsSelector, incomingEntry, operationCall, outgoingBuilder, outgoingEntry, outgoingSelector, outputCollector, remainderFields, RETAIN_COLLECTOR
branchNames, flowElement, flowProcess, incomingScopes, outgoingScopes, trapHandler
Constructor and Description |
---|
EachStage(FlowProcess flowProcess,
Each each) |
Modifier and Type | Method and Description |
---|---|
Operator |
getOperator() |
protected Fields |
getOutgoingSelector() |
cleanup, complete, createArgumentsBuilder, createOutgoingBuilder, getIncomingArgumentsFields, getIncomingPassThroughFields, getOperationDeclaredFields, initialize, prepare
equals, getBranchNames, getFlowElement, getIncomingScopes, getOutgoingFields, getOutgoingScopes, handleException, handleReThrowableException, hashCode, hasTrapHandler, setBranchNames, setTrapHandler, toString
bind, getNext, getNextFor, receiveFirst, start
public EachStage(FlowProcess flowProcess, Each each)
public Operator getOperator()
getOperator
in class OperatorStage<TupleEntry>
protected Fields getOutgoingSelector()
getOutgoingSelector
in class OperatorStage<TupleEntry>
Copyright © 2007-2015 Concurrent, Inc. All Rights Reserved.