Java 类org.apache.hadoop.hdfs.server.datanode.BlockScanner.Conf 实例源码

项目：hadoop 文件：VolumeScanner.java

VolumeScanner(Conf conf, DataNode datanode, FsVolumeReference ref) {
  this.conf = conf;
  this.datanode = datanode;
  this.ref = ref;
  this.volume = ref.getVolume();
  ScanResultHandler handler;
  try {
    handler = conf.resultHandler.newInstance();
  } catch (Throwable e) {
    LOG.error("unable to instantiate {}", conf.resultHandler, e);
    handler = new ScanResultHandler();
  }
  this.resultHandler = handler;
  setName("VolumeScannerThread(" + volume.getBasePath() + ")");
  setDaemon(true);
}

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

VolumeScanner(Conf conf, DataNode datanode, FsVolumeReference ref) {
  this.conf = conf;
  this.datanode = datanode;
  this.ref = ref;
  this.volume = ref.getVolume();
  ScanResultHandler handler;
  try {
    handler = conf.resultHandler.newInstance();
  } catch (Throwable e) {
    LOG.error("unable to instantiate {}", conf.resultHandler, e);
    handler = new ScanResultHandler();
  }
  this.resultHandler = handler;
  setName("VolumeScannerThread(" + volume.getBasePath() + ")");
  setDaemon(true);
}

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

VolumeScanner(Conf conf, DataNode datanode, FsVolumeReference ref) {
  this.conf = conf;
  this.datanode = datanode;
  this.ref = ref;
  this.volume = ref.getVolume();
  ScanResultHandler handler;
  try {
    handler = conf.resultHandler.newInstance();
  } catch (Throwable e) {
    LOG.error("unable to instantiate {}", conf.resultHandler, e);
    handler = new ScanResultHandler();
  }
  this.resultHandler = handler;
  setName("VolumeScannerThread(" + volume.getBasePath() + ")");
  setDaemon(true);
}

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

VolumeScanner(Conf conf, DataNode datanode, FsVolumeReference ref) {
  this.conf = conf;
  this.datanode = datanode;
  this.ref = ref;
  this.volume = ref.getVolume();
  ScanResultHandler handler;
  try {
    handler = conf.resultHandler.newInstance();
  } catch (Throwable e) {
    LOG.error("unable to instantiate {}", conf.resultHandler, e);
    handler = new ScanResultHandler();
  }
  this.resultHandler = handler;
  setName("VolumeScannerThread(" + volume.getBasePath() + ")");
  setDaemon(true);
}