AbstractYarnClusterDescriptor
The descriptor with deployment information for spawning or resuming a YarnClusterClient .
|
ApplicationClient$ |
RegisteredYarnWorkerNode
|
YarnClusterClient
Java representation of a running Flink cluster within YARN.
|
YarnFlinkResourceManager
Specialized Flink Resource Manager implementation for YARN clusters.
|
YarnMessages.AcknowledgeApplicationClientRegistration$
Response to a RegisterApplicationClient message which led to a successful registration
of the ApplicationClient
|
YarnMessages.ApplicationMasterStatus$ |
YarnMessages.CheckForUserCommand$ |
YarnMessages.HeartbeatWithYarn$ |
YarnMessages.JobManagerLeaderAddress$ |
YarnMessages.LocalGetYarnMessage$ |
YarnMessages.LocalStopYarnSession$ |
YarnMessages.RegisterApplicationClient$
|
YarnMessages.StartYarnSession$ |
YarnMessages.TriggerApplicationClientRegistration$ |
YarnMessages.YarnContainersAllocated$ |
YarnMessages.YarnContainersCompleted$ |
YarnMessages$ |
YarnResourceManagerCallbackHandler
This class reacts to callbacks from the YARN Resource Manager.
|
YarnTaskManager
An extension of the TaskManager that listens for additional YARN related
messages.
|
YarnTaskManager$ |