public class WatermarkMessage extends ControlMessage
Constructor and Description |
---|
WatermarkMessage(long watermark) |
WatermarkMessage(long timestamp,
java.lang.String taskName) |
Modifier and Type | Method and Description |
---|---|
boolean |
equals(java.lang.Object obj) |
long |
getTimestamp() |
int |
hashCode() |
getTaskName, getVersion, setVersion
public WatermarkMessage(long watermark)
public WatermarkMessage(long timestamp, java.lang.String taskName)
public long getTimestamp()
public int hashCode()
hashCode
in class ControlMessage
public boolean equals(java.lang.Object obj)
equals
in class ControlMessage