Package org.apache.storm.windowing
Class WaterMarkEvent<T>
- java.lang.Object
-
- org.apache.storm.windowing.EventImpl<T>
-
- org.apache.storm.windowing.WaterMarkEvent<T>
-
-
Constructor Summary
Constructors Constructor Description WaterMarkEvent(long ts)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description booleanisWatermark()If this is a watermark event or not.StringtoString()-
Methods inherited from class org.apache.storm.windowing.EventImpl
get, getTimestamp
-
-
-
-
Method Detail
-
isWatermark
public 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 interfaceEvent<T>- Overrides:
isWatermarkin classEventImpl<T>- Returns:
- true if this is a watermark event
-
-