ApplicationClient$ |
ApplicationMaster$ |
ApplicationMasterBase
Base class for all application masters.
|
ApplicationMasterBase$ |
FlinkYarnClientBase
All classes in this package contain code taken from
https://github.com/apache/hadoop-common/blob/trunk/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-applications/hadoop-yarn-applications-distributedshell/src/main/java/org/apache/hadoop/yarn/applications/distributedshell/Client.java?source=cc
and
https://github.com/hortonworks/simple-yarn-app
and
https://github.com/yahoo/storm-yarn/blob/master/src/main/java/com/yahoo/storm/yarn/StormOnYarn.java
The Flink jar is uploaded to HDFS by this client.
|
FlinkYarnClientBase.YarnDeploymentException |
RegisterApplicationMasterResponseReflector$
Singleton object to reflect the getContainersFromPreviousAttempts method for
RegisterApplicationMasterResponse .
|
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.JobManagerStopped$ |
YarnMessages.LocalGetYarnClusterStatus$ |
YarnMessages.LocalGetYarnMessage$ |
YarnMessages.LocalStopAMAfterJob$ |
YarnMessages.LocalStopYarnSession$ |
YarnMessages.PollYarnClusterStatus$ |
YarnMessages.RegisterApplicationClient$
|
YarnMessages.StartYarnSession$ |
YarnMessages.StopAMAfterJob$ |
YarnMessages.StopYarnSession$ |
YarnMessages.TriggerApplicationClientRegistration$ |
YarnMessages.UnregisterClient$ |
YarnMessages.YarnContainersAllocated$ |
YarnMessages.YarnContainersCompleted$ |
YarnMessages.YarnMessage |
YarnMessages.YarnMessage$ |
YarnMessages$ |
YarnTaskManager
An extension of the TaskManager that listens for additional YARN related
messages.
|