org.apache.samza.system

Class WatermarkMessage

java.lang.Object

org.apache.samza.system.ControlMessage

org.apache.samza.system.WatermarkMessage

public class WatermarkMessage
extends ControlMessage

The WatermarkMessage is a control message that is sent out to next stage with a watermark timestamp and the task that produces the watermark.

Constructor Summary

Constructors

Constructor and Description
WatermarkMessage(long watermark)
WatermarkMessage(long timestamp, java.lang.String taskName)

Method Summary

Modifier and Type	Method and Description
boolean	equals(java.lang.Object obj)
long	getTimestamp()
int	hashCode()

Methods inherited from class org.apache.samza.system.ControlMessage

getTaskName, getVersion, setVersion

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

WatermarkMessage

public WatermarkMessage(long watermark)

WatermarkMessage

public WatermarkMessage(long timestamp,
                        java.lang.String taskName)

Method Detail

getTimestamp

public long getTimestamp()

hashCode

public int hashCode()

Overrides:

hashCode in class ControlMessage

equals

public boolean equals(java.lang.Object obj)

Overrides:

equals in class ControlMessage