1. 包列表
  2. 类列表
  3. org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.LocatedBlocksProto

Java 类org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.LocatedBlocksProto 实例源码

项目：hadoop    文件：PBHelper.java    
public static LocatedBlocksProto convert(LocatedBlocks lb) {
  if (lb == null) {
    return null;
  }
  LocatedBlocksProto.Builder builder = 
      LocatedBlocksProto.newBuilder();
  if (lb.getLastLocatedBlock() != null) {
    builder.setLastBlock(PBHelper.convert(lb.getLastLocatedBlock()));
  }
  if (lb.getFileEncryptionInfo() != null) {
    builder.setFileEncryptionInfo(convert(lb.getFileEncryptionInfo()));
  }
  return builder.setFileLength(lb.getFileLength())
      .setUnderConstruction(lb.isUnderConstruction())
      .addAllBlocks(PBHelper.convertLocatedBlock2(lb.getLocatedBlocks()))
      .setIsLastBlockComplete(lb.isLastBlockComplete()).build();
}
项目：aliyun-oss-hadoop-fs    文件：PBHelperClient.java    
public static LocatedBlocksProto convert(LocatedBlocks lb) {
  if (lb == null) {
    return null;
  }
  LocatedBlocksProto.Builder builder =
      LocatedBlocksProto.newBuilder();
  if (lb.getLastLocatedBlock() != null) {
    builder.setLastBlock(
        convertLocatedBlock(lb.getLastLocatedBlock()));
  }
  if (lb.getFileEncryptionInfo() != null) {
    builder.setFileEncryptionInfo(convert(lb.getFileEncryptionInfo()));
  }
  if (lb.getErasureCodingPolicy() != null) {
    builder.setEcPolicy(convertErasureCodingPolicy(
        lb.getErasureCodingPolicy()));
  }
  return builder.setFileLength(lb.getFileLength())
      .setUnderConstruction(lb.isUnderConstruction())
      .addAllBlocks(convertLocatedBlocks2(lb.getLocatedBlocks()))
      .setIsLastBlockComplete(lb.isLastBlockComplete()).build();
}
项目：big-c    文件：PBHelper.java    
public static LocatedBlocksProto convert(LocatedBlocks lb) {
  if (lb == null) {
    return null;
  }
  LocatedBlocksProto.Builder builder = 
      LocatedBlocksProto.newBuilder();
  if (lb.getLastLocatedBlock() != null) {
    builder.setLastBlock(PBHelper.convert(lb.getLastLocatedBlock()));
  }
  if (lb.getFileEncryptionInfo() != null) {
    builder.setFileEncryptionInfo(convert(lb.getFileEncryptionInfo()));
  }
  return builder.setFileLength(lb.getFileLength())
      .setUnderConstruction(lb.isUnderConstruction())
      .addAllBlocks(PBHelper.convertLocatedBlock2(lb.getLocatedBlocks()))
      .setIsLastBlockComplete(lb.isLastBlockComplete()).build();
}
项目：hadoop-2.6.0-cdh5.4.3    文件：PBHelper.java    
public static LocatedBlocksProto convert(LocatedBlocks lb) {
  if (lb == null) {
    return null;
  }
  LocatedBlocksProto.Builder builder = 
      LocatedBlocksProto.newBuilder();
  if (lb.getLastLocatedBlock() != null) {
    builder.setLastBlock(PBHelper.convert(lb.getLastLocatedBlock()));
  }
  if (lb.getFileEncryptionInfo() != null) {
    builder.setFileEncryptionInfo(convert(lb.getFileEncryptionInfo()));
  }
  return builder.setFileLength(lb.getFileLength())
      .setUnderConstruction(lb.isUnderConstruction())
      .addAllBlocks(PBHelper.convertLocatedBlock2(lb.getLocatedBlocks()))
      .setIsLastBlockComplete(lb.isLastBlockComplete()).build();
}
项目：FlexMap    文件：PBHelper.java    
public static LocatedBlocksProto convert(LocatedBlocks lb) {
  if (lb == null) {
    return null;
  }
  LocatedBlocksProto.Builder builder = 
      LocatedBlocksProto.newBuilder();
  if (lb.getLastLocatedBlock() != null) {
    builder.setLastBlock(PBHelper.convert(lb.getLastLocatedBlock()));
  }
  if (lb.getFileEncryptionInfo() != null) {
    builder.setFileEncryptionInfo(convert(lb.getFileEncryptionInfo()));
  }
  return builder.setFileLength(lb.getFileLength())
      .setUnderConstruction(lb.isUnderConstruction())
      .addAllBlocks(PBHelper.convertLocatedBlock2(lb.getLocatedBlocks()))
      .setIsLastBlockComplete(lb.isLastBlockComplete()).build();
}
项目：hadoop    文件：PBHelper.java    
public static LocatedBlocks convert(LocatedBlocksProto lb) {
  return new LocatedBlocks(
      lb.getFileLength(), lb.getUnderConstruction(),
      PBHelper.convertLocatedBlock(lb.getBlocksList()),
      lb.hasLastBlock() ? PBHelper.convert(lb.getLastBlock()) : null,
      lb.getIsLastBlockComplete(),
      lb.hasFileEncryptionInfo() ? convert(lb.getFileEncryptionInfo()) :
          null);
}
项目：aliyun-oss-hadoop-fs    文件：PBHelperClient.java    
public static LocatedBlocks convert(LocatedBlocksProto lb) {
  return new LocatedBlocks(
      lb.getFileLength(), lb.getUnderConstruction(),
      convertLocatedBlocks(lb.getBlocksList()),
      lb.hasLastBlock() ?
          convertLocatedBlockProto(lb.getLastBlock()) : null,
      lb.getIsLastBlockComplete(),
      lb.hasFileEncryptionInfo() ? convert(lb.getFileEncryptionInfo()) : null,
      lb.hasEcPolicy() ? convertErasureCodingPolicy(lb.getEcPolicy()) : null);
}
项目：big-c    文件：PBHelper.java    
public static LocatedBlocks convert(LocatedBlocksProto lb) {
  return new LocatedBlocks(
      lb.getFileLength(), lb.getUnderConstruction(),
      PBHelper.convertLocatedBlock(lb.getBlocksList()),
      lb.hasLastBlock() ? PBHelper.convert(lb.getLastBlock()) : null,
      lb.getIsLastBlockComplete(),
      lb.hasFileEncryptionInfo() ? convert(lb.getFileEncryptionInfo()) :
          null);
}
项目：hadoop-2.6.0-cdh5.4.3    文件：PBHelper.java    
public static LocatedBlocks convert(LocatedBlocksProto lb) {
  return new LocatedBlocks(
      lb.getFileLength(), lb.getUnderConstruction(),
      PBHelper.convertLocatedBlock(lb.getBlocksList()),
      lb.hasLastBlock() ? PBHelper.convert(lb.getLastBlock()) : null,
      lb.getIsLastBlockComplete(),
      lb.hasFileEncryptionInfo() ? convert(lb.getFileEncryptionInfo()) :
          null);
}
项目：hadoop-plus    文件：PBHelper.java    
public static LocatedBlocks convert(LocatedBlocksProto lb) {
  return new LocatedBlocks(
      lb.getFileLength(), lb.getUnderConstruction(),
      PBHelper.convertLocatedBlock(lb.getBlocksList()),
      lb.hasLastBlock() ? PBHelper.convert(lb.getLastBlock()) : null,
      lb.getIsLastBlockComplete());
}
项目：hadoop-plus    文件：PBHelper.java    
public static LocatedBlocksProto convert(LocatedBlocks lb) {
  if (lb == null) {
    return null;
  }
  LocatedBlocksProto.Builder builder = 
      LocatedBlocksProto.newBuilder();
  if (lb.getLastLocatedBlock() != null) {
    builder.setLastBlock(PBHelper.convert(lb.getLastLocatedBlock()));
  }
  return builder.setFileLength(lb.getFileLength())
      .setUnderConstruction(lb.isUnderConstruction())
      .addAllBlocks(PBHelper.convertLocatedBlock2(lb.getLocatedBlocks()))
      .setIsLastBlockComplete(lb.isLastBlockComplete()).build();
}
项目：FlexMap    文件：PBHelper.java    
public static LocatedBlocks convert(LocatedBlocksProto lb) {
  return new LocatedBlocks(
      lb.getFileLength(), lb.getUnderConstruction(),
      PBHelper.convertLocatedBlock(lb.getBlocksList()),
      lb.hasLastBlock() ? PBHelper.convert(lb.getLastBlock()) : null,
      lb.getIsLastBlockComplete(),
      lb.hasFileEncryptionInfo() ? convert(lb.getFileEncryptionInfo()) :
          null);
}
项目：hops    文件：PBHelper.java    
public static LocatedBlocks convert(LocatedBlocksProto lb) {
  LocatedBlocks locatedBlocks =  new LocatedBlocks(lb.getFileLength(), lb.getUnderConstruction(),
      PBHelper.convertLocatedBlock(lb.getBlocksList()),
      lb.hasLastBlock() ? PBHelper.convert(lb.getLastBlock()) : null,
      lb.getIsLastBlockComplete());
  return locatedBlocks;
}
项目：hops    文件：PBHelper.java    
public static LocatedBlocksProto convert(LocatedBlocks lb) {
  if (lb == null) {
    return null;
  }
  LocatedBlocksProto.Builder builder = LocatedBlocksProto.newBuilder();
  if (lb.getLastLocatedBlock() != null) {
    builder.setLastBlock(PBHelper.convert(lb.getLastLocatedBlock()));
  }
  return builder.setFileLength(lb.getFileLength())
      .setUnderConstruction(lb.isUnderConstruction())
      .addAllBlocks(PBHelper.convertLocatedBlock2(lb.getLocatedBlocks()))
      .setIsLastBlockComplete(lb.isLastBlockComplete()).build();
}
项目：hadoop-TCP    文件：PBHelper.java    
public static LocatedBlocks convert(LocatedBlocksProto lb) {
  return new LocatedBlocks(
      lb.getFileLength(), lb.getUnderConstruction(),
      PBHelper.convertLocatedBlock(lb.getBlocksList()),
      lb.hasLastBlock() ? PBHelper.convert(lb.getLastBlock()) : null,
      lb.getIsLastBlockComplete());
}
项目：hadoop-TCP    文件：PBHelper.java    
public static LocatedBlocksProto convert(LocatedBlocks lb) {
  if (lb == null) {
    return null;
  }
  LocatedBlocksProto.Builder builder = 
      LocatedBlocksProto.newBuilder();
  if (lb.getLastLocatedBlock() != null) {
    builder.setLastBlock(PBHelper.convert(lb.getLastLocatedBlock()));
  }
  return builder.setFileLength(lb.getFileLength())
      .setUnderConstruction(lb.isUnderConstruction())
      .addAllBlocks(PBHelper.convertLocatedBlock2(lb.getLocatedBlocks()))
      .setIsLastBlockComplete(lb.isLastBlockComplete()).build();
}
项目：hardfs    文件：PBHelper.java    
public static LocatedBlocks convert(LocatedBlocksProto lb) {
  return new LocatedBlocks(
      lb.getFileLength(), lb.getUnderConstruction(),
      PBHelper.convertLocatedBlock(lb.getBlocksList()),
      lb.hasLastBlock() ? PBHelper.convert(lb.getLastBlock()) : null,
      lb.getIsLastBlockComplete());
}
项目：hardfs    文件：PBHelper.java    
public static LocatedBlocksProto convert(LocatedBlocks lb) {
  if (lb == null) {
    return null;
  }
  LocatedBlocksProto.Builder builder = 
      LocatedBlocksProto.newBuilder();
  if (lb.getLastLocatedBlock() != null) {
    builder.setLastBlock(PBHelper.convert(lb.getLastLocatedBlock()));
  }
  return builder.setFileLength(lb.getFileLength())
      .setUnderConstruction(lb.isUnderConstruction())
      .addAllBlocks(PBHelper.convertLocatedBlock2(lb.getLocatedBlocks()))
      .setIsLastBlockComplete(lb.isLastBlockComplete()).build();
}
项目：hadoop-on-lustre2    文件：PBHelper.java    
public static LocatedBlocks convert(LocatedBlocksProto lb) {
  return new LocatedBlocks(
      lb.getFileLength(), lb.getUnderConstruction(),
      PBHelper.convertLocatedBlock(lb.getBlocksList()),
      lb.hasLastBlock() ? PBHelper.convert(lb.getLastBlock()) : null,
      lb.getIsLastBlockComplete());
}
项目：hadoop-on-lustre2    文件：PBHelper.java    
public static LocatedBlocksProto convert(LocatedBlocks lb) {
  if (lb == null) {
    return null;
  }
  LocatedBlocksProto.Builder builder = 
      LocatedBlocksProto.newBuilder();
  if (lb.getLastLocatedBlock() != null) {
    builder.setLastBlock(PBHelper.convert(lb.getLastLocatedBlock()));
  }
  return builder.setFileLength(lb.getFileLength())
      .setUnderConstruction(lb.isUnderConstruction())
      .addAllBlocks(PBHelper.convertLocatedBlock2(lb.getLocatedBlocks()))
      .setIsLastBlockComplete(lb.isLastBlockComplete()).build();
}