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 boolean
isWatermark()
If this is a watermark event or not.String
toString()
-
Methods inherited from class org.apache.storm.windowing.EventImpl
get, getTimestamp
-
-
-
-
Method Detail
-
isWatermark
public boolean isWatermark()
Description copied from interface:Event
If this is a watermark event or not. Watermark events are used for tracking time while processing event based ts.- Specified by:
isWatermark
in interfaceEvent<T>
- Overrides:
isWatermark
in classEventImpl<T>
- Returns:
- true if this is a watermark event
-
-