ArchiveMessages.ArchivedJob$ |
ArchiveMessages.ArchivedJobs$ |
ArchiveMessages.ArchiveExecutionGraph$ |
ArchiveMessages.RequestArchivedJob$ |
ArchiveMessages.RequestArchivedJobs$
Request the currently archived jobs in the archiver.
|
ArchiveMessages.RequestJobCounts$
Requests the number of finished, canceled, and failed jobs
|
ArchiveMessages$
This object contains the archive specific messages.
|
ExecutionGraphMessages.ExecutionStateChanged$ |
ExecutionGraphMessages.JobStatusChanged$ |
ExecutionGraphMessages$
This object contains the execution graph specific messages.
|
JobClientMessages.ConnectionTimeout$
Messaeg which is triggered when the connection timeout has been reached.
|
JobClientMessages.JobManagerActorRef$ |
JobClientMessages.JobManagerLeaderAddress$ |
JobClientMessages.SubmissionTimeout$
Message which is triggered when the submission timeout has been reached.
|
JobClientMessages.SubmitJobAndWait$ |
JobClientMessages.SubmitJobDetached$ |
JobClientMessages$
This object contains the JobClient specific messages
|
JobManagerMessages.CancelJob$ |
JobManagerMessages.CancellationFailure$ |
JobManagerMessages.CancellationResponse |
JobManagerMessages.CancellationSuccess$ |
JobManagerMessages.CurrentJobStatus$ |
JobManagerMessages.DisposeSavepoint$ |
JobManagerMessages.DisposeSavepointFailure$ |
JobManagerMessages.DisposeSavepointSuccess$
Response after a successful savepoint dispose.
|
JobManagerMessages.GrantLeadership$ |
JobManagerMessages.JobFound$ |
JobManagerMessages.JobManagerStatus
Response to RequestJobManagerStatus
|
JobManagerMessages.JobManagerStatusAlive$ |
JobManagerMessages.JobNotFound$ |
JobManagerMessages.JobResponse |
JobManagerMessages.JobResultFailure$ |
JobManagerMessages.JobResultSuccess$ |
JobManagerMessages.JobStatusResponse |
JobManagerMessages.JobSubmitSuccess$ |
JobManagerMessages.LeaderSessionMessage$ |
JobManagerMessages.NextInputSplit$ |
JobManagerMessages.RecoverAllJobs$
Triggers recovery of all available jobs.
|
JobManagerMessages.RecoverJob$ |
JobManagerMessages.RecoverSubmittedJob$ |
JobManagerMessages.RegisteredTaskManagers$ |
JobManagerMessages.RemoveCachedJob$ |
JobManagerMessages.RemoveJob$ |
JobManagerMessages.RequestArchive$
Requests the ActorRef of the archiver
|
JobManagerMessages.RequestBlobManagerPort$
Requests the port of the blob manager from the job manager.
|
JobManagerMessages.RequestJob$ |
JobManagerMessages.RequestJobManagerStatus$
Requests the current state of the job manager
|
JobManagerMessages.RequestJobStatus$ |
JobManagerMessages.RequestLeaderSessionID$
Requests the current leader session ID of the job manager.
|
JobManagerMessages.RequestNextInputSplit$ |
JobManagerMessages.RequestNumberRegisteredTaskManager$
Requests the number of currently registered task manager at the job manager.
|
JobManagerMessages.RequestPartitionState$ |
JobManagerMessages.RequestRegisteredTaskManagers$
Requests the instances of all registered task managers.
|
JobManagerMessages.RequestRunningJobs$
Requests all currently running jobs from the job manager.
|
JobManagerMessages.RequestRunningJobsStatus$
Requests the status of all currently running jobs from the job manager.
|
JobManagerMessages.RequestStackTrace$ |
JobManagerMessages.RequestTaskManagerInstance$ |
JobManagerMessages.RequestTotalNumberOfSlots$
Requests the maximum number of slots available to the job manager.
|
JobManagerMessages.RequestWebMonitorPort$
|
JobManagerMessages.ResponseArchive$ |
JobManagerMessages.ResponseLeaderSessionID$ |
JobManagerMessages.ResponseWebMonitorPort$ |
JobManagerMessages.RevokeLeadership$
Revokes leadership of the receiver.
|
JobManagerMessages.RunningJobs$ |
JobManagerMessages.RunningJobsStatus$ |
JobManagerMessages.ScheduleOrUpdateConsumers$ |
JobManagerMessages.StopJob$ |
JobManagerMessages.StoppingFailure$ |
JobManagerMessages.StoppingResponse |
JobManagerMessages.StoppingSuccess$ |
JobManagerMessages.SubmitJob$ |
JobManagerMessages.TaskManagerInstance$ |
JobManagerMessages.TriggerSavepoint$ |
JobManagerMessages.TriggerSavepointFailure$ |
JobManagerMessages.TriggerSavepointSuccess$ |
JobManagerMessages$
The job manager specific actor messages
|
MessageDecorator
Interface for message decorators
|
Messages.Acknowledge$
Message to signal the successful reception of another message
|
Messages.Disconnect$ |
Messages$
Generic messages between JobManager, TaskManager, JobClient.
|
RegistrationMessages.AcknowledgeRegistration$ |
RegistrationMessages.AlreadyRegistered$ |
RegistrationMessages.RefuseRegistration$ |
RegistrationMessages.RegisterTaskManager$ |
RegistrationMessages.RegistrationMessage
Marker trait for registration messages.
|
RegistrationMessages.TriggerTaskManagerRegistration$ |
RegistrationMessages$
A set of messages from the between TaskManager and JobManager handle the
registration of the TaskManager at the JobManager.
|
RequiresLeaderSessionID
|
StackTraceSampleMessages.ResponseStackTraceSampleFailure$ |
StackTraceSampleMessages.ResponseStackTraceSampleSuccess$ |
StackTraceSampleMessages.SampleTaskStackTrace$ |
StackTraceSampleMessages.StackTraceSampleMessages |
StackTraceSampleMessages.TriggerStackTraceSample$ |
StackTraceSampleMessages$
A set of messages exchanged with task manager instances in order to sample
the stack traces of running tasks.
|
TaskManagerMessages.FatalError$ |
TaskManagerMessages.Heartbeat$ |
TaskManagerMessages.JobManagerLeaderAddress$ |
TaskManagerMessages.NotifyWhenRegisteredAtAnyJobManager$
Requests a notification from the task manager as soon as the task manager has been
registered at any job manager.
|
TaskManagerMessages.RegisteredAtJobManager$
Acknowledges that the task manager has been successfully registered at any job manager.
|
TaskManagerMessages.SendHeartbeat$
Tells the task manager to send a heartbeat message to the job manager.
|
TaskManagerMessages.SendStackTrace$
Tells the TaskManager to send a stack trace of all threads to the sender.
|
TaskManagerMessages.StackTrace$ |
TaskManagerMessages$
Miscellaneous actor messages exchanged with the TaskManager.
|
TaskMessages.CancelTask$ |
TaskMessages.FailIntermediateResultPartitions$ |
TaskMessages.FailTask$ |
TaskMessages.PartitionState$ |
TaskMessages.StopTask$ |
TaskMessages.SubmitTask$ |
TaskMessages.TaskInFinalState$ |
TaskMessages.TaskMessage
Marker trait for task messages.
|
TaskMessages.TaskOperationResult$ |
TaskMessages.UpdatePartitionInfo
Base class for messages that update the information about location of input partitions
|
TaskMessages.UpdateTaskExecutionState$ |
TaskMessages.UpdateTaskMultiplePartitionInfos |
TaskMessages.UpdateTaskMultiplePartitionInfos$ |
TaskMessages.UpdateTaskSinglePartitionInfo$ |
TaskMessages$
A set of messages that control the deployment and the state of Tasks executed
on the TaskManager.
|