org.apache.samza.system

Class DrainMessage

java.lang.Object

org.apache.samza.system.ControlMessage

org.apache.samza.system.DrainMessage

public class DrainMessage
extends ControlMessage

The DrainMessage is a control message that is sent out to next stage once the task has consumed to the end of a bounded stream.

Constructor Summary

Constructors

Constructor and Description
DrainMessage(java.lang.String runId)
DrainMessage(java.lang.String taskName, java.lang.String runId)

Method Summary

Modifier and Type	Method and Description
boolean	equals(java.lang.Object obj)
java.lang.String	getRunId()
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

DrainMessage

public DrainMessage(java.lang.String runId)

DrainMessage

public DrainMessage(java.lang.String taskName,
                    java.lang.String runId)

Method Detail

getRunId

public java.lang.String getRunId()

hashCode

public int hashCode()

Overrides:

hashCode in class ControlMessage

equals

public boolean equals(java.lang.Object obj)

Overrides:

equals in class ControlMessage