Package org.apache.storm.windowing
Class WaterMarkEvent<T>
java.lang.Object
org.apache.storm.windowing.EventImpl<T>
org.apache.storm.windowing.WaterMarkEvent<T>
- All Implemented Interfaces:
- Event<T>
Watermark event used for tracking progress of time when processing event based ts.
- 
Constructor SummaryConstructors
- 
Method SummaryMethods inherited from class org.apache.storm.windowing.EventImplget, getTimestamp
- 
Constructor Details- 
WaterMarkEventpublic WaterMarkEvent(long ts) 
 
- 
- 
Method Details- 
isWatermarkpublic boolean isWatermark()Description copied from interface:EventIf this is a watermark event or not. Watermark events are used for tracking time while processing event based ts.- Specified by:
- isWatermarkin interface- Event<T>
- Overrides:
- isWatermarkin class- EventImpl<T>
- Returns:
- true if this is a watermark event
 
- 
toString
 
-