public class JobManagerMessages extends Object
Modifier and Type | Class and Description |
---|---|
static class |
JobManagerMessages.CancelJob
Cancels a job with the given
jobID at the JobManager. |
static class |
JobManagerMessages.CancelJob$ |
static class |
JobManagerMessages.CancelJobWithSavepoint
Cancels the job with the given
jobID at the JobManager. |
static class |
JobManagerMessages.CancelJobWithSavepoint$ |
static class |
JobManagerMessages.CancellationFailure
Denotes a failed job cancellation
|
static class |
JobManagerMessages.CancellationFailure$ |
static interface |
JobManagerMessages.CancellationResponse |
static class |
JobManagerMessages.CancellationSuccess
Denotes a successful job cancellation
|
static class |
JobManagerMessages.CancellationSuccess$ |
static class |
JobManagerMessages.ClassloadingProps
Response to
JobManagerMessages.RequestClassloadingProps |
static class |
JobManagerMessages.ClassloadingProps$ |
static class |
JobManagerMessages.CurrentJobStatus
Denotes the current
JobStatus of the job with jobID . |
static class |
JobManagerMessages.CurrentJobStatus$ |
static class |
JobManagerMessages.DisposeSavepoint
Disposes a savepoint.
|
static class |
JobManagerMessages.DisposeSavepoint$ |
static class |
JobManagerMessages.DisposeSavepointFailure
Response after a failed savepoint dispose containing the failure cause.
|
static class |
JobManagerMessages.DisposeSavepointFailure$ |
static class |
JobManagerMessages.DisposeSavepointSuccess$
Response after a successful savepoint dispose.
|
static class |
JobManagerMessages.GrantLeadership
Grants leadership to the receiver.
|
static class |
JobManagerMessages.GrantLeadership$ |
static class |
JobManagerMessages.JobFound
Contains the
executionGraph of a job with jobID . |
static class |
JobManagerMessages.JobFound$ |
static interface |
JobManagerMessages.JobManagerStatus
Response to RequestJobManagerStatus
|
static class |
JobManagerMessages.JobManagerStatusAlive$ |
static class |
JobManagerMessages.JobNotFound
Denotes that there is no job with
jobID retrievable. |
static class |
JobManagerMessages.JobNotFound$ |
static interface |
JobManagerMessages.JobResponse |
static class |
JobManagerMessages.JobResultFailure
Denotes an unsuccessful job execution.
|
static class |
JobManagerMessages.JobResultFailure$ |
static interface |
JobManagerMessages.JobResultMessage
Denotes messages which contain the result of a completed job execution
|
static class |
JobManagerMessages.JobResultSuccess
Denotes a successful job execution.
|
static class |
JobManagerMessages.JobResultSuccess$ |
static interface |
JobManagerMessages.JobStatusResponse |
static class |
JobManagerMessages.JobSubmitSuccess
Denotes a successful job submission.
|
static class |
JobManagerMessages.JobSubmitSuccess$ |
static class |
JobManagerMessages.LeaderSessionMessage
Wrapper class for leader session messages.
|
static class |
JobManagerMessages.LeaderSessionMessage$ |
static class |
JobManagerMessages.NextInputSplit
Contains the next input split for a task.
|
static class |
JobManagerMessages.NextInputSplit$ |
static class |
JobManagerMessages.RecoverAllJobs$
Triggers recovery of all available jobs.
|
static class |
JobManagerMessages.RecoverJob
Triggers the recovery of the job with the given ID.
|
static class |
JobManagerMessages.RecoverJob$ |
static class |
JobManagerMessages.RecoverSubmittedJob
Triggers the submission of the recovered job
|
static class |
JobManagerMessages.RecoverSubmittedJob$ |
static class |
JobManagerMessages.RegisteredTaskManagers
Contains the
Instance objects of all registered task managers. |
static class |
JobManagerMessages.RegisteredTaskManagers$ |
static class |
JobManagerMessages.RegisterJobClient
Registers the sender of the message as the client for the provided job identifier.
|
static class |
JobManagerMessages.RegisterJobClient$ |
static class |
JobManagerMessages.RegisterJobClientSuccess
Denotes a successful registration of a JobClientActor for a running job
|
static class |
JobManagerMessages.RegisterJobClientSuccess$ |
static class |
JobManagerMessages.RemoveCachedJob
Removes the job belonging to the job identifier from the job manager and archives it.
|
static class |
JobManagerMessages.RemoveCachedJob$ |
static class |
JobManagerMessages.RemoveJob
Triggers the removal of the job with the given job ID
|
static class |
JobManagerMessages.RemoveJob$ |
static class |
JobManagerMessages.RequestArchive$
Requests the ActorRef of the archiver
|
static class |
JobManagerMessages.RequestBlobManagerPort$
Requests the port of the blob manager from the job manager.
|
static class |
JobManagerMessages.RequestClassloadingProps
Requests all entities necessary for reconstructing a job class loader
May respond with
JobManagerMessages.ClassloadingProps or JobManagerMessages.JobNotFound |
static class |
JobManagerMessages.RequestClassloadingProps$ |
static class |
JobManagerMessages.RequestJob
Requests the execution graph of a specific job identified by
jobID . |
static class |
JobManagerMessages.RequestJob$ |
static class |
JobManagerMessages.RequestJobManagerStatus$
Requests the current state of the job manager
|
static class |
JobManagerMessages.RequestJobStatus
Requests the current
JobStatus of the job identified by jobID . |
static class |
JobManagerMessages.RequestJobStatus$ |
static class |
JobManagerMessages.RequestLeaderSessionID$
Requests the current leader session ID of the job manager.
|
static class |
JobManagerMessages.RequestNextInputSplit
Requesting next input split for the
ExecutionJobVertex
of the job specified by jobID . |
static class |
JobManagerMessages.RequestNextInputSplit$ |
static class |
JobManagerMessages.RequestNumberRegisteredTaskManager$
Requests the number of currently registered task manager at the job manager.
|
static class |
JobManagerMessages.RequestPartitionProducerState
Requests the execution state of the execution producing a result partition.
|
static class |
JobManagerMessages.RequestPartitionProducerState$ |
static class |
JobManagerMessages.RequestRegisteredTaskManagers$
Requests the instances of all registered task managers.
|
static class |
JobManagerMessages.RequestRunningJobs$
Requests all currently running jobs from the job manager.
|
static class |
JobManagerMessages.RequestRunningJobsStatus$
Requests the status of all currently running jobs from the job manager.
|
static class |
JobManagerMessages.RequestStackTrace
Requests stack trace messages of the task manager
|
static class |
JobManagerMessages.RequestStackTrace$ |
static class |
JobManagerMessages.RequestTaskManagerInstance
Requests the
Instance object of the task manager with the given instance ID |
static class |
JobManagerMessages.RequestTaskManagerInstance$ |
static class |
JobManagerMessages.RequestTotalNumberOfSlots$
Requests the maximum number of slots available to the job manager.
|
static class |
JobManagerMessages.RequestWebMonitorPort$
Request for the
WebMonitor port. |
static class |
JobManagerMessages.ResponseArchive
Response containing the ActorRef of the archiver
|
static class |
JobManagerMessages.ResponseArchive$ |
static class |
JobManagerMessages.ResponseLeaderSessionID
Response to the
RequestLeaderSessionID message. |
static class |
JobManagerMessages.ResponseLeaderSessionID$ |
static class |
JobManagerMessages.ResponseWebMonitorPort
Response containing the
WebMonitor port. |
static class |
JobManagerMessages.ResponseWebMonitorPort$ |
static class |
JobManagerMessages.RevokeLeadership$
Revokes leadership of the receiver.
|
static class |
JobManagerMessages.RunningJobs
This message is the response to the
RequestRunningJobs message. |
static class |
JobManagerMessages.RunningJobs$ |
static class |
JobManagerMessages.RunningJobsStatus |
static class |
JobManagerMessages.RunningJobsStatus$ |
static class |
JobManagerMessages.ScheduleOrUpdateConsumers
Notifies the
JobManager about available data for a
produced partition. |
static class |
JobManagerMessages.ScheduleOrUpdateConsumers$ |
static class |
JobManagerMessages.StopJob
Stops a (streaming) job with the given
jobID at the JobManager. |
static class |
JobManagerMessages.StopJob$ |
static class |
JobManagerMessages.StoppingFailure
Denotes a failed (streaming) job stopping
|
static class |
JobManagerMessages.StoppingFailure$ |
static interface |
JobManagerMessages.StoppingResponse |
static class |
JobManagerMessages.StoppingSuccess
Denotes a successful (streaming) job stopping
|
static class |
JobManagerMessages.StoppingSuccess$ |
static class |
JobManagerMessages.SubmitJob
Submits a job to the job manager.
|
static class |
JobManagerMessages.SubmitJob$ |
static class |
JobManagerMessages.TaskManagerInstance
Returns the
Instance object of the requested task manager. |
static class |
JobManagerMessages.TaskManagerInstance$ |
static class |
JobManagerMessages.TriggerSavepoint
Triggers a savepoint for the specified job.
|
static class |
JobManagerMessages.TriggerSavepoint$ |
static class |
JobManagerMessages.TriggerSavepointFailure
Response after a failed savepoint trigger containing the failure cause.
|
static class |
JobManagerMessages.TriggerSavepointFailure$ |
static class |
JobManagerMessages.TriggerSavepointSuccess
Response after a successful savepoint trigger containing the savepoint path.
|
static class |
JobManagerMessages.TriggerSavepointSuccess$ |
Constructor and Description |
---|
JobManagerMessages() |
Modifier and Type | Method and Description |
---|---|
static Object |
getDisposeSavepointSuccess() |
static Object |
getJobManagerStatusAlive() |
static Object |
getRecoverAllJobs() |
static Object |
getRequestArchive() |
static Object |
getRequestBlobManagerPort() |
static Object |
getRequestJobManagerStatus() |
static Object |
getRequestJobStatus(JobID jobId) |
static Object |
getRequestLeaderSessionID() |
static Object |
getRequestNumberRegisteredTaskManager() |
static Object |
getRequestRegisteredTaskManagers() |
static Object |
getRequestRunningJobs() |
static Object |
getRequestRunningJobsStatus() |
static Object |
getRequestTotalNumberOfSlots() |
static Object |
getRequestWebMonitorPort() |
public static Object getRequestNumberRegisteredTaskManager()
public static Object getRequestTotalNumberOfSlots()
public static Object getRequestBlobManagerPort()
public static Object getRequestRunningJobs()
public static Object getRequestRunningJobsStatus()
public static Object getRequestRegisteredTaskManagers()
public static Object getRequestJobManagerStatus()
public static Object getJobManagerStatusAlive()
public static Object getRequestLeaderSessionID()
public static Object getRequestArchive()
public static Object getRecoverAllJobs()
public static Object getRequestWebMonitorPort()
public static Object getDisposeSavepointSuccess()
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.