Acknowledge
A generic acknowledgement message.
|
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.AttachToJobAndWait$ |
JobClientMessages.ConnectionTimeout$ |
JobClientMessages.JobManagerActorRef$ |
JobClientMessages.JobManagerLeaderAddress$ |
JobClientMessages.RegistrationTimeout$
Message which is triggered when the JobClient registration at the JobManager times out
|
JobClientMessages.SubmissionTimeout$
Message which is triggered when the submission timeout has been reached.
|
JobClientMessages.SubmitJobAndWait$ |
JobClientMessages$
This object contains the JobClient specific messages
|
JobManagerMessages.CancelJob$ |
JobManagerMessages.CancelJobWithSavepoint$ |
JobManagerMessages.CancellationFailure$ |
JobManagerMessages.CancellationResponse |
JobManagerMessages.CancellationSuccess$ |
JobManagerMessages.ClassloadingProps$ |
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.JobResultMessage
Denotes messages which contain the result of a completed job execution
|
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.RegisterJobClient$ |
JobManagerMessages.RegisterJobClientSuccess$ |
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.RequestClassloadingProps$ |
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.RequestPartitionProducerState$ |
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.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 between TaskManager and JobManager to handle the
registration of the TaskManager at the JobManager.
|
RequiresLeaderSessionID
|
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.LogFileRequest$
Indicates a request for the .log file
|
TaskManagerMessages.LogTypeRequest
Trait do differentiate which log file is requested
|
TaskManagerMessages.NotifyWhenRegisteredAtJobManager$
Requests a notification from the task manager as soon as the task manager has been
registered at a job manager.
|
TaskManagerMessages.RegisteredAtJobManager$ |
TaskManagerMessages.RequestBroadcastVariablesWithReferences$
Requests the number of broadcast variables with references
|
TaskManagerMessages.RequestNumActiveConnections$
Requests the number of active connections at the ConnectionManager
|
TaskManagerMessages.RequestTaskManagerLog$ |
TaskManagerMessages.ResponseBroadcastVariablesWithReferences$ |
TaskManagerMessages.ResponseNumActiveConnections$ |
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.StdOutFileRequest$
Indicates a request for the .out file
|
TaskManagerMessages$
Miscellaneous actor messages exchanged with the TaskManager.
|
TaskMessages.CancelTask$ |
TaskMessages.FailIntermediateResultPartitions$ |
TaskMessages.FailTask$ |
TaskMessages.StopTask$ |
TaskMessages.SubmitTask$ |
TaskMessages.TaskInFinalState$ |
TaskMessages.TaskMessage
Marker trait for task messages.
|
TaskMessages.UpdatePartitionInfo
Base class for messages that update the information about location of input partitions
|
TaskMessages.UpdateTaskExecutionState$ |
TaskMessages.UpdateTaskMultiplePartitionInfos
param: executionID The task's execution attempt ID.
|
TaskMessages.UpdateTaskMultiplePartitionInfos$ |
TaskMessages.UpdateTaskSinglePartitionInfo$ |
TaskMessages$
A set of messages that control the deployment and the state of Tasks executed
on the TaskManager.
|