1. 包列表
  2. 类列表
  3. org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.CacheDirectiveInfoProto

Java 类org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.CacheDirectiveInfoProto 实例源码

项目：hadoop    文件：PBHelper.java    
public static CacheDirectiveInfoProto convert
    (CacheDirectiveInfo info) {
  CacheDirectiveInfoProto.Builder builder = 
      CacheDirectiveInfoProto.newBuilder();
  if (info.getId() != null) {
    builder.setId(info.getId());
  }
  if (info.getPath() != null) {
    builder.setPath(info.getPath().toUri().getPath());
  }
  if (info.getReplication() != null) {
    builder.setReplication(info.getReplication());
  }
  if (info.getPool() != null) {
    builder.setPool(info.getPool());
  }
  if (info.getExpiration() != null) {
    builder.setExpiration(convert(info.getExpiration()));
  }
  return builder.build();
}
项目：hadoop    文件：PBHelper.java    
public static CacheDirectiveInfo convert
    (CacheDirectiveInfoProto proto) {
  CacheDirectiveInfo.Builder builder =
      new CacheDirectiveInfo.Builder();
  if (proto.hasId()) {
    builder.setId(proto.getId());
  }
  if (proto.hasPath()) {
    builder.setPath(new Path(proto.getPath()));
  }
  if (proto.hasReplication()) {
    builder.setReplication(Shorts.checkedCast(
        proto.getReplication()));
  }
  if (proto.hasPool()) {
    builder.setPool(proto.getPool());
  }
  if (proto.hasExpiration()) {
    builder.setExpiration(convert(proto.getExpiration()));
  }
  return builder.build();
}
项目：aliyun-oss-hadoop-fs    文件：PBHelperClient.java    
public static CacheDirectiveInfoProto convert(CacheDirectiveInfo info) {
  CacheDirectiveInfoProto.Builder builder =
      CacheDirectiveInfoProto.newBuilder();
  if (info.getId() != null) {
    builder.setId(info.getId());
  }
  if (info.getPath() != null) {
    builder.setPath(info.getPath().toUri().getPath());
  }
  if (info.getReplication() != null) {
    builder.setReplication(info.getReplication());
  }
  if (info.getPool() != null) {
    builder.setPool(info.getPool());
  }
  if (info.getExpiration() != null) {
    builder.setExpiration(convert(info.getExpiration()));
  }
  return builder.build();
}
项目：aliyun-oss-hadoop-fs    文件：PBHelperClient.java    
public static CacheDirectiveInfo convert(CacheDirectiveInfoProto proto) {
  CacheDirectiveInfo.Builder builder = new CacheDirectiveInfo.Builder();
  if (proto.hasId()) {
    builder.setId(proto.getId());
  }
  if (proto.hasPath()) {
    builder.setPath(new Path(proto.getPath()));
  }
  if (proto.hasReplication()) {
    builder.setReplication(Shorts.checkedCast(
        proto.getReplication()));
  }
  if (proto.hasPool()) {
    builder.setPool(proto.getPool());
  }
  if (proto.hasExpiration()) {
    builder.setExpiration(convert(proto.getExpiration()));
  }
  return builder.build();
}
项目：aliyun-oss-hadoop-fs    文件：FSImageFormatProtobuf.java    
private void loadCacheManagerSection(InputStream in, StartupProgress prog,
    Step currentStep) throws IOException {
  CacheManagerSection s = CacheManagerSection.parseDelimitedFrom(in);
  int numPools = s.getNumPools();
  ArrayList<CachePoolInfoProto> pools = Lists
      .newArrayListWithCapacity(numPools);
  ArrayList<CacheDirectiveInfoProto> directives = Lists
      .newArrayListWithCapacity(s.getNumDirectives());
  prog.setTotal(Phase.LOADING_FSIMAGE, currentStep, numPools);
  Counter counter = prog.getCounter(Phase.LOADING_FSIMAGE, currentStep);
  for (int i = 0; i < numPools; ++i) {
    pools.add(CachePoolInfoProto.parseDelimitedFrom(in));
    counter.increment();
  }
  for (int i = 0; i < s.getNumDirectives(); ++i)
    directives.add(CacheDirectiveInfoProto.parseDelimitedFrom(in));
  fsn.getCacheManager().loadState(
      new CacheManager.PersistState(s, pools, directives));
}
项目：big-c    文件：PBHelper.java    
public static CacheDirectiveInfoProto convert
    (CacheDirectiveInfo info) {
  CacheDirectiveInfoProto.Builder builder = 
      CacheDirectiveInfoProto.newBuilder();
  if (info.getId() != null) {
    builder.setId(info.getId());
  }
  if (info.getPath() != null) {
    builder.setPath(info.getPath().toUri().getPath());
  }
  if (info.getReplication() != null) {
    builder.setReplication(info.getReplication());
  }
  if (info.getPool() != null) {
    builder.setPool(info.getPool());
  }
  if (info.getExpiration() != null) {
    builder.setExpiration(convert(info.getExpiration()));
  }
  return builder.build();
}
项目：big-c    文件：PBHelper.java    
public static CacheDirectiveInfo convert
    (CacheDirectiveInfoProto proto) {
  CacheDirectiveInfo.Builder builder =
      new CacheDirectiveInfo.Builder();
  if (proto.hasId()) {
    builder.setId(proto.getId());
  }
  if (proto.hasPath()) {
    builder.setPath(new Path(proto.getPath()));
  }
  if (proto.hasReplication()) {
    builder.setReplication(Shorts.checkedCast(
        proto.getReplication()));
  }
  if (proto.hasPool()) {
    builder.setPool(proto.getPool());
  }
  if (proto.hasExpiration()) {
    builder.setExpiration(convert(proto.getExpiration()));
  }
  return builder.build();
}
项目：hadoop-2.6.0-cdh5.4.3    文件：PBHelper.java    
public static CacheDirectiveInfoProto convert
    (CacheDirectiveInfo info) {
  CacheDirectiveInfoProto.Builder builder = 
      CacheDirectiveInfoProto.newBuilder();
  if (info.getId() != null) {
    builder.setId(info.getId());
  }
  if (info.getPath() != null) {
    builder.setPath(info.getPath().toUri().getPath());
  }
  if (info.getReplication() != null) {
    builder.setReplication(info.getReplication());
  }
  if (info.getPool() != null) {
    builder.setPool(info.getPool());
  }
  if (info.getExpiration() != null) {
    builder.setExpiration(convert(info.getExpiration()));
  }
  return builder.build();
}
项目：hadoop-2.6.0-cdh5.4.3    文件：PBHelper.java    
public static CacheDirectiveInfo convert
    (CacheDirectiveInfoProto proto) {
  CacheDirectiveInfo.Builder builder =
      new CacheDirectiveInfo.Builder();
  if (proto.hasId()) {
    builder.setId(proto.getId());
  }
  if (proto.hasPath()) {
    builder.setPath(new Path(proto.getPath()));
  }
  if (proto.hasReplication()) {
    builder.setReplication(Shorts.checkedCast(
        proto.getReplication()));
  }
  if (proto.hasPool()) {
    builder.setPool(proto.getPool());
  }
  if (proto.hasExpiration()) {
    builder.setExpiration(convert(proto.getExpiration()));
  }
  return builder.build();
}
项目：FlexMap    文件：PBHelper.java    
public static CacheDirectiveInfoProto convert
    (CacheDirectiveInfo info) {
  CacheDirectiveInfoProto.Builder builder = 
      CacheDirectiveInfoProto.newBuilder();
  if (info.getId() != null) {
    builder.setId(info.getId());
  }
  if (info.getPath() != null) {
    builder.setPath(info.getPath().toUri().getPath());
  }
  if (info.getReplication() != null) {
    builder.setReplication(info.getReplication());
  }
  if (info.getPool() != null) {
    builder.setPool(info.getPool());
  }
  if (info.getExpiration() != null) {
    builder.setExpiration(convert(info.getExpiration()));
  }
  return builder.build();
}
项目：FlexMap    文件：PBHelper.java    
public static CacheDirectiveInfo convert
    (CacheDirectiveInfoProto proto) {
  CacheDirectiveInfo.Builder builder =
      new CacheDirectiveInfo.Builder();
  if (proto.hasId()) {
    builder.setId(proto.getId());
  }
  if (proto.hasPath()) {
    builder.setPath(new Path(proto.getPath()));
  }
  if (proto.hasReplication()) {
    builder.setReplication(Shorts.checkedCast(
        proto.getReplication()));
  }
  if (proto.hasPool()) {
    builder.setPool(proto.getPool());
  }
  if (proto.hasExpiration()) {
    builder.setExpiration(convert(proto.getExpiration()));
  }
  return builder.build();
}
项目：hadoop-on-lustre2    文件：PBHelper.java    
public static CacheDirectiveInfoProto convert
    (CacheDirectiveInfo info) {
  CacheDirectiveInfoProto.Builder builder = 
      CacheDirectiveInfoProto.newBuilder();
  if (info.getId() != null) {
    builder.setId(info.getId());
  }
  if (info.getPath() != null) {
    builder.setPath(info.getPath().toUri().getPath());
  }
  if (info.getReplication() != null) {
    builder.setReplication(info.getReplication());
  }
  if (info.getPool() != null) {
    builder.setPool(info.getPool());
  }
  if (info.getExpiration() != null) {
    builder.setExpiration(convert(info.getExpiration()));
  }
  return builder.build();
}
项目：hadoop-on-lustre2    文件：PBHelper.java    
public static CacheDirectiveInfo convert
    (CacheDirectiveInfoProto proto) {
  CacheDirectiveInfo.Builder builder =
      new CacheDirectiveInfo.Builder();
  if (proto.hasId()) {
    builder.setId(proto.getId());
  }
  if (proto.hasPath()) {
    builder.setPath(new Path(proto.getPath()));
  }
  if (proto.hasReplication()) {
    builder.setReplication(Shorts.checkedCast(
        proto.getReplication()));
  }
  if (proto.hasPool()) {
    builder.setPool(proto.getPool());
  }
  if (proto.hasExpiration()) {
    builder.setExpiration(convert(proto.getExpiration()));
  }
  return builder.build();
}
项目：hadoop    文件：FSImageFormatProtobuf.java    
private void loadCacheManagerSection(InputStream in) throws IOException {
  CacheManagerSection s = CacheManagerSection.parseDelimitedFrom(in);
  ArrayList<CachePoolInfoProto> pools = Lists.newArrayListWithCapacity(s
      .getNumPools());
  ArrayList<CacheDirectiveInfoProto> directives = Lists
      .newArrayListWithCapacity(s.getNumDirectives());
  for (int i = 0; i < s.getNumPools(); ++i)
    pools.add(CachePoolInfoProto.parseDelimitedFrom(in));
  for (int i = 0; i < s.getNumDirectives(); ++i)
    directives.add(CacheDirectiveInfoProto.parseDelimitedFrom(in));
  fsn.getCacheManager().loadState(
      new CacheManager.PersistState(s, pools, directives));
}
项目：big-c    文件：FSImageFormatProtobuf.java    
private void loadCacheManagerSection(InputStream in) throws IOException {
  CacheManagerSection s = CacheManagerSection.parseDelimitedFrom(in);
  ArrayList<CachePoolInfoProto> pools = Lists.newArrayListWithCapacity(s
      .getNumPools());
  ArrayList<CacheDirectiveInfoProto> directives = Lists
      .newArrayListWithCapacity(s.getNumDirectives());
  for (int i = 0; i < s.getNumPools(); ++i)
    pools.add(CachePoolInfoProto.parseDelimitedFrom(in));
  for (int i = 0; i < s.getNumDirectives(); ++i)
    directives.add(CacheDirectiveInfoProto.parseDelimitedFrom(in));
  fsn.getCacheManager().loadState(
      new CacheManager.PersistState(s, pools, directives));
}
项目：hadoop-2.6.0-cdh5.4.3    文件：FSImageFormatProtobuf.java    
private void loadCacheManagerSection(InputStream in) throws IOException {
  CacheManagerSection s = CacheManagerSection.parseDelimitedFrom(in);
  ArrayList<CachePoolInfoProto> pools = Lists.newArrayListWithCapacity(s
      .getNumPools());
  ArrayList<CacheDirectiveInfoProto> directives = Lists
      .newArrayListWithCapacity(s.getNumDirectives());
  for (int i = 0; i < s.getNumPools(); ++i)
    pools.add(CachePoolInfoProto.parseDelimitedFrom(in));
  for (int i = 0; i < s.getNumDirectives(); ++i)
    directives.add(CacheDirectiveInfoProto.parseDelimitedFrom(in));
  fsn.getCacheManager().loadState(
      new CacheManager.PersistState(s, pools, directives));
}
项目：FlexMap    文件：FSImageFormatProtobuf.java    
private void loadCacheManagerSection(InputStream in) throws IOException {
  CacheManagerSection s = CacheManagerSection.parseDelimitedFrom(in);
  ArrayList<CachePoolInfoProto> pools = Lists.newArrayListWithCapacity(s
      .getNumPools());
  ArrayList<CacheDirectiveInfoProto> directives = Lists
      .newArrayListWithCapacity(s.getNumDirectives());
  for (int i = 0; i < s.getNumPools(); ++i)
    pools.add(CachePoolInfoProto.parseDelimitedFrom(in));
  for (int i = 0; i < s.getNumDirectives(); ++i)
    directives.add(CacheDirectiveInfoProto.parseDelimitedFrom(in));
  fsn.getCacheManager().loadState(
      new CacheManager.PersistState(s, pools, directives));
}
项目：hadoop-on-lustre2    文件：FSImageFormatProtobuf.java    
private void loadCacheManagerSection(InputStream in) throws IOException {
  CacheManagerSection s = CacheManagerSection.parseDelimitedFrom(in);
  ArrayList<CachePoolInfoProto> pools = Lists.newArrayListWithCapacity(s
      .getNumPools());
  ArrayList<CacheDirectiveInfoProto> directives = Lists
      .newArrayListWithCapacity(s.getNumDirectives());
  for (int i = 0; i < s.getNumPools(); ++i)
    pools.add(CachePoolInfoProto.parseDelimitedFrom(in));
  for (int i = 0; i < s.getNumDirectives(); ++i)
    directives.add(CacheDirectiveInfoProto.parseDelimitedFrom(in));
  fsn.getCacheManager().loadState(
      new CacheManager.PersistState(s, pools, directives));
}
项目：hadoop    文件：CacheManager.java    
public PersistState(CacheManagerSection section,
    List<CachePoolInfoProto> pools, List<CacheDirectiveInfoProto> directives) {
  this.section = section;
  this.pools = pools;
  this.directives = directives;
}
项目：aliyun-oss-hadoop-fs    文件：CacheManager.java    
public PersistState(CacheManagerSection section,
    List<CachePoolInfoProto> pools, List<CacheDirectiveInfoProto> directives) {
  this.section = section;
  this.pools = pools;
  this.directives = directives;
}
项目：big-c    文件：CacheManager.java    
public PersistState(CacheManagerSection section,
    List<CachePoolInfoProto> pools, List<CacheDirectiveInfoProto> directives) {
  this.section = section;
  this.pools = pools;
  this.directives = directives;
}
项目：hadoop-2.6.0-cdh5.4.3    文件：CacheManager.java    
public PersistState(CacheManagerSection section,
    List<CachePoolInfoProto> pools, List<CacheDirectiveInfoProto> directives) {
  this.section = section;
  this.pools = pools;
  this.directives = directives;
}
项目：FlexMap    文件：CacheManager.java    
public PersistState(CacheManagerSection section,
    List<CachePoolInfoProto> pools, List<CacheDirectiveInfoProto> directives) {
  this.section = section;
  this.pools = pools;
  this.directives = directives;
}
项目：hadoop-on-lustre2    文件：CacheManager.java    
public PersistState(CacheManagerSection section,
    List<CachePoolInfoProto> pools, List<CacheDirectiveInfoProto> directives) {
  this.section = section;
  this.pools = pools;
  this.directives = directives;
}