Package org.apache.storm.windowing
Class TupleWindowIterImpl
java.lang.Object
org.apache.storm.windowing.TupleWindowIterImpl
- All Implemented Interfaces:
- TupleWindow,- Window<Tuple>
An iterator based implementation over the events in a window.
- 
Constructor SummaryConstructors
- 
Method SummaryModifier and TypeMethodDescriptionget()Gets the list of events in the window.If processing based on event time, returns the window end time based on watermark otherwise returns the window end time based on processing time.Get the list of events expired from the window since the last time the window was generated.getIter()Returns an iterator over the events in the window.getNew()Get the list of newly added events in the window since the last time the window was generated.Returns the window start timestamp.
- 
Constructor Details- 
TupleWindowIterImpl
 
- 
- 
Method Details- 
getDescription copied from interface:WindowGets the list of events in the window.Note: If the number of tuples in windows is huge, invoking getwould load all the tuples into memory and may throw an OOM exception. Use windowing with persistence (BaseStatefulWindowedBolt.withPersistence()) andWindow.getIter()to retrieve an iterator over the events in the window.
- 
getIterDescription copied from interface:WindowReturns an iterator over the events in the window.Note: This is only supported when using windowing with persistence BaseStatefulWindowedBolt.withPersistence().
- 
getNewDescription copied from interface:WindowGet the list of newly added events in the window since the last time the window was generated.Note: This is not supported when using windowing with persistence ( BaseStatefulWindowedBolt.withPersistence()).
- 
getExpiredDescription copied from interface:WindowGet the list of events expired from the window since the last time the window was generated.Note: This is not supported when using windowing with persistence ( BaseStatefulWindowedBolt.withPersistence()).- Specified by:
- getExpiredin interface- Window<Tuple>
- Returns:
- the list of events expired from the window.
 
- 
getEndTimestampDescription copied from interface:WindowIf processing based on event time, returns the window end time based on watermark otherwise returns the window end time based on processing time.- Specified by:
- getEndTimestampin interface- Window<Tuple>
- Returns:
- the window end timestamp
 
- 
getStartTimestampDescription copied from interface:WindowReturns the window start timestamp. Will return null if the window length is not based on time duration.- Specified by:
- getStartTimestampin interface- Window<Tuple>
- Returns:
- the window start timestamp or null if the window length is not time based
 
 
-