public class TaskManagerMessages extends Object
Modifier and Type | Class and Description |
---|---|
static class |
TaskManagerMessages.FatalError
This message informs the TaskManager about a fatal error that prevents
it from continuing.
|
static class |
TaskManagerMessages.FatalError$ |
static class |
TaskManagerMessages.Heartbeat
Reports liveliness of the TaskManager instance with the given instance ID to the
This message is sent to the job.
|
static class |
TaskManagerMessages.Heartbeat$ |
static class |
TaskManagerMessages.JobManagerLeaderAddress
Tells the address of the new leading
JobManager
and the new leader session ID. |
static class |
TaskManagerMessages.JobManagerLeaderAddress$ |
static class |
TaskManagerMessages.NotifyWhenRegisteredAtAnyJobManager$
Requests a notification from the task manager as soon as the task manager has been
registered at any job manager.
|
static class |
TaskManagerMessages.RegisteredAtJobManager$
Acknowledges that the task manager has been successfully registered at any job manager.
|
static class |
TaskManagerMessages.SendHeartbeat$
Tells the task manager to send a heartbeat message to the job manager.
|
static class |
TaskManagerMessages.SendStackTrace$
Tells the TaskManager to send a stack trace of all threads to the sender.
|
static class |
TaskManagerMessages.StackTrace
Communicates the stack trace of the TaskManager with the given ID.
|
static class |
TaskManagerMessages.StackTrace$ |
Constructor and Description |
---|
TaskManagerMessages() |
Modifier and Type | Method and Description |
---|---|
static TaskManagerMessages.NotifyWhenRegisteredAtAnyJobManager$ |
getNotifyWhenRegisteredAtJobManagerMessage()
Accessor for the case object instance, to simplify Java interoperability.
|
static TaskManagerMessages.RegisteredAtJobManager$ |
getRegisteredAtJobManagerMessage()
Accessor for the case object instance, to simplify Java interoperability.
|
public static TaskManagerMessages.NotifyWhenRegisteredAtAnyJobManager$ getNotifyWhenRegisteredAtJobManagerMessage()
public static TaskManagerMessages.RegisteredAtJobManager$ getRegisteredAtJobManagerMessage()
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.