public class GroupAssertionEveryStage extends EveryStage<TupleEntry> implements Reducing<TupleEntry,TupleEntry>
argumentsBuilder, argumentsEntry, argumentsSelector, incomingEntry, operationCall, outgoingBuilder, outgoingEntry, outgoingSelector, outputCollector, remainderFields, RETAIN_COLLECTOR
branchNames, flowElement, flowProcess, incomingScopes, outgoingScopes, trapHandler
Constructor and Description |
---|
GroupAssertionEveryStage(FlowProcess flowProcess,
Every every) |
Modifier and Type | Method and Description |
---|---|
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,
int ordinal,
TupleEntry tupleEntry) |
void |
startGroup(Duct previous,
TupleEntry groupEntry) |
getOperator
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 GroupAssertionEveryStage(FlowProcess flowProcess, Every every)
protected Fields getIncomingPassThroughFields()
getIncomingPassThroughFields
in class OperatorStage<TupleEntry>
protected Fields getIncomingArgumentsFields()
getIncomingArgumentsFields
in class OperatorStage<TupleEntry>
protected Fields getOutgoingSelector()
getOutgoingSelector
in class OperatorStage<TupleEntry>
public void initialize()
Duct
initialize
in class OperatorStage<TupleEntry>
public void startGroup(Duct previous, TupleEntry groupEntry)
startGroup
in interface Reducing<TupleEntry,TupleEntry>
public void receive(Duct previous, int ordinal, TupleEntry tupleEntry)
receive
in class Stage<TupleEntry,TupleEntry>
public void completeGroup(Duct previous, TupleEntry incomingEntry)
completeGroup
in interface Reducing<TupleEntry,TupleEntry>
Copyright © 2007-2017 Cascading Maintainers. All Rights Reserved.