Package org.apache.flink.yarn
Class YarnClientYarnClusterInformationRetriever
- java.lang.Object
-
- org.apache.flink.yarn.YarnClientYarnClusterInformationRetriever
-
- All Implemented Interfaces:
YarnClusterInformationRetriever
public final class YarnClientYarnClusterInformationRetriever extends Object implements YarnClusterInformationRetriever
YarnClusterInformationRetrieverimplementation which queries the Yarn cluster using aYarnClientinstance.
-
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description static YarnClientYarnClusterInformationRetrievercreate(org.apache.hadoop.yarn.client.api.YarnClient yarnClient)intgetMaxVcores()Get the maximum number of vcores supported by the Yarn cluster.
-
-
-
Method Detail
-
getMaxVcores
public int getMaxVcores() throws org.apache.flink.util.FlinkExceptionDescription copied from interface:YarnClusterInformationRetrieverGet the maximum number of vcores supported by the Yarn cluster.- Specified by:
getMaxVcoresin interfaceYarnClusterInformationRetriever- Returns:
- max vcores supported by the cluster
- Throws:
org.apache.flink.util.FlinkException
-
create
public static YarnClientYarnClusterInformationRetriever create(org.apache.hadoop.yarn.client.api.YarnClient yarnClient)
-
-