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

项目：hadoop 文件：StandbyCheckpointer.java

public StandbyCheckpointer(Configuration conf, FSNamesystem ns)
    throws IOException {
  this.namesystem = ns;
  this.conf = conf;
  this.checkpointConf = new CheckpointConf(conf); 
  this.thread = new CheckpointerThread();
  this.uploadThreadFactory = new ThreadFactoryBuilder().setDaemon(true)
      .setNameFormat("TransferFsImageUpload-%d").build();

  setNameNodeAddresses(conf);
}

项目：aliyun-oss-hadoop-fs 文件：StandbyCheckpointer.java

public StandbyCheckpointer(Configuration conf, FSNamesystem ns)
    throws IOException {
  this.namesystem = ns;
  this.conf = conf;
  this.checkpointConf = new CheckpointConf(conf); 
  this.thread = new CheckpointerThread();
  this.uploadThreadFactory = new ThreadFactoryBuilder().setDaemon(true)
      .setNameFormat("TransferFsImageUpload-%d").build();

  setNameNodeAddresses(conf);
}

项目：big-c 文件：StandbyCheckpointer.java

public StandbyCheckpointer(Configuration conf, FSNamesystem ns)
    throws IOException {
  this.namesystem = ns;
  this.conf = conf;
  this.checkpointConf = new CheckpointConf(conf); 
  this.thread = new CheckpointerThread();
  this.uploadThreadFactory = new ThreadFactoryBuilder().setDaemon(true)
      .setNameFormat("TransferFsImageUpload-%d").build();

  setNameNodeAddresses(conf);
}

项目：hadoop-2.6.0-cdh5.4.3 文件：StandbyCheckpointer.java

public StandbyCheckpointer(Configuration conf, FSNamesystem ns)
    throws IOException {
  this.namesystem = ns;
  this.conf = conf;
  this.checkpointConf = new CheckpointConf(conf); 
  this.thread = new CheckpointerThread();
  this.uploadThreadFactory = new ThreadFactoryBuilder().setDaemon(true)
      .setNameFormat("TransferFsImageUpload-%d").build();

  setNameNodeAddresses(conf);
}

项目：hadoop-plus 文件：StandbyCheckpointer.java

public StandbyCheckpointer(Configuration conf, FSNamesystem ns)
    throws IOException {
  this.namesystem = ns;
  this.checkpointConf = new CheckpointConf(conf); 
  this.thread = new CheckpointerThread();

  setNameNodeAddresses(conf);
}

项目：FlexMap 文件：StandbyCheckpointer.java

public StandbyCheckpointer(Configuration conf, FSNamesystem ns)
    throws IOException {
  this.namesystem = ns;
  this.conf = conf;
  this.checkpointConf = new CheckpointConf(conf); 
  this.thread = new CheckpointerThread();
  this.uploadThreadFactory = new ThreadFactoryBuilder().setDaemon(true)
      .setNameFormat("TransferFsImageUpload-%d").build();

  setNameNodeAddresses(conf);
}

项目：hadoop-TCP 文件：StandbyCheckpointer.java

public StandbyCheckpointer(Configuration conf, FSNamesystem ns)
    throws IOException {
  this.namesystem = ns;
  this.checkpointConf = new CheckpointConf(conf); 
  this.thread = new CheckpointerThread();

  setNameNodeAddresses(conf);
}

项目：hardfs 文件：StandbyCheckpointer.java

public StandbyCheckpointer(Configuration conf, FSNamesystem ns)
    throws IOException {
  this.namesystem = ns;
  this.checkpointConf = new CheckpointConf(conf); 
  this.thread = new CheckpointerThread();

  setNameNodeAddresses(conf);
}

项目：hadoop-on-lustre2 文件：StandbyCheckpointer.java

public StandbyCheckpointer(Configuration conf, FSNamesystem ns)
    throws IOException {
  this.namesystem = ns;
  this.conf = conf;
  this.checkpointConf = new CheckpointConf(conf); 
  this.thread = new CheckpointerThread();
  this.uploadThreadFactory = new ThreadFactoryBuilder().setDaemon(true)
      .setNameFormat("TransferFsImageUpload-%d").build();

  setNameNodeAddresses(conf);
}