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 java.lang.Object
implements Event<T>

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.
java.lang.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()

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 interface Event<T>

Returns:

the event timestamp in milliseconds.

get

public T get()

Description copied from interface: Event

Returns the wrapped object, E.g. a tuple

Specified by:

get in interface Event<T>

Returns:

the wrapped object.

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 interface Event<T>

Returns:

true if this is a watermark event

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object