Package org.apache.storm.windowing
Class EventImpl<T>
- java.lang.Object
-
- org.apache.storm.windowing.EventImpl<T>
-
- All Implemented Interfaces:
Event<T>
- Direct Known Subclasses:
WaterMarkEvent
public class EventImpl<T> extends Object implements Event<T>
-
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description T
get()
Returns the wrapped object, E.g.long
getTimestamp()
The event timestamp in millis.boolean
isWatermark()
If this is a watermark event or not.String
toString()
-
-
-
Method Detail
-
getTimestamp
public long getTimestamp()
Description copied from interface:Event
The event timestamp in millis. This could be the time when the source generated the tuple or the time when the tuple was received by a bolt.- Specified by:
getTimestamp
in interfaceEvent<T>
- Returns:
- the event timestamp in milliseconds.
-
get
public T get()
Description copied from interface:Event
Returns the wrapped object, E.g. a tuple
-
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>
- Returns:
- true if this is a watermark event
-
-