org.apache.flink.yarn

类 YarnClientYarnClusterInformationRetriever

java.lang.Object

org.apache.flink.yarn.YarnClientYarnClusterInformationRetriever

所有已实现的接口:

YarnClusterInformationRetriever

public final class YarnClientYarnClusterInformationRetriever
extends Object
implements YarnClusterInformationRetriever

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

方法概要

限定符和类型	方法和说明
static YarnClientYarnClusterInformationRetriever	create(org.apache.hadoop.yarn.client.api.YarnClient yarnClient)
int	getMaxVcores() Get the maximum number of vcores supported by the Yarn cluster.

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

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

方法详细资料

getMaxVcores

public int getMaxVcores()
                 throws org.apache.flink.util.FlinkException

从接口复制的说明: YarnClusterInformationRetriever

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

指定者:

getMaxVcores 在接口中 YarnClusterInformationRetriever

返回:

max vcores supported by the cluster

抛出:

org.apache.flink.util.FlinkException

create

public static YarnClientYarnClusterInformationRetriever create(org.apache.hadoop.yarn.client.api.YarnClient yarnClient)