Class | Description |
---|---|
AbstractYarnClusterDescriptor |
The descriptor with deployment information for spwaning or resuming a
YarnClusterClient . |
ApplicationClient |
Actor which is responsible to repeatedly poll the Yarn cluster status from the ResourceManager.
|
ApplicationClient$ | |
RegisteredYarnWorkerNode |
A representation of a registered Yarn container managed by the
YarnFlinkResourceManager . |
Utils |
Utility class that provides helper methods to work with Apache Hadoop YARN.
|
YarnApplicationMasterRunner |
This class is the executable entry point for the YARN application master.
|
YarnClusterClient |
Java representation of a running Flink cluster within YARN.
|
YarnClusterDescriptor |
Default implementation of
AbstractYarnClusterDescriptor which starts an YarnApplicationMasterRunner . |
YarnConfigKeys |
The Yarn environment variables used for settings of the containers.
|
YarnContainerInLaunch |
This class describes a container in which a TaskManager is being launched (or
has been launched) but where the TaskManager has not properly registered, yet.
|
YarnFlinkResourceManager |
Specialized Flink Resource Manager implementation for YARN clusters.
|
YarnJobManager |
JobManager actor for execution on Yarn.
|
YarnMessages | |
YarnMessages.AcknowledgeApplicationClientRegistration$ |
Response to a
RegisterApplicationClient message which led to a successful registration
of the ApplicationClient |
YarnMessages.ApplicationMasterStatus | |
YarnMessages.ApplicationMasterStatus$ | |
YarnMessages.CheckForUserCommand$ | |
YarnMessages.HeartbeatWithYarn$ | |
YarnMessages.JobManagerLeaderAddress |
Notification message that a new leader has been found.
|
YarnMessages.JobManagerLeaderAddress$ | |
YarnMessages.LocalGetYarnMessage$ | |
YarnMessages.LocalStopYarnSession | |
YarnMessages.LocalStopYarnSession$ | |
YarnMessages.RegisterApplicationClient$ |
Registration message sent from the
ApplicationClient to the YarnFlinkResourceManager . |
YarnMessages.StartYarnSession |
Entry point to start a new YarnSession.
|
YarnMessages.StartYarnSession$ | |
YarnMessages.TriggerApplicationClientRegistration |
Triggers the registration of the ApplicationClient to the YarnJobManager
|
YarnMessages.TriggerApplicationClientRegistration$ | |
YarnMessages.YarnContainersAllocated |
Callback from the async ResourceManager client when containers were allocated.
|
YarnMessages.YarnContainersAllocated$ | |
YarnMessages.YarnContainersCompleted |
Callback from the async ResourceManager client when containers were completed.
|
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$ | |
YarnTaskManagerRunner |
The entry point for running a TaskManager in a YARN container.
|
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.