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