org.apache.flink.yarn.executors

类 YarnJobClusterExecutor

java.lang.Object

org.apache.flink.client.deployment.executors.AbstractJobClusterExecutor<org.apache.hadoop.yarn.api.records.ApplicationId,YarnClusterClientFactory>

org.apache.flink.yarn.executors.YarnJobClusterExecutor

所有已实现的接口:

org.apache.flink.core.execution.PipelineExecutor

@Internal
public class YarnJobClusterExecutor
extends org.apache.flink.client.deployment.executors.AbstractJobClusterExecutor<org.apache.hadoop.yarn.api.records.ApplicationId,YarnClusterClientFactory>

The PipelineExecutor to be used when executing a job in isolation. This executor will start a cluster specifically for the job at hand and tear it down when the job is finished either successfully or due to an error.

字段概要

字段

限定符和类型	字段和说明
static String	NAME

构造器概要

构造器

构造器和说明
YarnJobClusterExecutor()

方法概要

从类继承的方法 org.apache.flink.client.deployment.executors.AbstractJobClusterExecutor

execute

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

字段详细资料

NAME

public static final String NAME

另请参阅:

常量字段值

构造器详细资料

YarnJobClusterExecutor

public YarnJobClusterExecutor()