Java 类org.apache.hadoop.hdfs.server.namenode.FsImageProto.SnapshotDiffSection.CreatedListEntry 实例源码

项目:hadoop    文件:FSImageFormatPBSnapshot.java   
/** Load the created list in a DirectoryDiff */
private List<INode> loadCreatedList(InputStream in, INodeDirectory dir,
    int size) throws IOException {
  List<INode> clist = new ArrayList<INode>(size);
  for (long c = 0; c < size; c++) {
    CreatedListEntry entry = CreatedListEntry.parseDelimitedFrom(in);
    INode created = SnapshotFSImageFormat.loadCreated(entry.getName()
        .toByteArray(), dir);
    clist.add(created);
  }
  return clist;
}
项目:hadoop    文件:FSImageFormatPBSnapshot.java   
private void saveCreatedList(List<INode> created, OutputStream out)
    throws IOException {
  // local names of the created list member
  for (INode c : created) {
    SnapshotDiffSection.CreatedListEntry.newBuilder()
        .setName(ByteString.copyFrom(c.getLocalNameBytes())).build()
        .writeDelimitedTo(out);
  }
}
项目:aliyun-oss-hadoop-fs    文件:FSImageFormatPBSnapshot.java   
/** Load the created list in a DirectoryDiff */
private List<INode> loadCreatedList(InputStream in, INodeDirectory dir,
    int size) throws IOException {
  List<INode> clist = new ArrayList<INode>(size);
  for (long c = 0; c < size; c++) {
    CreatedListEntry entry = CreatedListEntry.parseDelimitedFrom(in);
    INode created = SnapshotFSImageFormat.loadCreated(entry.getName()
        .toByteArray(), dir);
    clist.add(created);
  }
  return clist;
}
项目:aliyun-oss-hadoop-fs    文件:FSImageFormatPBSnapshot.java   
private void saveCreatedList(List<INode> created, OutputStream out)
    throws IOException {
  // local names of the created list member
  for (INode c : created) {
    SnapshotDiffSection.CreatedListEntry.newBuilder()
        .setName(ByteString.copyFrom(c.getLocalNameBytes())).build()
        .writeDelimitedTo(out);
  }
}
项目:big-c    文件:FSImageFormatPBSnapshot.java   
/** Load the created list in a DirectoryDiff */
private List<INode> loadCreatedList(InputStream in, INodeDirectory dir,
    int size) throws IOException {
  List<INode> clist = new ArrayList<INode>(size);
  for (long c = 0; c < size; c++) {
    CreatedListEntry entry = CreatedListEntry.parseDelimitedFrom(in);
    INode created = SnapshotFSImageFormat.loadCreated(entry.getName()
        .toByteArray(), dir);
    clist.add(created);
  }
  return clist;
}
项目:big-c    文件:FSImageFormatPBSnapshot.java   
private void saveCreatedList(List<INode> created, OutputStream out)
    throws IOException {
  // local names of the created list member
  for (INode c : created) {
    SnapshotDiffSection.CreatedListEntry.newBuilder()
        .setName(ByteString.copyFrom(c.getLocalNameBytes())).build()
        .writeDelimitedTo(out);
  }
}
项目:hadoop-2.6.0-cdh5.4.3    文件:FSImageFormatPBSnapshot.java   
/** Load the created list in a DirectoryDiff */
private List<INode> loadCreatedList(InputStream in, INodeDirectory dir,
    int size) throws IOException {
  List<INode> clist = new ArrayList<INode>(size);
  for (long c = 0; c < size; c++) {
    CreatedListEntry entry = CreatedListEntry.parseDelimitedFrom(in);
    INode created = SnapshotFSImageFormat.loadCreated(entry.getName()
        .toByteArray(), dir);
    clist.add(created);
  }
  return clist;
}
项目:hadoop-2.6.0-cdh5.4.3    文件:FSImageFormatPBSnapshot.java   
private void saveCreatedList(List<INode> created, OutputStream out)
    throws IOException {
  // local names of the created list member
  for (INode c : created) {
    SnapshotDiffSection.CreatedListEntry.newBuilder()
        .setName(ByteString.copyFrom(c.getLocalNameBytes())).build()
        .writeDelimitedTo(out);
  }
}
项目:FlexMap    文件:FSImageFormatPBSnapshot.java   
/** Load the created list in a DirectoryDiff */
private List<INode> loadCreatedList(InputStream in, INodeDirectory dir,
    int size) throws IOException {
  List<INode> clist = new ArrayList<INode>(size);
  for (long c = 0; c < size; c++) {
    CreatedListEntry entry = CreatedListEntry.parseDelimitedFrom(in);
    INode created = SnapshotFSImageFormat.loadCreated(entry.getName()
        .toByteArray(), dir);
    clist.add(created);
  }
  return clist;
}
项目:FlexMap    文件:FSImageFormatPBSnapshot.java   
private void saveCreatedList(List<INode> created, OutputStream out)
    throws IOException {
  // local names of the created list member
  for (INode c : created) {
    SnapshotDiffSection.CreatedListEntry.newBuilder()
        .setName(ByteString.copyFrom(c.getLocalNameBytes())).build()
        .writeDelimitedTo(out);
  }
}
项目:hadoop-on-lustre2    文件:FSImageFormatPBSnapshot.java   
/** Load the created list in a DirectoryDiff */
private List<INode> loadCreatedList(InputStream in, INodeDirectory dir,
    int size) throws IOException {
  List<INode> clist = new ArrayList<INode>(size);
  for (long c = 0; c < size; c++) {
    CreatedListEntry entry = CreatedListEntry.parseDelimitedFrom(in);
    INode created = SnapshotFSImageFormat.loadCreated(entry.getName()
        .toByteArray(), dir);
    clist.add(created);
  }
  return clist;
}
项目:hadoop-on-lustre2    文件:FSImageFormatPBSnapshot.java   
private void saveCreatedList(List<INode> created, OutputStream out)
    throws IOException {
  // local names of the created list member
  for (INode c : created) {
    SnapshotDiffSection.CreatedListEntry.newBuilder()
        .setName(ByteString.copyFrom(c.getLocalNameBytes())).build()
        .writeDelimitedTo(out);
  }
}