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

Java LocalResourceStatus类代码示例

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

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



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

示例1: matches

import org.apache.hadoop.yarn.server.nodemanager.api.protocolrecords.LocalResourceStatus; //导入依赖的package包/类
@Override
public boolean matches(Object o) {
  LocalizerStatus status = (LocalizerStatus) o;
  for (LocalResourceStatus localized : status.getResources()) {
    switch (localized.getStatus()) {
    case FETCH_SUCCESS:
      if (localized.getLocalPath().getFile().contains(
            rsrc.getResource().getFile())) {
        return true;
      }
      break;
    default:
      fail("Unexpected: " + localized.getStatus());
      break;
    }
  }
  return false;
}
 
开发者ID:naver,项目名称:hadoop,代码行数:19,代码来源:TestContainerLocalizer.java


示例2: createLocalResourceStatus

import org.apache.hadoop.yarn.server.nodemanager.api.protocolrecords.LocalResourceStatus; //导入依赖的package包/类
static LocalResourceStatus createLocalResourceStatus() {
  LocalResourceStatus ret =
    recordFactory.newRecordInstance(LocalResourceStatus.class);
  assertTrue(ret instanceof LocalResourceStatusPBImpl);
  ret.setResource(createResource());
  ret.setLocalPath(
      ConverterUtils.getYarnUrlFromPath(
        new Path("file:///local/foo/bar")));
  ret.setStatus(ResourceStatusType.FETCH_SUCCESS);
  ret.setLocalSize(4443L);
  Exception e = new Exception("Dingos.");
  e.setStackTrace(new StackTraceElement[] {
      new StackTraceElement("foo", "bar", "baz", 10),
      new StackTraceElement("sbb", "one", "onm", 10) });
  ret.setException(SerializedException.newInstance(e));
  return ret;
}
 
开发者ID:naver,项目名称:hadoop,代码行数:18,代码来源:TestPBRecordImpl.java


示例3: testLocalResourceStatusSerDe

import org.apache.hadoop.yarn.server.nodemanager.api.protocolrecords.LocalResourceStatus; //导入依赖的package包/类
@Test(timeout=10000)
public void testLocalResourceStatusSerDe() throws Exception {
  LocalResourceStatus rsrcS = createLocalResourceStatus();
  assertTrue(rsrcS instanceof LocalResourceStatusPBImpl);
  LocalResourceStatusPBImpl rsrcPb = (LocalResourceStatusPBImpl) rsrcS;
  DataOutputBuffer out = new DataOutputBuffer();
  rsrcPb.getProto().writeDelimitedTo(out);
  DataInputBuffer in = new DataInputBuffer();
  in.reset(out.getData(), 0, out.getLength());
  LocalResourceStatusProto rsrcPbD =
    LocalResourceStatusProto.parseDelimitedFrom(in);
  assertNotNull(rsrcPbD);
  LocalResourceStatus rsrcD =
    new LocalResourceStatusPBImpl(rsrcPbD);

  assertEquals(rsrcS, rsrcD);
  assertEquals(createResource(), rsrcS.getResource());
  assertEquals(createResource(), rsrcD.getResource());
}
 
开发者ID:naver,项目名称:hadoop,代码行数:20,代码来源:TestPBRecordImpl.java


示例4: createLocalResourceStatus

import org.apache.hadoop.yarn.server.nodemanager.api.protocolrecords.LocalResourceStatus; //导入依赖的package包/类
static LocalResourceStatus createLocalResourceStatus() {
  LocalResourceStatus ret =
    recordFactory.newRecordInstance(LocalResourceStatus.class);
  assertTrue(ret instanceof LocalResourceStatusPBImpl);
  ret.setResource(createResource());
  ret.setLocalPath(
      URL.fromPath(
        new Path("file:///local/foo/bar")));
  ret.setStatus(ResourceStatusType.FETCH_SUCCESS);
  ret.setLocalSize(4443L);
  Exception e = new Exception("Dingos.");
  e.setStackTrace(new StackTraceElement[] {
      new StackTraceElement("foo", "bar", "baz", 10),
      new StackTraceElement("sbb", "one", "onm", 10) });
  ret.setException(SerializedException.newInstance(e));
  return ret;
}
 
开发者ID:hopshadoop,项目名称:hops,代码行数:18,代码来源:TestPBRecordImpl.java


示例5: initResources

import org.apache.hadoop.yarn.server.nodemanager.api.protocolrecords.LocalResourceStatus; //导入依赖的package包/类
private void initResources() {
  if (this.resources != null) {
    return;
  }
  LocalizerStatusProtoOrBuilder p = viaProto ? proto : builder;
  List<LocalResourceStatusProto> list = p.getResourcesList();
  this.resources = new ArrayList<LocalResourceStatus>();

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


示例6: addResourcesToProto

import org.apache.hadoop.yarn.server.nodemanager.api.protocolrecords.LocalResourceStatus; //导入依赖的package包/类
private void addResourcesToProto() {
  maybeInitBuilder();
  builder.clearResources();
  if (this.resources == null) 
    return;
  Iterable<LocalResourceStatusProto> iterable =
      new Iterable<LocalResourceStatusProto>() {
    @Override
    public Iterator<LocalResourceStatusProto> iterator() {
      return new Iterator<LocalResourceStatusProto>() {

        Iterator<LocalResourceStatus> iter = resources.iterator();

        @Override
        public boolean hasNext() {
          return iter.hasNext();
        }

        @Override
        public LocalResourceStatusProto next() {
          return convertToProtoFormat(iter.next());
        }

        @Override
        public void remove() {
          throw new UnsupportedOperationException();

        }
      };

    }
  };
  builder.addAllResources(iterable);
}
 
开发者ID:naver,项目名称:hadoop,代码行数:35,代码来源:LocalizerStatusPBImpl.java


示例7: addAllResources

import org.apache.hadoop.yarn.server.nodemanager.api.protocolrecords.LocalResourceStatus; //导入依赖的package包/类
@Override
public void addAllResources(List<LocalResourceStatus> resources) {
  if (resources == null)
    return;
  initResources();
  this.resources.addAll(resources);
}
 
开发者ID:naver,项目名称:hadoop,代码行数:8,代码来源:LocalizerStatusPBImpl.java


示例8: createLocalizerStatusForFailedResource

import org.apache.hadoop.yarn.server.nodemanager.api.protocolrecords.LocalResourceStatus; //导入依赖的package包/类
private LocalizerStatus createLocalizerStatusForFailedResource(
    String localizerId, LocalResourceRequest req) {
  LocalizerStatus status = createLocalizerStatus(localizerId);
  LocalResourceStatus resourceStatus = new LocalResourceStatusPBImpl();
  resourceStatus.setException(SerializedException
    .newInstance(new YarnException("test")));
  resourceStatus.setStatus(ResourceStatusType.FETCH_FAILURE);
  resourceStatus.setResource(req);
  status.addResourceStatus(resourceStatus);
  return status;
}
 
开发者ID:naver,项目名称:hadoop,代码行数:12,代码来源:TestResourceLocalizationService.java



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


鲜花

握手

雷人

路过

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

请发表评论

全部评论

专题导读
上一篇:
Java SecurityUtil类代码示例发布时间:2022-05-22
下一篇:
Java ValidityReport类代码示例发布时间: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