org.apache.flink.runtime.messages

Class Messages

java.lang.Object

org.apache.flink.runtime.messages.Messages

public class Messages
extends Object

Generic messages between JobManager, TaskManager, JobClient.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	Messages.Acknowledge$ Message to signal the successful reception of another message
static class	Messages.Disconnect Signals that the receiver (JobManager/TaskManager) shall disconnect the sender.
static class	Messages.Disconnect$

Constructor Summary

Constructors

Constructor and Description
Messages()

Method Summary

Modifier and Type	Method and Description
static Messages.Acknowledge$	getAcknowledge() Accessor for the case object instance, to simplify Java interoperability.

Methods inherited from class java.lang.Object

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

Constructor Detail

Messages

public Messages()

Method Detail

getAcknowledge

public static Messages.Acknowledge$ getAcknowledge()

Accessor for the case object instance, to simplify Java interoperability.

Returns:

The Acknowledge case object instance.