A C D E F G H I K L M N O P R S U V W Y

A

addGeneralOptions(Options) - 类 中的方法org.apache.flink.yarn.cli.FlinkYarnSessionCli

addRunOptions(Options) - 类 中的方法org.apache.flink.yarn.cli.FlinkYarnSessionCli

addShipFiles(List<File>) - 类 中的方法org.apache.flink.yarn.YarnClusterDescriptor

Adds the given files to the list of files to ship.

addToEnvironment(Map<String, String>, String, String) - 类 中的静态方法org.apache.flink.yarn.Utils

Copied method from org.apache.hadoop.yarn.util.Apps.

APP_MASTER_RPC_ADDRESS - 类 中的静态变量org.apache.flink.yarn.configuration.YarnConfigOptions

The hostname or address where the application master RPC system is listening.

APP_MASTER_RPC_PORT - 类 中的静态变量org.apache.flink.yarn.configuration.YarnConfigOptions

The port where the application master RPC system is listening.

APP_MASTER_VCORES - 类 中的静态变量org.apache.flink.yarn.configuration.YarnConfigOptions

The vcores used by YARN application master.

APPLICATION_ATTEMPT_FAILURE_VALIDITY_INTERVAL - 类 中的静态变量org.apache.flink.yarn.configuration.YarnConfigOptions

The config parameter defining the attemptFailuresValidityInterval of Yarn application.

APPLICATION_ATTEMPTS - 类 中的静态变量org.apache.flink.yarn.configuration.YarnConfigOptions

Set the number of retries for failed YARN ApplicationMasters/JobManagers in high availability mode.

APPLICATION_ID - 类 中的静态变量org.apache.flink.yarn.configuration.YarnConfigOptions

APPLICATION_LOG_CONFIG_FILE - 类 中的静态变量org.apache.flink.yarn.configuration.YarnConfigOptionsInternal

APPLICATION_MASTER_PORT - 类 中的静态变量org.apache.flink.yarn.configuration.YarnConfigOptions

The config parameter defining the Akka actor system port for the ApplicationMaster and JobManager.

APPLICATION_NAME - 类 中的静态变量org.apache.flink.yarn.configuration.YarnConfigOptions

APPLICATION_PRIORITY - 类 中的静态变量org.apache.flink.yarn.configuration.YarnConfigOptions

A non-negative integer indicating the priority for submitting a Flink YARN application.

APPLICATION_QUEUE - 类 中的静态变量org.apache.flink.yarn.configuration.YarnConfigOptions

APPLICATION_TAGS - 类 中的静态变量org.apache.flink.yarn.configuration.YarnConfigOptions

A comma-separated list of strings to use as YARN application tags.

APPLICATION_TYPE - 类 中的静态变量org.apache.flink.yarn.configuration.YarnConfigOptions

applyCommandLineOptionsToConfiguration(CommandLine) - 类 中的方法org.apache.flink.yarn.cli.FlinkYarnSessionCli

C

CLASSPATH_INCLUDE_USER_JAR - 类 中的静态变量org.apache.flink.yarn.configuration.YarnConfigOptions

Defines whether user-jars are included in the system class path for per-job-clusters as well as their positioning in the path.

close() - 类 中的方法org.apache.flink.yarn.cli.YarnApplicationStatusMonitor

close() - 类 中的方法org.apache.flink.yarn.YarnClusterDescriptor

CONFIG_FILE_LOG4J_NAME - 类 中的静态变量org.apache.flink.yarn.cli.FlinkYarnSessionCli

CONFIG_FILE_LOGBACK_NAME - 类 中的静态变量org.apache.flink.yarn.cli.FlinkYarnSessionCli

CONTAINER_REQUEST_HEARTBEAT_INTERVAL_MILLISECONDS - 类 中的静态变量org.apache.flink.yarn.configuration.YarnConfigOptions

The heartbeat interval between the Application Master and the YARN Resource Manager if Flink is requesting containers.

create(YarnClient) - 类 中的静态方法org.apache.flink.yarn.YarnClientYarnClusterInformationRetriever

createActiveResourceManager(Configuration, ResourceID, RpcService, HighAvailabilityServices, HeartbeatServices, FatalErrorHandler, ClusterInformation, String, ResourceManagerMetricGroup) - 类 中的方法org.apache.flink.yarn.entrypoint.YarnResourceManagerFactory

createAndStartNodeManagerClient(YarnConfiguration) - 类 中的方法org.apache.flink.yarn.YarnResourceManager

createAndStartResourceManagerClient(YarnConfiguration, int, String) - 类 中的方法org.apache.flink.yarn.YarnResourceManager

createClusterDescriptor(Configuration) - 类 中的方法org.apache.flink.yarn.YarnClusterClientFactory

createDispatcherResourceManagerComponentFactory(Configuration) - 类 中的方法org.apache.flink.yarn.entrypoint.YarnJobClusterEntrypoint

createDispatcherResourceManagerComponentFactory(Configuration) - 类 中的方法org.apache.flink.yarn.entrypoint.YarnSessionClusterEntrypoint

D

deleteApplicationFiles(Map<String, String>) - 类 中的静态方法org.apache.flink.yarn.Utils

Deletes the YARN application files, e.g., Flink binaries, libraries, etc., from the remote filesystem.

deployJobCluster(ClusterSpecification, JobGraph, boolean) - 类 中的方法org.apache.flink.yarn.YarnClusterDescriptor

deploySessionCluster(ClusterSpecification) - 类 中的方法org.apache.flink.yarn.YarnClusterDescriptor

E

ENV_APP_ID - 类 中的静态变量org.apache.flink.yarn.YarnConfigKeys

ENV_CLIENT_HOME_DIR - 类 中的静态变量org.apache.flink.yarn.YarnConfigKeys

ENV_CLIENT_SHIP_FILES - 类 中的静态变量org.apache.flink.yarn.YarnConfigKeys

ENV_FLINK_CLASSPATH - 类 中的静态变量org.apache.flink.yarn.YarnConfigKeys

ENV_HADOOP_USER_NAME - 类 中的静态变量org.apache.flink.yarn.YarnConfigKeys

ENV_KRB5_PATH - 类 中的静态变量org.apache.flink.yarn.YarnConfigKeys

ENV_YARN_SITE_XML_PATH - 类 中的静态变量org.apache.flink.yarn.YarnConfigKeys

ENV_ZOOKEEPER_NAMESPACE - 类 中的静态变量org.apache.flink.yarn.YarnConfigKeys

F

FLINK_DIST_JAR - 类 中的静态变量org.apache.flink.yarn.configuration.YarnConfigOptions

FLINK_JAR_PATH - 类 中的静态变量org.apache.flink.yarn.YarnConfigKeys

FLINK_YARN_FILES - 类 中的静态变量org.apache.flink.yarn.YarnConfigKeys

FlinkYarnSessionCli - org.apache.flink.yarn.cli中的类

Class handling the command line interface to the YARN session.

FlinkYarnSessionCli(Configuration, String, String, String) - 类 的构造器org.apache.flink.yarn.cli.FlinkYarnSessionCli

FlinkYarnSessionCli(Configuration, String, String, String, boolean) - 类 的构造器org.apache.flink.yarn.cli.FlinkYarnSessionCli

FlinkYarnSessionCli(Configuration, ClusterClientServiceLoader, String, String, String, boolean) - 类 的构造器org.apache.flink.yarn.cli.FlinkYarnSessionCli

G

getApplicationStatusNow() - 类 中的方法org.apache.flink.yarn.cli.YarnApplicationStatusMonitor

getClusterDescription() - 类 中的方法org.apache.flink.yarn.YarnClusterDescriptor

getClusterId(Configuration) - 类 中的方法org.apache.flink.yarn.YarnClusterClientFactory

getContainer() - 类 中的方法org.apache.flink.yarn.YarnWorkerNode

getCpuCores(Configuration) - 类 中的方法org.apache.flink.yarn.YarnResourceManager

getDynamicProperties(String) - 类 中的静态方法org.apache.flink.yarn.cli.FlinkYarnSessionCli

getExecutor(Configuration) - 类 中的方法org.apache.flink.yarn.executors.YarnJobClusterExecutorFactory

getExecutor(Configuration) - 类 中的方法org.apache.flink.yarn.executors.YarnSessionClusterExecutorFactory

getFlinkConfiguration() - 类 中的方法org.apache.flink.yarn.YarnClusterDescriptor

getId() - 类 中的方法org.apache.flink.yarn.cli.FlinkYarnSessionCli

getInstance() - 类 中的静态方法org.apache.flink.yarn.entrypoint.YarnResourceManagerFactory

getMaxVcores() - 类 中的方法org.apache.flink.yarn.YarnClientYarnClusterInformationRetriever

getMaxVcores() - 接口 中的方法org.apache.flink.yarn.YarnClusterInformationRetriever

Get the maximum number of vcores supported by the Yarn cluster.

getName() - 类 中的方法org.apache.flink.yarn.executors.YarnJobClusterExecutorFactory

getName() - 类 中的方法org.apache.flink.yarn.executors.YarnSessionClusterExecutorFactory

getNodeLabel() - 类 中的方法org.apache.flink.yarn.YarnClusterDescriptor

getProgress() - 类 中的方法org.apache.flink.yarn.YarnResourceManager

getResourceID() - 类 中的方法org.apache.flink.yarn.YarnWorkerNode

getRPCPortRange(Configuration) - 类 中的方法org.apache.flink.yarn.entrypoint.YarnJobClusterEntrypoint

getRPCPortRange(Configuration) - 类 中的方法org.apache.flink.yarn.entrypoint.YarnSessionClusterEntrypoint

getYarnClient() - 类 中的方法org.apache.flink.yarn.YarnClusterDescriptor

getYarnJobClusterEntrypoint() - 类 中的方法org.apache.flink.yarn.YarnClusterDescriptor

The class to start the application master with.

getYarnPropertiesLocation(String) - 类 中的静态方法org.apache.flink.yarn.cli.FlinkYarnSessionCli

getYarnSessionClusterEntrypoint() - 类 中的方法org.apache.flink.yarn.YarnClusterDescriptor

The class to start the application master with.

getZookeeperNamespace() - 类 中的方法org.apache.flink.yarn.YarnClusterDescriptor

H

HEARTBEAT_DELAY_SECONDS - 类 中的静态变量org.apache.flink.yarn.configuration.YarnConfigOptions

The heartbeat interval between the Application Master and the YARN Resource Manager.

I

initialize() - 类 中的方法org.apache.flink.yarn.YarnResourceManager

installSecurityContext(Configuration) - 类 中的静态方法org.apache.flink.yarn.entrypoint.YarnEntrypointUtils

installSecurityContext(Configuration) - 类 中的方法org.apache.flink.yarn.entrypoint.YarnJobClusterEntrypoint

installSecurityContext(Configuration) - 类 中的方法org.apache.flink.yarn.entrypoint.YarnSessionClusterEntrypoint

internalDeregisterApplication(ApplicationStatus, String) - 类 中的方法org.apache.flink.yarn.YarnResourceManager

isActive(CommandLine) - 类 中的方法org.apache.flink.yarn.cli.FlinkYarnSessionCli

isCompatibleWith(Configuration) - 类 中的方法org.apache.flink.yarn.executors.YarnJobClusterExecutorFactory

isCompatibleWith(Configuration) - 类 中的方法org.apache.flink.yarn.executors.YarnSessionClusterExecutorFactory

isCompatibleWith(Configuration) - 类 中的方法org.apache.flink.yarn.YarnClusterClientFactory

K

KEYTAB_FILE_NAME - 类 中的静态变量org.apache.flink.yarn.Utils

Keytab file name populated in YARN container.

KEYTAB_PATH - 类 中的静态变量org.apache.flink.yarn.YarnConfigKeys

KEYTAB_PRINCIPAL - 类 中的静态变量org.apache.flink.yarn.YarnConfigKeys

killCluster(ApplicationId) - 类 中的方法org.apache.flink.yarn.YarnClusterDescriptor

KRB5_FILE_NAME - 类 中的静态变量org.apache.flink.yarn.Utils

KRB5 file name populated in YARN container for secure IT run.

L

loadClientConfiguration() - 类 中的方法org.apache.flink.yarn.YarnResourceManager

loadConfiguration(String, Map<String, String>) - 类 中的静态方法org.apache.flink.yarn.entrypoint.YarnEntrypointUtils

LOG - 类 中的静态变量org.apache.flink.yarn.YarnTaskExecutorRunner

logDetachedClusterInformation(ApplicationId, Logger) - 类 中的静态方法org.apache.flink.yarn.YarnClusterDescriptor

logYarnEnvironmentInformation(Map<String, String>, Logger) - 类 中的静态方法org.apache.flink.yarn.entrypoint.YarnEntrypointUtils

M

main(String[]) - 类 中的静态方法org.apache.flink.yarn.cli.FlinkYarnSessionCli

main(String[]) - 类 中的静态方法org.apache.flink.yarn.entrypoint.YarnJobClusterEntrypoint

main(String[]) - 类 中的静态方法org.apache.flink.yarn.entrypoint.YarnSessionClusterEntrypoint

main(String[]) - 类 中的静态方法org.apache.flink.yarn.YarnTaskExecutorRunner

The entry point for the YARN task executor runner.

MAX_FAILED_CONTAINERS - 类 中的静态变量org.apache.flink.yarn.configuration.YarnConfigOptions

The maximum number of failed YARN containers before entirely stopping the YARN session / job on YARN.

N

NAME - 类 中的静态变量org.apache.flink.yarn.executors.YarnJobClusterExecutor

NAME - 类 中的静态变量org.apache.flink.yarn.executors.YarnSessionClusterExecutor

NODE_LABEL - 类 中的静态变量org.apache.flink.yarn.configuration.YarnConfigOptions

O

onContainersAllocated(List<Container>) - 类 中的方法org.apache.flink.yarn.YarnResourceManager

onContainersCompleted(List<ContainerStatus>) - 类 中的方法org.apache.flink.yarn.YarnResourceManager

onContainerStarted(ContainerId, Map<String, ByteBuffer>) - 类 中的方法org.apache.flink.yarn.YarnResourceManager

onContainerStatusReceived(ContainerId, ContainerStatus) - 类 中的方法org.apache.flink.yarn.YarnResourceManager

onContainerStopped(ContainerId) - 类 中的方法org.apache.flink.yarn.YarnResourceManager

onError(Throwable) - 类 中的方法org.apache.flink.yarn.YarnResourceManager

onGetContainerStatusError(ContainerId, Throwable) - 类 中的方法org.apache.flink.yarn.YarnResourceManager

onNodesUpdated(List<NodeReport>) - 类 中的方法org.apache.flink.yarn.YarnResourceManager

onShutdownRequest() - 类 中的方法org.apache.flink.yarn.YarnResourceManager

onStartContainerError(ContainerId, Throwable) - 类 中的方法org.apache.flink.yarn.YarnResourceManager

onStop() - 类 中的方法org.apache.flink.yarn.YarnResourceManager

onStopContainerError(ContainerId, Throwable) - 类 中的方法org.apache.flink.yarn.YarnResourceManager

org.apache.flink.yarn - 程序包 org.apache.flink.yarn

org.apache.flink.yarn.cli - 程序包 org.apache.flink.yarn.cli

org.apache.flink.yarn.configuration - 程序包 org.apache.flink.yarn.configuration

org.apache.flink.yarn.entrypoint - 程序包 org.apache.flink.yarn.entrypoint

org.apache.flink.yarn.executors - 程序包 org.apache.flink.yarn.executors

P

PROPERTIES_FILE_LOCATION - 类 中的静态变量org.apache.flink.yarn.configuration.YarnConfigOptions

When a Flink job is submitted to YARN, the JobManager's host and the number of available processing slots is written into a properties file, so that the Flink client is able to pick those details up.

R

REMOTE_RESOURCES_FETCH_NUM_RETRY - 类 中的静态变量org.apache.flink.yarn.Utils

Number of total retries to fetch the remote resources after uploaded in case of FileNotFoundException.

REMOTE_RESOURCES_FETCH_WAIT_IN_MILLI - 类 中的静态变量org.apache.flink.yarn.Utils

Time to wait in milliseconds between each remote resources fetch in case of FileNotFoundException.

retrieve(ApplicationId) - 类 中的方法org.apache.flink.yarn.YarnClusterDescriptor

run(String[]) - 类 中的方法org.apache.flink.yarn.cli.FlinkYarnSessionCli

S

setLocalJarPath(Path) - 类 中的方法org.apache.flink.yarn.YarnClusterDescriptor

setLogConfigFileInConfig(Configuration, String) - 类 中的静态方法org.apache.flink.yarn.cli.FlinkYarnSessionCli

setTokensFor(ContainerLaunchContext, List<Path>, Configuration) - 类 中的静态方法org.apache.flink.yarn.Utils

setupYarnClassPath(Configuration, Map<String, String>) - 类 中的静态方法org.apache.flink.yarn.Utils

SHIP_DIRECTORIES - 类 中的静态变量org.apache.flink.yarn.configuration.YarnConfigOptions

startNewWorker(ResourceProfile) - 类 中的方法org.apache.flink.yarn.YarnResourceManager

stopWorker(YarnWorkerNode) - 类 中的方法org.apache.flink.yarn.YarnResourceManager

U

Utils - org.apache.flink.yarn中的类

Utility class that provides helper methods to work with Apache Hadoop YARN.

V

valueOf(String) - 枚举 中的静态方法org.apache.flink.yarn.configuration.YarnConfigOptions.UserJarInclusion

返回带有指定名称的该类型的枚举常量。

values() - 枚举 中的静态方法org.apache.flink.yarn.configuration.YarnConfigOptions.UserJarInclusion

按照声明该枚举类型的常量的顺序, 返回 包含这些常量的数组。

VCORES - 类 中的静态变量org.apache.flink.yarn.configuration.YarnConfigOptions

The vcores exposed by YARN.

W

workerStarted(ResourceID) - 类 中的方法org.apache.flink.yarn.YarnResourceManager

Y

YARN_SITE_FILE_NAME - 类 中的静态变量org.apache.flink.yarn.Utils

Yarn site xml file name populated in YARN container for secure IT run.

YarnApplicationStatusMonitor - org.apache.flink.yarn.cli中的类

Utility class which monitors the specified yarn application status periodically.

YarnApplicationStatusMonitor(YarnClient, ApplicationId, ScheduledExecutor) - 类 的构造器org.apache.flink.yarn.cli.YarnApplicationStatusMonitor

YarnClientYarnClusterInformationRetriever - org.apache.flink.yarn中的类

YarnClusterInformationRetriever implementation which queries the Yarn cluster using a YarnClient instance.

YarnClusterClientFactory - org.apache.flink.yarn中的类

A ClusterClientFactory for a YARN cluster.

YarnClusterClientFactory() - 类 的构造器org.apache.flink.yarn.YarnClusterClientFactory

YarnClusterDescriptor - org.apache.flink.yarn中的类

The descriptor with deployment information for deploying a Flink cluster on Yarn.

YarnClusterDescriptor(Configuration, YarnConfiguration, YarnClient, YarnClusterInformationRetriever, boolean) - 类 的构造器org.apache.flink.yarn.YarnClusterDescriptor

YarnClusterInformationRetriever - org.apache.flink.yarn中的接口

Interface which allows to retrieve information about a Yarn cluster.

YarnConfigKeys - org.apache.flink.yarn中的类

The Yarn environment variables used for settings of the containers.

YarnConfigOptions - org.apache.flink.yarn.configuration中的类

This class holds configuration constants used by Flink's YARN runners.

YarnConfigOptions.UserJarInclusion - org.apache.flink.yarn.configuration中的枚举

YarnConfigOptionsInternal - org.apache.flink.yarn.configuration中的类

Yarn configuration options that are not meant to be set by the user.

YarnConfigOptionsInternal() - 类 的构造器org.apache.flink.yarn.configuration.YarnConfigOptionsInternal

YarnEntrypointUtils - org.apache.flink.yarn.entrypoint中的类

This class contains utility methods for the YarnSessionClusterEntrypoint and YarnJobClusterEntrypoint.

YarnEntrypointUtils() - 类 的构造器org.apache.flink.yarn.entrypoint.YarnEntrypointUtils

YarnJobClusterEntrypoint - org.apache.flink.yarn.entrypoint中的类

Entry point for Yarn per-job clusters.

YarnJobClusterEntrypoint(Configuration) - 类 的构造器org.apache.flink.yarn.entrypoint.YarnJobClusterEntrypoint

YarnJobClusterExecutor - org.apache.flink.yarn.executors中的类

The PipelineExecutor to be used when executing a job in isolation.

YarnJobClusterExecutor() - 类 的构造器org.apache.flink.yarn.executors.YarnJobClusterExecutor

YarnJobClusterExecutorFactory - org.apache.flink.yarn.executors中的类

An PipelineExecutorFactory for executing jobs on dedicated (per-job) clusters.

YarnJobClusterExecutorFactory() - 类 的构造器org.apache.flink.yarn.executors.YarnJobClusterExecutorFactory

YarnResourceManager - org.apache.flink.yarn中的类

The yarn implementation of the resource manager.

YarnResourceManager(RpcService, String, ResourceID, Configuration, Map<String, String>, HighAvailabilityServices, HeartbeatServices, SlotManager, JobLeaderIdService, ClusterInformation, FatalErrorHandler, String, ResourceManagerMetricGroup) - 类 的构造器org.apache.flink.yarn.YarnResourceManager

YarnResourceManagerFactory - org.apache.flink.yarn.entrypoint中的类

ResourceManagerFactory implementation which creates a YarnResourceManager.

YarnSessionClusterEntrypoint - org.apache.flink.yarn.entrypoint中的类

Entry point for Yarn session clusters.

YarnSessionClusterEntrypoint(Configuration) - 类 的构造器org.apache.flink.yarn.entrypoint.YarnSessionClusterEntrypoint

YarnSessionClusterExecutor - org.apache.flink.yarn.executors中的类

The PipelineExecutor to be used when executing a job on an already running cluster.

YarnSessionClusterExecutor() - 类 的构造器org.apache.flink.yarn.executors.YarnSessionClusterExecutor

YarnSessionClusterExecutorFactory - org.apache.flink.yarn.executors中的类

An PipelineExecutorFactory for executing jobs on an existing (session) cluster.

YarnSessionClusterExecutorFactory() - 类 的构造器org.apache.flink.yarn.executors.YarnSessionClusterExecutorFactory

YarnTaskExecutorRunner - org.apache.flink.yarn中的类

This class is the executable entry point for running a TaskExecutor in a YARN container.

YarnTaskExecutorRunner() - 类 的构造器org.apache.flink.yarn.YarnTaskExecutorRunner

YarnWorkerNode - org.apache.flink.yarn中的类

A stored YARN worker, which contains the YARN container.

YarnWorkerNode(Container) - 类 的构造器org.apache.flink.yarn.YarnWorkerNode

A C D E F G H I K L M N O P R S U V W Y