org.apache.samza.system

Class EndOfStreamMessage

java.lang.Object

org.apache.samza.system.ControlMessage

org.apache.samza.system.EndOfStreamMessage

public class EndOfStreamMessage
extends ControlMessage

The EndOfStreamMessage 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
EndOfStreamMessage()
EndOfStreamMessage(java.lang.String taskName)

Method Summary

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

equals, getTaskName, getVersion, hashCode, setVersion

Methods inherited from class java.lang.Object

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

Constructor Detail

EndOfStreamMessage

public EndOfStreamMessage()

EndOfStreamMessage

public EndOfStreamMessage(java.lang.String taskName)