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,
int ordinal,
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, int ordinal, TupleEntry incomingEntry)
receive
in class Stage<TupleEntry,TupleEntry>
Copyright © 2007-2015 Xplenty, Inc. All Rights Reserved.