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.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.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$