Package | Description |
---|---|
org.apache.flink.runtime.messages |
This package contains the messages that are sent between actors, like the
JobManager and
TaskManager to coordinate the distributed operations. |
org.apache.flink.yarn |
Modifier and Type | Interface and Description |
---|---|
static interface |
RegistrationMessages.RegistrationMessage
Marker trait for registration messages.
|
Modifier and Type | Class and Description |
---|---|
static class |
ExecutionGraphMessages.ExecutionStateChanged
Denotes the execution state change of an
ExecutionVertex |
static class |
ExecutionGraphMessages.JobStatusChanged
Denotes the job state change of a job.
|
static class |
JobClientMessages.ConnectionTimeout$
Messaeg which is triggered when the connection timeout has been reached.
|
static class |
JobClientMessages.JobManagerActorRef
Notifies the JobClientActor about the ActorRef of the new leader.
|
static class |
JobClientMessages.SubmissionTimeout$
Message which is triggered when the submission timeout has been reached.
|
static class |
JobManagerMessages.CancelJob
Cancels a job with the given
jobID at the JobManager. |
static class |
JobManagerMessages.DisposeSavepoint
Disposes a savepoint.
|
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.RecoverSubmittedJob
Triggers the submission of the recovered job
|
static class |
JobManagerMessages.RemoveJob
Triggers the removal of the job with the given job ID
|
static class |
JobManagerMessages.RequestNextInputSplit
Requesting next input split for the
ExecutionJobVertex
of the job specified by jobID . |
static class |
JobManagerMessages.RequestPartitionState
Requests the current state of the partition.
|
static class |
JobManagerMessages.ScheduleOrUpdateConsumers
Notifies the
JobManager about available data for a
produced partition. |
static class |
JobManagerMessages.StopJob
Stops a (streaming) job with the given
jobID at the JobManager. |
static class |
JobManagerMessages.SubmitJob
Submits a job to the job manager.
|
static class |
JobManagerMessages.TriggerSavepoint
Triggers a savepoint for the specified job.
|
static class |
Messages.Disconnect
Signals that the receiver (JobManager/TaskManager) shall disconnect the sender.
|
static class |
RegistrationMessages.AcknowledgeRegistration
Denotes the successful registration of a task manager at the job manager.
|
static class |
RegistrationMessages.AlreadyRegistered
Denotes that the TaskManager has already been registered at the JobManager.
|
static class |
RegistrationMessages.RefuseRegistration
Denotes the unsuccessful registration of a task manager at the job manager.
|
static class |
RegistrationMessages.RegisterTaskManager
Registers a task manager at the job manager.
|
static class |
RegistrationMessages.TriggerTaskManagerRegistration
Triggers the TaskManager to attempt a registration at the JobManager.
|
static class |
TaskMessages.CancelTask
Cancels the task associated with
attemptID . |
static class |
TaskMessages.FailIntermediateResultPartitions
Fails (and releases) all intermediate result partitions identified by
executionID from the task manager. |
static class |
TaskMessages.PartitionState
Answer to a
RequestPartitionState with the state of the respective partition. |
static class |
TaskMessages.StopTask
Stops the task associated with
attemptID . |
static class |
TaskMessages.SubmitTask
Submits a task to the task manager.
|
static class |
TaskMessages.UpdatePartitionInfo
Base class for messages that update the information about location of input partitions
|
static class |
TaskMessages.UpdateTaskExecutionState
Denotes a state change of a task at the JobManager.
|
static class |
TaskMessages.UpdateTaskMultiplePartitionInfos |
static class |
TaskMessages.UpdateTaskSinglePartitionInfo |
Modifier and Type | Class and Description |
---|---|
static class |
YarnMessages.AcknowledgeApplicationClientRegistration$
Response to a
RegisterApplicationClient message which led to a successful registration
of the ApplicationClient |
static class |
YarnMessages.RegisterApplicationClient$
Registration message sent from the
ApplicationClient to the YarnJobManager . |
static class |
YarnMessages.StopAMAfterJob |
static class |
YarnMessages.StopYarnSession |
static class |
YarnMessages.TriggerApplicationClientRegistration
Triggers the registration of the ApplicationClient to the YarnJobManager
|
static class |
YarnMessages.UnregisterClient$ |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.