• 设为首页
  • 点击收藏
  • 手机版
    手机扫一扫访问
    迪恩网络手机版
  • 关注官方公众号
    微信扫一扫关注
    公众号

Java GetClusterMetricsRequest类代码示例

原作者: [db:作者] 来自: [db:来源] 收藏 邀请

本文整理汇总了Java中org.apache.hadoop.yarn.api.protocolrecords.GetClusterMetricsRequest的典型用法代码示例。如果您正苦于以下问题:Java GetClusterMetricsRequest类的具体用法?Java GetClusterMetricsRequest怎么用?Java GetClusterMetricsRequest使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。



GetClusterMetricsRequest类属于org.apache.hadoop.yarn.api.protocolrecords包,在下文中一共展示了GetClusterMetricsRequest类的9个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Java代码示例。

示例1: waitForNodeManagersToConnect

import org.apache.hadoop.yarn.api.protocolrecords.GetClusterMetricsRequest; //导入依赖的package包/类
/**
 * Wait for all the NodeManagers to connect to the ResourceManager.
 *
 * @param timeout Time to wait (sleeps in 100 ms intervals) in milliseconds.
 * @return true if all NodeManagers connect to the (Active)
 * ResourceManager, false otherwise.
 * @throws YarnException
 * @throws InterruptedException
 */
public boolean waitForNodeManagersToConnect(long timeout)
    throws YarnException, InterruptedException {
  GetClusterMetricsRequest req = GetClusterMetricsRequest.newInstance();
  for (int i = 0; i < timeout / 100; i++) {
    ResourceManager rm = getResourceManager();
    if (rm == null) {
      throw new YarnException("Can not find the active RM.");
    }
    else if (nodeManagers.length == rm.getClientRMService()
          .getClusterMetrics(req).getClusterMetrics().getNumNodeManagers()) {
      return true;
    }
    Thread.sleep(100);
  }
  return false;
}
 
开发者ID:naver,项目名称:hadoop,代码行数:26,代码来源:MiniYARNCluster.java


示例2: getClusterMetrics

import org.apache.hadoop.yarn.api.protocolrecords.GetClusterMetricsRequest; //导入依赖的package包/类
@Override
public GetClusterMetricsResponse getClusterMetrics(
    GetClusterMetricsRequest request) throws YarnException {
  GetClusterMetricsResponse response = recordFactory
      .newRecordInstance(GetClusterMetricsResponse.class);
  YarnClusterMetrics ymetrics = recordFactory
      .newRecordInstance(YarnClusterMetrics.class);
  ymetrics.setNumNodeManagers(this.rmContext.getRMNodes().size());
  ClusterMetrics clusterMetrics = ClusterMetrics.getMetrics();
  ymetrics.setNumDecommissionedNodeManagers(clusterMetrics
    .getNumDecommisionedNMs());
  ymetrics.setNumActiveNodeManagers(clusterMetrics.getNumActiveNMs());
  ymetrics.setNumLostNodeManagers(clusterMetrics.getNumLostNMs());
  ymetrics.setNumUnhealthyNodeManagers(clusterMetrics.getUnhealthyNMs());
  ymetrics.setNumRebootedNodeManagers(clusterMetrics.getNumRebootedNMs());
  response.setClusterMetrics(ymetrics);
  return response;
}
 
开发者ID:aliyun-beta,项目名称:aliyun-oss-hadoop-fs,代码行数:19,代码来源:ClientRMService.java


示例3: waitForNodeManagersToConnect

import org.apache.hadoop.yarn.api.protocolrecords.GetClusterMetricsRequest; //导入依赖的package包/类
/**
 * Wait for all the NodeManagers to connect to the ResourceManager.
 *
 * @param timeout Time to wait (sleeps in 10 ms intervals) in milliseconds.
 * @return true if all NodeManagers connect to the (Active)
 * ResourceManager, false otherwise.
 * @throws YarnException if there is no active RM
 * @throws InterruptedException if any thread has interrupted
 * the current thread
 */
public boolean waitForNodeManagersToConnect(long timeout)
    throws YarnException, InterruptedException {
  GetClusterMetricsRequest req = GetClusterMetricsRequest.newInstance();
  for (int i = 0; i < timeout / 10; i++) {
    ResourceManager rm = getResourceManager();
    if (rm == null) {
      throw new YarnException("Can not find the active RM.");
    }
    else if (nodeManagers.length == rm.getClientRMService()
        .getClusterMetrics(req).getClusterMetrics().getNumNodeManagers()) {
      LOG.info("All Node Managers connected in MiniYARNCluster");
      return true;
    }
    Thread.sleep(10);
  }
  LOG.info("Node Managers did not connect within 5000ms");
  return false;
}
 
开发者ID:hopshadoop,项目名称:hops,代码行数:29,代码来源:MiniYARNCluster.java


示例4: waitForNodeManagersToConnect

import org.apache.hadoop.yarn.api.protocolrecords.GetClusterMetricsRequest; //导入依赖的package包/类
/**
 * Wait for all the NodeManagers to connect to the ResourceManager.
 *
 * @param timeout Time to wait (sleeps in 100 ms intervals) in milliseconds.
 * @return true if all NodeManagers connect to the (Active)
 * ResourceManager, false otherwise.
 * @throws YarnException
 * @throws InterruptedException
 */
public boolean waitForNodeManagersToConnect(long timeout)
    throws YarnException, InterruptedException {
    GetClusterMetricsRequest req = GetClusterMetricsRequest.newInstance();
    for (int i = 0; i < timeout / 100; i++) {
        ResourceManager rm = getResourceManager();
        if (rm == null) {
            throw new YarnException("Can not find the active RM.");
        }
        else if (nodeManagers.length == rm.getClientRMService()
                                          .getClusterMetrics(req).getClusterMetrics().getNumNodeManagers()) {
            return true;
        }
        Thread.sleep(100);
    }
    return false;
}
 
开发者ID:splicemachine,项目名称:spliceengine,代码行数:26,代码来源:MiniYARNClusterSplice.java


示例5: getClusterMetrics

import org.apache.hadoop.yarn.api.protocolrecords.GetClusterMetricsRequest; //导入依赖的package包/类
@Override
public GetClusterMetricsResponse getClusterMetrics(
    GetClusterMetricsRequest request) throws YarnException,
    IOException {
  GetClusterMetricsRequestProto requestProto =
      ((GetClusterMetricsRequestPBImpl) request).getProto();
  try {
    return new GetClusterMetricsResponsePBImpl(proxy.getClusterMetrics(null,
      requestProto));
  } catch (ServiceException e) {
    RPCUtil.unwrapAndThrowException(e);
    return null;
  }
}
 
开发者ID:naver,项目名称:hadoop,代码行数:15,代码来源:ApplicationClientProtocolPBClientImpl.java


示例6: getClusterMetrics

import org.apache.hadoop.yarn.api.protocolrecords.GetClusterMetricsRequest; //导入依赖的package包/类
@Override
public GetClusterMetricsResponse getClusterMetrics(
    GetClusterMetricsRequest request) throws YarnException {
  GetClusterMetricsResponse response = recordFactory
      .newRecordInstance(GetClusterMetricsResponse.class);
  YarnClusterMetrics ymetrics = recordFactory
      .newRecordInstance(YarnClusterMetrics.class);
  ymetrics.setNumNodeManagers(this.rmContext.getRMNodes().size());
  response.setClusterMetrics(ymetrics);
  return response;
}
 
开发者ID:naver,项目名称:hadoop,代码行数:12,代码来源:ClientRMService.java


示例7: getYarnClusterMetrics

import org.apache.hadoop.yarn.api.protocolrecords.GetClusterMetricsRequest; //导入依赖的package包/类
@Override
public YarnClusterMetrics getYarnClusterMetrics() throws YarnException,
    IOException {
  GetClusterMetricsRequest request =
      Records.newRecord(GetClusterMetricsRequest.class);
  GetClusterMetricsResponse response = rmClient.getClusterMetrics(request);
  return response.getClusterMetrics();
}
 
开发者ID:naver,项目名称:hadoop,代码行数:9,代码来源:YarnClientImpl.java


示例8: getClusterMetrics

import org.apache.hadoop.yarn.api.protocolrecords.GetClusterMetricsRequest; //导入依赖的package包/类
@Override
public GetClusterMetricsResponse getClusterMetrics(
    GetClusterMetricsRequest request) throws YarnException {
  resetStartFailoverFlag(true);

  // make sure failover has been triggered
  Assert.assertTrue(waittingForFailOver());

  // create GetClusterMetricsResponse with fake YarnClusterMetrics
  GetClusterMetricsResponse response =
      GetClusterMetricsResponse.newInstance(
          createFakeYarnClusterMetrics());
  return response;
}
 
开发者ID:naver,项目名称:hadoop,代码行数:15,代码来源:ProtocolHATestBase.java


示例9: waitForNodeManagersToConnect

import org.apache.hadoop.yarn.api.protocolrecords.GetClusterMetricsRequest; //导入依赖的package包/类
/**
 * Wait for all the NodeManagers to connect to the ResourceManager.
 *
 * @param timeout Time to wait (sleeps in 100 ms intervals) in milliseconds.
 * @return true if all NodeManagers connect to the (Active)
 * ResourceManager, false otherwise.
 * @throws YarnException
 * @throws InterruptedException
 */
public boolean waitForNodeManagersToConnect(long timeout)
    throws YarnException, InterruptedException {
  ResourceManager rm = getResourceManager();
  GetClusterMetricsRequest req = GetClusterMetricsRequest.newInstance();

  for (int i = 0; i < timeout / 100; i++) {
    if (nodeManagers.length == rm.getClientRMService().getClusterMetrics(req)
        .getClusterMetrics().getNumNodeManagers()) {
      return true;
    }
    Thread.sleep(100);
  }
  return false;
}
 
开发者ID:Seagate,项目名称:hadoop-on-lustre2,代码行数:24,代码来源:MiniYARNCluster.java



注:本文中的org.apache.hadoop.yarn.api.protocolrecords.GetClusterMetricsRequest类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。


鲜花

握手

雷人

路过

鸡蛋
该文章已有0人参与评论

请发表评论

全部评论

专题导读
上一篇:
Java HttpHandler类代码示例发布时间:2022-05-21
下一篇:
Java Resources类代码示例发布时间:2022-05-21
热门推荐
阅读排行榜

扫描微信二维码

查看手机版网站

随时了解更新最新资讯

139-2527-9053

在线客服(服务时间 9:00~18:00)

在线QQ客服
地址:深圳市南山区西丽大学城创智工业园
电邮:jeky_zhao#qq.com
移动电话:139-2527-9053

Powered by 互联科技 X3.4© 2001-2213 极客世界.|Sitemap