cascading.flow.stream
Class BufferEveryWindow
java.lang.Object
cascading.flow.stream.Duct<Incoming,Outgoing>
cascading.flow.stream.Stage<Incoming,Outgoing>
cascading.flow.stream.ElementStage<Incoming,TupleEntry>
cascading.flow.stream.OperatorStage<Incoming>
cascading.flow.stream.EveryStage<Grouping<TupleEntry,TupleEntryIterator>>
cascading.flow.stream.BufferEveryWindow
- All Implemented Interfaces:
- ElementDuct, OpenWindow
public class BufferEveryWindow
- extends EveryStage<Grouping<TupleEntry,TupleEntryIterator>>
- implements OpenWindow
Fields inherited from class cascading.flow.stream.OperatorStage |
argumentsBuilder, argumentsEntry, argumentsSelector, incomingEntry, operationCall, outgoingBuilder, outgoingEntry, outgoingSelector, outputCollector, remainderFields, RETAIN_COLLECTOR |
Fields inherited from class cascading.flow.stream.Duct |
next |
Methods inherited from class cascading.flow.stream.ElementStage |
addIncomingScope, addOutgoingScope, equals, getBranchNames, getFlowElement, getIncomingScopes, getOutgoingFields, getOutgoingScopes, handleException, handleReThrowableException, hashCode, hasTrapHandler, setBranchNames, setTrapHandler, toString |
BufferEveryWindow
public BufferEveryWindow(FlowProcess flowProcess,
Every every)
initialize
public void initialize()
- Description copied from class:
Duct
- Called immediately after bind
- Overrides:
initialize
in class OperatorStage<Grouping<TupleEntry,TupleEntryIterator>>
getIncomingPassThroughFields
protected Fields getIncomingPassThroughFields()
- Specified by:
getIncomingPassThroughFields
in class OperatorStage<Grouping<TupleEntry,TupleEntryIterator>>
getIncomingArgumentsFields
protected Fields getIncomingArgumentsFields()
- Specified by:
getIncomingArgumentsFields
in class OperatorStage<Grouping<TupleEntry,TupleEntryIterator>>
getOutgoingSelector
protected Fields getOutgoingSelector()
- Specified by:
getOutgoingSelector
in class OperatorStage<Grouping<TupleEntry,TupleEntryIterator>>
start
public void start(Duct previous)
- Overrides:
start
in class Duct<Grouping<TupleEntry,TupleEntryIterator>,TupleEntry>
receive
public void receive(Duct previous,
Grouping<TupleEntry,TupleEntryIterator> grouping)
- Overrides:
receive
in class Stage<Grouping<TupleEntry,TupleEntryIterator>,TupleEntry>
Copyright © 2007-2014 Concurrent, Inc. All Rights Reserved.