org.apache.storm.windowing

Class EventImpl<T>

java.lang.Object

org.apache.storm.windowing.EventImpl<T>

Direct Known Subclasses:

WaterMarkEvent

public class EventImpl<T>
extends Object

Method Summary

Modifier and Type	Method and 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()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Method Detail

getTimestamp

public long getTimestamp()

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.

Returns:

the event timestamp in milliseconds.

get

public T get()

Returns the wrapped object, E.g. a tuple

Returns:

the wrapped object.

isWatermark

public boolean isWatermark()

If this is a watermark event or not. Watermark events are used for tracking time while processing event based ts.

Returns:

true if this is a watermark event

toString

public String toString()

Overrides:

toString in class Object