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.LogFileRequest$
Indicates a request for the .log file
|
static interface |
TaskManagerMessages.LogTypeRequest
Trait do differentiate which log file is requested
|
static class |
TaskManagerMessages.NotifyWhenRegisteredAtJobManager$
Requests a notification from the task manager as soon as the task manager has been
registered at a job manager.
|
static class |
TaskManagerMessages.RegisteredAtJobManager$
Acknowledges that the task manager has been successfully registered at any job manager.
|
static class |
TaskManagerMessages.RequestTaskManagerLog
Requests the TaskManager to upload either his log/stdout file to the Blob store
param requestType LogTypeRequest indicating which file is requested
|
static class |
TaskManagerMessages.RequestTaskManagerLog$ |
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$ |
static class |
TaskManagerMessages.StdOutFileRequest$
Indicates a request for the .out file
|
Constructor and Description |
---|
TaskManagerMessages() |
Modifier and Type | Method and Description |
---|---|
static TaskManagerMessages.NotifyWhenRegisteredAtJobManager$ |
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.
|
static Object |
getRequestTaskManagerLog()
Accessor for the case object instance, to simplify Java interoperability.
|
static Object |
getRequestTaskManagerStdout()
Accessor for the case object instance, to simplify Java interoperability.
|
public static TaskManagerMessages.NotifyWhenRegisteredAtJobManager$ getNotifyWhenRegisteredAtJobManagerMessage()
public static TaskManagerMessages.RegisteredAtJobManager$ getRegisteredAtJobManagerMessage()
public static Object getRequestTaskManagerLog()
public static Object getRequestTaskManagerStdout()
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.