Java INodeReferenceSection类代码示例

OStack程序员社区-中国程序员成长平台 › 门户 › 编程› Java›Java编程经验

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

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

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

示例1: loadINodeReference

import org.apache.hadoop.hdfs.server.namenode.FsImageProto.INodeReferenceSection; //导入依赖的package包/类
private INodeReference loadINodeReference(
    INodeReferenceSection.INodeReference r) throws IOException {
  long referredId = r.getReferredId();
  INode referred = fsDir.getInode(referredId);
  WithCount withCount = (WithCount) referred.getParentReference();
  if (withCount == null) {
    withCount = new INodeReference.WithCount(null, referred);
  }
  final INodeReference ref;
  if (r.hasDstSnapshotId()) { // DstReference
    ref = new INodeReference.DstReference(null, withCount,
        r.getDstSnapshotId());
  } else {
    ref = new INodeReference.WithName(null, withCount, r.getName()
        .toByteArray(), r.getLastSnapshotId());
  }
  return ref;
}

开发者ID:naver，项目名称:hadoop，代码行数:19，代码来源:FSImageFormatPBSnapshot.java

示例2: loadINodeReferenceSection

import org.apache.hadoop.hdfs.server.namenode.FsImageProto.INodeReferenceSection; //导入依赖的package包/类
private void loadINodeReferenceSection(InputStream in) throws IOException {
  if (LOG.isDebugEnabled()) {
    LOG.debug("Loading inode reference section");
  }
  while (true) {
    INodeReferenceSection.INodeReference e = INodeReferenceSection
        .INodeReference.parseDelimitedFrom(in);
    if (e == null) {
      break;
    }
    refList.add(e);
    if (LOG.isTraceEnabled()) {
      LOG.trace("Loaded inode reference named '" + e.getName()
          + "' referring to id " + e.getReferredId() + "");
    }
  }
  if (LOG.isDebugEnabled()) {
    LOG.debug("Loaded " + refList.size() + " inode references");
  }
}

开发者ID:Seagate，项目名称:hadoop-on-lustre2，代码行数:21，代码来源:LsrPBImage.java

示例3: loadINodeReferenceSection

import org.apache.hadoop.hdfs.server.namenode.FsImageProto.INodeReferenceSection; //导入依赖的package包/类
/**
 * The sequence of the ref node in refList must be strictly the same with
 * the sequence in fsimage
 */
public void loadINodeReferenceSection(InputStream in) throws IOException {
  final List<INodeReference> refList = parent.getLoaderContext()
      .getRefList();
  while (true) {
    INodeReferenceSection.INodeReference e = INodeReferenceSection
        .INodeReference.parseDelimitedFrom(in);
    if (e == null) {
      break;
    }
    INodeReference ref = loadINodeReference(e);
    refList.add(ref);
  }
}

开发者ID:naver，项目名称:hadoop，代码行数:18，代码来源:FSImageFormatPBSnapshot.java

示例4: serializeINodeReferenceSection

import org.apache.hadoop.hdfs.server.namenode.FsImageProto.INodeReferenceSection; //导入依赖的package包/类
/**
 * This can only be called after serializing both INode_Dir and SnapshotDiff
 */
public void serializeINodeReferenceSection(OutputStream out)
    throws IOException {
  final List<INodeReference> refList = parent.getSaverContext()
      .getRefList();
  for (INodeReference ref : refList) {
    INodeReferenceSection.INodeReference.Builder rb = buildINodeReference(ref);
    rb.build().writeDelimitedTo(out);
  }
  parent.commitSection(headers, SectionName.INODE_REFERENCE);
}

开发者ID:naver，项目名称:hadoop，代码行数:14，代码来源:FSImageFormatPBSnapshot.java

示例5: buildINodeReference

import org.apache.hadoop.hdfs.server.namenode.FsImageProto.INodeReferenceSection; //导入依赖的package包/类
private INodeReferenceSection.INodeReference.Builder buildINodeReference(
    INodeReference ref) throws IOException {
  INodeReferenceSection.INodeReference.Builder rb =
      INodeReferenceSection.INodeReference.newBuilder().
        setReferredId(ref.getId());
  if (ref instanceof WithName) {
    rb.setLastSnapshotId(((WithName) ref).getLastSnapshotId()).setName(
        ByteString.copyFrom(ref.getLocalNameBytes()));
  } else if (ref instanceof DstReference) {
    rb.setDstSnapshotId(ref.getDstSnapshotId());
  }
  return rb;
}

开发者ID:naver，项目名称:hadoop，代码行数:14，代码来源:FSImageFormatPBSnapshot.java

示例6: dumpINodeReferenceSection

import org.apache.hadoop.hdfs.server.namenode.FsImageProto.INodeReferenceSection; //导入依赖的package包/类
private void dumpINodeReferenceSection(InputStream in) throws IOException {
  out.print("<INodeReferenceSection>");
  while (true) {
    INodeReferenceSection.INodeReference e = INodeReferenceSection
        .INodeReference.parseDelimitedFrom(in);
    if (e == null) {
      break;
    }
    dumpINodeReference(e);
  }
  out.print("</INodeReferenceSection>");
}

开发者ID:naver，项目名称:hadoop，代码行数:13，代码来源:PBImageXmlWriter.java

示例7: dumpINodeReference

import org.apache.hadoop.hdfs.server.namenode.FsImageProto.INodeReferenceSection; //导入依赖的package包/类
private void dumpINodeReference(INodeReferenceSection.INodeReference r) {
  out.print("<ref>");
  o("referredId", r.getReferredId()).o("name", r.getName().toStringUtf8())
      .o("dstSnapshotId", r.getDstSnapshotId())
      .o("lastSnapshotId", r.getLastSnapshotId());
  out.print("</ref>\n");
}

开发者ID:naver，项目名称:hadoop，代码行数:8，代码来源:PBImageXmlWriter.java

示例8: buildINodeReference

import org.apache.hadoop.hdfs.server.namenode.FsImageProto.INodeReferenceSection; //导入依赖的package包/类
private INodeReferenceSection.INodeReference.Builder buildINodeReference(
    INodeReference ref) throws IOException {
  INodeReferenceSection.INodeReference.Builder rb =
      INodeReferenceSection.INodeReference.newBuilder().
        setReferredId(ref.getId());
  if (ref instanceof WithName) {
    rb.setLastSnapshotId(((WithName) ref).getLastSnapshotId()).setName(
        ByteString.copyFrom(ref.getLocalNameBytes()));
  } else if (ref instanceof DstReference) {
    rb.setDstSnapshotId(((DstReference) ref).getDstSnapshotId());
  }
  return rb;
}

开发者ID:Seagate，项目名称:hadoop-on-lustre2，代码行数:14，代码来源:FSImageFormatPBSnapshot.java

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