org.apache.samza.system

Class ControlMessage

java.lang.Object

org.apache.samza.system.ControlMessage

Direct Known Subclasses:

EndOfStreamMessage, WatermarkMessage

public abstract class ControlMessage
extends java.lang.Object

The abstract class of all control messages, containing the task that produces the control message, the total number of producer tasks, and a version number.

Constructor Summary

Constructors

Constructor and Description
ControlMessage(java.lang.String taskName)

Method Summary

Modifier and Type	Method and Description
boolean	equals(java.lang.Object obj)
java.lang.String	getTaskName()
int	getVersion()
int	hashCode()
void	setVersion(int version)

Methods inherited from class java.lang.Object

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

Constructor Detail

ControlMessage

public ControlMessage(java.lang.String taskName)

Method Detail

getTaskName

public java.lang.String getTaskName()

setVersion

public void setVersion(int version)

getVersion

public int getVersion()

hashCode

public int hashCode()

Overrides:

hashCode in class java.lang.Object

equals

public boolean equals(java.lang.Object obj)

Overrides:

equals in class java.lang.Object