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

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));
}

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));
}

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));
}

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));
}

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));
}

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));
}

public PersistState(CacheManagerSection section,
    List<CachePoolInfoProto> pools, List<CacheDirectiveInfoProto> directives) {
  this.section = section;
  this.pools = pools;
  this.directives = directives;
}

public PersistState(CacheManagerSection section,
    List<CachePoolInfoProto> pools, List<CacheDirectiveInfoProto> directives) {
  this.section = section;
  this.pools = pools;
  this.directives = directives;
}

public PersistState(CacheManagerSection section,
    List<CachePoolInfoProto> pools, List<CacheDirectiveInfoProto> directives) {
  this.section = section;
  this.pools = pools;
  this.directives = directives;
}

public PersistState(CacheManagerSection section,
    List<CachePoolInfoProto> pools, List<CacheDirectiveInfoProto> directives) {
  this.section = section;
  this.pools = pools;
  this.directives = directives;
}

public PersistState(CacheManagerSection section,
    List<CachePoolInfoProto> pools, List<CacheDirectiveInfoProto> directives) {
  this.section = section;
  this.pools = pools;
  this.directives = directives;
}

public PersistState(CacheManagerSection section,
    List<CachePoolInfoProto> pools, List<CacheDirectiveInfoProto> directives) {
  this.section = section;
  this.pools = pools;
  this.directives = directives;
}