org.apache.flink.runtime.messages

Interfaces

• JobManagerMessages.CancellationResponse
• JobManagerMessages.JobManagerStatus
• JobManagerMessages.JobResponse
• JobManagerMessages.JobResultMessage
• JobManagerMessages.JobStatusResponse
• JobManagerMessages.StoppingResponse
• MessageDecorator
• RegistrationMessages.RegistrationMessage
• RequiresLeaderSessionID
• StackTraceSampleMessages.StackTraceSampleMessages
• TaskManagerMessages.LogTypeRequest
• TaskMessages.TaskMessage

Classes

• Acknowledge
• ArchiveMessages
• ArchiveMessages.ArchivedJob
• ArchiveMessages.ArchivedJob$
• ArchiveMessages.ArchivedJobs
• ArchiveMessages.ArchivedJobs$
• ArchiveMessages.ArchiveExecutionGraph
• ArchiveMessages.ArchiveExecutionGraph$
• ArchiveMessages.RequestArchivedJob
• ArchiveMessages.RequestArchivedJob$
• ArchiveMessages.RequestArchivedJobs$
• ArchiveMessages.RequestJobCounts$
• ArchiveMessages$
• ExecutionGraphMessages
• ExecutionGraphMessages.ExecutionStateChanged
• ExecutionGraphMessages.ExecutionStateChanged$
• ExecutionGraphMessages.JobStatusChanged
• ExecutionGraphMessages.JobStatusChanged$
• ExecutionGraphMessages$
• JobClientMessages
• JobClientMessages.AttachToJobAndWait
• JobClientMessages.AttachToJobAndWait$
• JobClientMessages.ConnectionTimeout
• JobClientMessages.ConnectionTimeout$
• JobClientMessages.JobManagerActorRef
• JobClientMessages.JobManagerActorRef$
• JobClientMessages.JobManagerLeaderAddress
• JobClientMessages.JobManagerLeaderAddress$
• JobClientMessages.RegistrationTimeout$
• JobClientMessages.SubmissionTimeout$
• JobClientMessages.SubmitJobAndWait
• JobClientMessages.SubmitJobAndWait$
• JobClientMessages$
• JobManagerMessages
• JobManagerMessages.CancelJob
• JobManagerMessages.CancelJob$
• JobManagerMessages.CancelJobWithSavepoint
• JobManagerMessages.CancelJobWithSavepoint$
• JobManagerMessages.CancellationFailure
• JobManagerMessages.CancellationFailure$
• JobManagerMessages.CancellationSuccess
• JobManagerMessages.CancellationSuccess$
• JobManagerMessages.ClassloadingProps
• JobManagerMessages.ClassloadingProps$
• JobManagerMessages.CurrentJobStatus
• JobManagerMessages.CurrentJobStatus$
• JobManagerMessages.DisposeSavepoint
• JobManagerMessages.DisposeSavepoint$
• JobManagerMessages.DisposeSavepointFailure
• JobManagerMessages.DisposeSavepointFailure$
• JobManagerMessages.DisposeSavepointSuccess$
• JobManagerMessages.GrantLeadership
• JobManagerMessages.GrantLeadership$
• JobManagerMessages.JobFound
• JobManagerMessages.JobFound$
• JobManagerMessages.JobManagerStatusAlive$
• JobManagerMessages.JobNotFound
• JobManagerMessages.JobNotFound$
• JobManagerMessages.JobResultFailure
• JobManagerMessages.JobResultFailure$
• JobManagerMessages.JobResultSuccess
• JobManagerMessages.JobResultSuccess$
• JobManagerMessages.JobSubmitSuccess
• JobManagerMessages.JobSubmitSuccess$
• JobManagerMessages.LeaderSessionMessage
• JobManagerMessages.LeaderSessionMessage$
• JobManagerMessages.NextInputSplit
• JobManagerMessages.NextInputSplit$
• JobManagerMessages.RecoverAllJobs$
• JobManagerMessages.RecoverJob
• JobManagerMessages.RecoverJob$
• JobManagerMessages.RecoverSubmittedJob
• JobManagerMessages.RecoverSubmittedJob$
• JobManagerMessages.RegisteredTaskManagers
• JobManagerMessages.RegisteredTaskManagers$
• JobManagerMessages.RegisterJobClient
• JobManagerMessages.RegisterJobClient$
• JobManagerMessages.RegisterJobClientSuccess
• JobManagerMessages.RegisterJobClientSuccess$
• JobManagerMessages.RemoveCachedJob
• JobManagerMessages.RemoveCachedJob$
• JobManagerMessages.RemoveJob
• JobManagerMessages.RemoveJob$
• JobManagerMessages.RequestArchive$
• JobManagerMessages.RequestBlobManagerPort$
• JobManagerMessages.RequestClassloadingProps
• JobManagerMessages.RequestClassloadingProps$
• JobManagerMessages.RequestJob
• JobManagerMessages.RequestJob$
• JobManagerMessages.RequestJobManagerStatus$
• JobManagerMessages.RequestJobStatus
• JobManagerMessages.RequestJobStatus$
• JobManagerMessages.RequestLeaderSessionID$
• JobManagerMessages.RequestNextInputSplit
• JobManagerMessages.RequestNextInputSplit$
• JobManagerMessages.RequestNumberRegisteredTaskManager$
• JobManagerMessages.RequestPartitionProducerState
• JobManagerMessages.RequestPartitionProducerState$
• JobManagerMessages.RequestRegisteredTaskManagers$
• JobManagerMessages.RequestRunningJobs$
• JobManagerMessages.RequestRunningJobsStatus$
• JobManagerMessages.RequestStackTrace
• JobManagerMessages.RequestStackTrace$
• JobManagerMessages.RequestTaskManagerInstance
• JobManagerMessages.RequestTaskManagerInstance$
• JobManagerMessages.RequestTotalNumberOfSlots$
• JobManagerMessages.RequestWebMonitorPort$
• JobManagerMessages.ResponseArchive
• JobManagerMessages.ResponseArchive$
• JobManagerMessages.ResponseLeaderSessionID
• JobManagerMessages.ResponseLeaderSessionID$
• JobManagerMessages.ResponseWebMonitorPort
• JobManagerMessages.ResponseWebMonitorPort$
• JobManagerMessages.RevokeLeadership$
• JobManagerMessages.RunningJobs
• JobManagerMessages.RunningJobs$
• JobManagerMessages.RunningJobsStatus
• JobManagerMessages.RunningJobsStatus$
• JobManagerMessages.ScheduleOrUpdateConsumers
• JobManagerMessages.ScheduleOrUpdateConsumers$
• JobManagerMessages.StopJob
• JobManagerMessages.StopJob$
• JobManagerMessages.StoppingFailure
• JobManagerMessages.StoppingFailure$
• JobManagerMessages.StoppingSuccess
• JobManagerMessages.StoppingSuccess$
• JobManagerMessages.SubmitJob
• JobManagerMessages.SubmitJob$
• JobManagerMessages.TaskManagerInstance
• JobManagerMessages.TaskManagerInstance$
• JobManagerMessages.TriggerSavepoint
• JobManagerMessages.TriggerSavepoint$
• JobManagerMessages.TriggerSavepointFailure
• JobManagerMessages.TriggerSavepointFailure$
• JobManagerMessages.TriggerSavepointSuccess
• JobManagerMessages.TriggerSavepointSuccess$
• JobManagerMessages$
• LeaderSessionMessageDecorator
• Messages
• Messages.Disconnect
• Messages.Disconnect$
• Messages$
• RegistrationMessages
• RegistrationMessages.AcknowledgeRegistration
• RegistrationMessages.AcknowledgeRegistration$
• RegistrationMessages.AlreadyRegistered
• RegistrationMessages.AlreadyRegistered$
• RegistrationMessages.RefuseRegistration
• RegistrationMessages.RefuseRegistration$
• RegistrationMessages.RegisterTaskManager
• RegistrationMessages.RegisterTaskManager$
• RegistrationMessages.TriggerTaskManagerRegistration
• RegistrationMessages.TriggerTaskManagerRegistration$
• RegistrationMessages$
• StackTrace
• StackTraceSampleMessages
• StackTraceSampleMessages.SampleTaskStackTrace
• StackTraceSampleMessages.SampleTaskStackTrace$
• StackTraceSampleMessages.TriggerStackTraceSample
• StackTraceSampleMessages.TriggerStackTraceSample$
• StackTraceSampleMessages$
• StackTraceSampleResponse
• TaskManagerMessages
• TaskManagerMessages.FatalError
• TaskManagerMessages.FatalError$
• TaskManagerMessages.Heartbeat
• TaskManagerMessages.Heartbeat$
• TaskManagerMessages.JobManagerLeaderAddress
• TaskManagerMessages.JobManagerLeaderAddress$
• TaskManagerMessages.LogFileRequest$
• TaskManagerMessages.NotifyWhenRegisteredAtJobManager$
• TaskManagerMessages.RegisteredAtJobManager
• TaskManagerMessages.RegisteredAtJobManager$
• TaskManagerMessages.RequestBroadcastVariablesWithReferences$
• TaskManagerMessages.RequestNumActiveConnections$
• TaskManagerMessages.RequestTaskManagerLog
• TaskManagerMessages.RequestTaskManagerLog$
• TaskManagerMessages.ResponseBroadcastVariablesWithReferences
• TaskManagerMessages.ResponseBroadcastVariablesWithReferences$
• TaskManagerMessages.ResponseNumActiveConnections
• TaskManagerMessages.ResponseNumActiveConnections$
• TaskManagerMessages.SendHeartbeat$
• TaskManagerMessages.SendStackTrace$
• TaskManagerMessages.StackTrace
• TaskManagerMessages.StackTrace$
• TaskManagerMessages.StdOutFileRequest$
• TaskManagerMessages$
• TaskMessages
• TaskMessages.CancelTask
• TaskMessages.CancelTask$
• TaskMessages.FailIntermediateResultPartitions
• TaskMessages.FailIntermediateResultPartitions$
• TaskMessages.FailTask
• TaskMessages.FailTask$
• TaskMessages.StopTask
• TaskMessages.StopTask$
• TaskMessages.SubmitTask
• TaskMessages.SubmitTask$
• TaskMessages.TaskInFinalState
• TaskMessages.TaskInFinalState$
• TaskMessages.UpdatePartitionInfo
• TaskMessages.UpdateTaskExecutionState
• TaskMessages.UpdateTaskExecutionState$
• TaskMessages.UpdateTaskMultiplePartitionInfos
• TaskMessages.UpdateTaskMultiplePartitionInfos$
• TaskMessages.UpdateTaskSinglePartitionInfo
• TaskMessages.UpdateTaskSinglePartitionInfo$
• TaskMessages$