cascading.flow.stream
Class BufferEveryWindow

java.lang.Object
  extended by cascading.flow.stream.Duct<Incoming,Outgoing>
      extended by cascading.flow.stream.Stage<Incoming,Outgoing>
          extended by cascading.flow.stream.ElementStage<Incoming,TupleEntry>
              extended by cascading.flow.stream.OperatorStage<Incoming>
                  extended by cascading.flow.stream.EveryStage<Grouping<TupleEntry,TupleEntryIterator>>
                      extended by cascading.flow.stream.BufferEveryWindow
All Implemented Interfaces:
ElementDuct, OpenWindow

public class BufferEveryWindow
extends EveryStage<Grouping<TupleEntry,TupleEntryIterator>>
implements OpenWindow


Field Summary
 
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.ElementStage
branchNames, flowElement, flowProcess, incomingScopes, outgoingScopes, trapHandler
 
Fields inherited from class cascading.flow.stream.Duct
next
 
Constructor Summary
BufferEveryWindow(FlowProcess flowProcess, Every every)
           
 
Method Summary
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)
           
 
Methods inherited from class cascading.flow.stream.EveryStage
getOperator
 
Methods inherited from class cascading.flow.stream.OperatorStage
cleanup, complete, createArgumentsBuilder, createOutgoingBuilder, getOperationDeclaredFields, prepare
 
Methods inherited from class cascading.flow.stream.ElementStage
addIncomingScope, addOutgoingScope, equals, getBranchNames, getFlowElement, getIncomingScopes, getOutgoingFields, getOutgoingScopes, handleException, handleReThrowableException, hashCode, hasTrapHandler, setBranchNames, setTrapHandler, toString
 
Methods inherited from class cascading.flow.stream.Duct
bind, getNext, getNextFor, receiveFirst
 
Methods inherited from class java.lang.Object
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
 

Constructor Detail

BufferEveryWindow

public BufferEveryWindow(FlowProcess flowProcess,
                         Every every)
Method Detail

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-2015 Concurrent, Inc. All Rights Reserved.