Package org.apache.storm.windowing
Class TupleWindowImpl
- java.lang.Object
-
- org.apache.storm.windowing.TupleWindowImpl
-
- All Implemented Interfaces:
TupleWindow,Window<Tuple>
public class TupleWindowImpl extends Object implements TupleWindow
Holds the expired, new and current tuples in a window.
-
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description booleanequals(Object o)List<Tuple>get()Gets the list of events in the window.LonggetEndTimestamp()If processing based on event time, returns the window end time based on watermark otherwise returns the window end time based on processing time.List<Tuple>getExpired()Get the list of events expired from the window since the last time the window was generated.List<Tuple>getNew()Get the list of newly added events in the window since the last time the window was generated.LonggetStartTimestamp()Returns the window start timestamp.inthashCode()StringtoString()
-
-
-
Method Detail
-
get
public List<Tuple> get()
Description 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.
-
getNew
public List<Tuple> getNew()
Description 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()).
-
getExpired
public List<Tuple> getExpired()
Description 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 interfaceWindow<Tuple>- Returns:
- the list of events expired from the window.
-
getStartTimestamp
public Long getStartTimestamp()
Description copied from interface:WindowReturns the window start timestamp. Will return null if the window length is not based on time duration.- Specified by:
getStartTimestampin interfaceWindow<Tuple>- Returns:
- the window start timestamp or null if the window length is not time based
-
getEndTimestamp
public Long getEndTimestamp()
Description 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 interfaceWindow<Tuple>- Returns:
- the window end timestamp
-
-