Class | Description |
---|---|
AbstractYarnClusterDescriptor |
The descriptor with deployment information for spawning or resuming a
YarnClusterClient . |
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.
|
YarnClusterClientV2 |
Java representation of a running Flink job on YARN.
|
YarnClusterDescriptor |
Default implementation of
AbstractYarnClusterDescriptor which starts an YarnApplicationMasterRunner . |
YarnClusterDescriptorV2 |
Implementation of
AbstractYarnClusterDescriptor which is used to start the new application master for a job under flip-6. |
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.
|
YarnResourceManager |
The yarn implementation of the resource manager.
|
YarnResourceManagerCallbackHandler |
This class reacts to callbacks from the YARN Resource Manager.
|
YarnTaskExecutorRunner |
This class is the executable entry point for running a TaskExecutor in a YARN container.
|
YarnTaskManagerRunnerFactory |
The entry point for running a TaskManager in a YARN container.
|
YarnTaskManagerRunnerFactory.Runner |
Runner for a
YarnTaskManager . |
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.