Package org.apache.storm.windowing

Class WaterMarkEvent<T>

java.lang.Object

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

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

All Implemented Interfaces:

Event<T>

public class WaterMarkEvent<T>
extends EventImpl<T>

Watermark event used for tracking progress of time when processing event based ts.

Constructor Summary

Constructors

Constructor	Description
WaterMarkEvent(long ts)

Method Summary

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

Methods inherited from class java.lang.Object

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

Constructor Details

WaterMarkEvent

public WaterMarkEvent(long ts)

Method Details

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>

Overrides:

isWatermark in class EventImpl<T>

Returns:

true if this is a watermark event

toString

public String toString()

Overrides:

toString in class EventImpl<T>