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