org.apache.samza.drain

Class DrainNotification

java.lang.Object

org.apache.samza.drain.DrainNotification

public class DrainNotification
extends java.lang.Object

DrainNotification is a custom message used by an external controller to trigger Drain.

Constructor Summary

Constructors

Constructor and Description
DrainNotification(java.util.UUID uuid, java.lang.String runId, DrainMode drainMode)

Method Summary

Modifier and Type	Method and Description
static DrainNotification	create(java.util.UUID uuid, java.lang.String runId) Creates a DrainNotification in DrainMode.DEFAULT mode.
boolean	equals(java.lang.Object o)
DrainMode	getDrainMode()
java.lang.String	getRunId()
java.util.UUID	getUuid()
int	hashCode()
java.lang.String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

DrainNotification

public DrainNotification(java.util.UUID uuid,
                         java.lang.String runId,
                         DrainMode drainMode)

Method Detail

create

public static DrainNotification create(java.util.UUID uuid,
                                       java.lang.String runId)

Creates a DrainNotification in DrainMode.DEFAULT mode.

getUuid

public java.util.UUID getUuid()

getRunId

public java.lang.String getRunId()

getDrainMode

public DrainMode getDrainMode()

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

equals

public boolean equals(java.lang.Object o)

Overrides:

equals in class java.lang.Object

hashCode

public int hashCode()

Overrides:

hashCode in class java.lang.Object