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

Java NodeHeartbeatResponseProtoOrBuilder类代码示例

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

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



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

示例1: getContainerTokenMasterKey

import org.apache.hadoop.yarn.proto.YarnServerCommonServiceProtos.NodeHeartbeatResponseProtoOrBuilder; //导入依赖的package包/类
@Override
public MasterKey getContainerTokenMasterKey() {
  NodeHeartbeatResponseProtoOrBuilder p = viaProto ? proto : builder;
  if (this.containerTokenMasterKey != null) {
    return this.containerTokenMasterKey;
  }
  if (!p.hasContainerTokenMasterKey()) {
    return null;
  }
  this.containerTokenMasterKey =
      convertFromProtoFormat(p.getContainerTokenMasterKey());
  return this.containerTokenMasterKey;
}
 
开发者ID:naver,项目名称:hadoop,代码行数:14,代码来源:NodeHeartbeatResponsePBImpl.java


示例2: getNMTokenMasterKey

import org.apache.hadoop.yarn.proto.YarnServerCommonServiceProtos.NodeHeartbeatResponseProtoOrBuilder; //导入依赖的package包/类
@Override
public MasterKey getNMTokenMasterKey() {
  NodeHeartbeatResponseProtoOrBuilder p = viaProto ? proto : builder;
  if (this.nmTokenMasterKey != null) {
    return this.nmTokenMasterKey;
  }
  if (!p.hasNmTokenMasterKey()) {
    return null;
  }
  this.nmTokenMasterKey =
      convertFromProtoFormat(p.getNmTokenMasterKey());
  return this.nmTokenMasterKey;
}
 
开发者ID:naver,项目名称:hadoop,代码行数:14,代码来源:NodeHeartbeatResponsePBImpl.java


示例3: getNodeAction

import org.apache.hadoop.yarn.proto.YarnServerCommonServiceProtos.NodeHeartbeatResponseProtoOrBuilder; //导入依赖的package包/类
@Override
public NodeAction getNodeAction() {
  NodeHeartbeatResponseProtoOrBuilder p = viaProto ? proto : builder;
  if (!p.hasNodeAction()) {
    return null;
  }
  return (convertFromProtoFormat(p.getNodeAction()));
}
 
开发者ID:naver,项目名称:hadoop,代码行数:9,代码来源:NodeHeartbeatResponsePBImpl.java


示例4: getDiagnosticsMessage

import org.apache.hadoop.yarn.proto.YarnServerCommonServiceProtos.NodeHeartbeatResponseProtoOrBuilder; //导入依赖的package包/类
@Override
public String getDiagnosticsMessage() {
  NodeHeartbeatResponseProtoOrBuilder p = viaProto ? proto : builder;
  if (!p.hasDiagnosticsMessage()) {
    return null;
  }
  return p.getDiagnosticsMessage();
}
 
开发者ID:naver,项目名称:hadoop,代码行数:9,代码来源:NodeHeartbeatResponsePBImpl.java


示例5: initContainersToCleanup

import org.apache.hadoop.yarn.proto.YarnServerCommonServiceProtos.NodeHeartbeatResponseProtoOrBuilder; //导入依赖的package包/类
private void initContainersToCleanup() {
  if (this.containersToCleanup != null) {
    return;
  }
  NodeHeartbeatResponseProtoOrBuilder p = viaProto ? proto : builder;
  List<ContainerIdProto> list = p.getContainersToCleanupList();
  this.containersToCleanup = new ArrayList<ContainerId>();

  for (ContainerIdProto c : list) {
    this.containersToCleanup.add(convertFromProtoFormat(c));
  }
}
 
开发者ID:naver,项目名称:hadoop,代码行数:13,代码来源:NodeHeartbeatResponsePBImpl.java


示例6: initContainersToBeRemovedFromNM

import org.apache.hadoop.yarn.proto.YarnServerCommonServiceProtos.NodeHeartbeatResponseProtoOrBuilder; //导入依赖的package包/类
private void initContainersToBeRemovedFromNM() {
  if (this.containersToBeRemovedFromNM != null) {
    return;
  }
  NodeHeartbeatResponseProtoOrBuilder p = viaProto ? proto : builder;
  List<ContainerIdProto> list = p.getContainersToBeRemovedFromNmList();
  this.containersToBeRemovedFromNM = new ArrayList<ContainerId>();

  for (ContainerIdProto c : list) {
    this.containersToBeRemovedFromNM.add(convertFromProtoFormat(c));
  }
}
 
开发者ID:naver,项目名称:hadoop,代码行数:13,代码来源:NodeHeartbeatResponsePBImpl.java


示例7: initApplicationsToCleanup

import org.apache.hadoop.yarn.proto.YarnServerCommonServiceProtos.NodeHeartbeatResponseProtoOrBuilder; //导入依赖的package包/类
private void initApplicationsToCleanup() {
  if (this.applicationsToCleanup != null) {
    return;
  }
  NodeHeartbeatResponseProtoOrBuilder p = viaProto ? proto : builder;
  List<ApplicationIdProto> list = p.getApplicationsToCleanupList();
  this.applicationsToCleanup = new ArrayList<ApplicationId>();

  for (ApplicationIdProto c : list) {
    this.applicationsToCleanup.add(convertFromProtoFormat(c));
  }
}
 
开发者ID:naver,项目名称:hadoop,代码行数:13,代码来源:NodeHeartbeatResponsePBImpl.java


示例8: initSystemCredentials

import org.apache.hadoop.yarn.proto.YarnServerCommonServiceProtos.NodeHeartbeatResponseProtoOrBuilder; //导入依赖的package包/类
private void initSystemCredentials() {
  NodeHeartbeatResponseProtoOrBuilder p = viaProto ? proto : builder;
  List<SystemCredentialsForAppsProto> list = p.getSystemCredentialsForAppsList();
  this.systemCredentials = new HashMap<ApplicationId, ByteBuffer> ();
  for (SystemCredentialsForAppsProto c : list) {
    ApplicationId appId = convertFromProtoFormat(c.getAppId());
    ByteBuffer byteBuffer = ProtoUtils.convertFromProtoFormat(c.getCredentialsForApp());
    this.systemCredentials.put(appId, byteBuffer);
  }
}
 
开发者ID:naver,项目名称:hadoop,代码行数:11,代码来源:NodeHeartbeatResponsePBImpl.java


示例9: initContainersToDecrease

import org.apache.hadoop.yarn.proto.YarnServerCommonServiceProtos.NodeHeartbeatResponseProtoOrBuilder; //导入依赖的package包/类
private void initContainersToDecrease() {
  if (this.containersToDecrease != null) {
    return;
  }
  NodeHeartbeatResponseProtoOrBuilder p = viaProto ? proto : builder;
  List<ContainerProto> list = p.getContainersToDecreaseList();
  this.containersToDecrease = new ArrayList<>();

  for (ContainerProto c : list) {
    this.containersToDecrease.add(convertFromProtoFormat(c));
  }
}
 
开发者ID:aliyun-beta,项目名称:aliyun-oss-hadoop-fs,代码行数:13,代码来源:NodeHeartbeatResponsePBImpl.java


示例10: initContainersToSignal

import org.apache.hadoop.yarn.proto.YarnServerCommonServiceProtos.NodeHeartbeatResponseProtoOrBuilder; //导入依赖的package包/类
private void initContainersToSignal() {
  if (this.containersToSignal != null) {
    return;
  }
  NodeHeartbeatResponseProtoOrBuilder p = viaProto ? proto : builder;
  List<SignalContainerRequestProto> list = p.getContainersToSignalList();
  this.containersToSignal = new ArrayList<SignalContainerRequest>();

  for (SignalContainerRequestProto c : list) {
    this.containersToSignal.add(convertFromProtoFormat(c));
  }
}
 
开发者ID:aliyun-beta,项目名称:aliyun-oss-hadoop-fs,代码行数:13,代码来源:NodeHeartbeatResponsePBImpl.java


示例11: initContainersToUpdate

import org.apache.hadoop.yarn.proto.YarnServerCommonServiceProtos.NodeHeartbeatResponseProtoOrBuilder; //导入依赖的package包/类
private void initContainersToUpdate(){
 if(this.containersToUpdate != null) {
  return;
 }
 NodeHeartbeatResponseProtoOrBuilder p = viaProto ? proto : builder;
 List<NodeContainerUpdateProto> list = p.getContainersToUpdateList();
 this.containersToUpdate = new ArrayList<NodeContainerUpdate>();
 
 for(NodeContainerUpdateProto c : list){
  this.containersToUpdate.add(convertFromProtoFormat(c));
 }
}
 
开发者ID:yncxcw,项目名称:big-c,代码行数:13,代码来源:NodeHeartbeatResponsePBImpl.java



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


鲜花

握手

雷人

路过

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

请发表评论

全部评论

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

扫描微信二维码

查看手机版网站

随时了解更新最新资讯

139-2527-9053

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

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

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