Java 类org.apache.hadoop.hbase.io.hfile.ChecksumUtil 实例源码

public HBaseTestingUtility(Configuration conf) {
  this.conf = conf;

  // a hbase checksum verification failure will cause unit tests to fail
  ChecksumUtil.generateExceptionForChecksumFailureForTest(true);
  setHDFSClientRetryProperty();
}

public HBaseTestingUtility(Configuration conf) {
  this.conf = conf;

  // a hbase checksum verification failure will cause unit tests to fail
  ChecksumUtil.generateExceptionForChecksumFailureForTest(true);
  setHDFSClientRetryProperty();
}

/**
 * <p>Create an HBaseTestingUtility using a given configuration.
 *
 * <p>Initially, all tmp files are written to a local test data directory.
 * Once {@link #startMiniDFSCluster} is called, either directly or via
 * {@link #startMiniCluster()}, tmp data will be written to the DFS directory instead.
 *
 * <p>Previously, there was a distinction between the type of utility returned by
 * {@link #createLocalHTU()} and this constructor; this is no longer the case. All
 * HBaseTestingUtility objects will behave as local until a DFS cluster is started,
 * at which point they will switch to using mini DFS for storage.
 *
 * @param conf The configuration to use for further operations
 */
public HBaseTestingUtility(@Nullable Configuration conf) {
  super(conf);

  // a hbase checksum verification failure will cause unit tests to fail
  ChecksumUtil.generateExceptionForChecksumFailureForTest(true);

  // if conf is provided, prevent contention for ports if other hbase thread(s) are running
  if (conf != null) {
    if (conf.getInt(HConstants.MASTER_INFO_PORT, HConstants.DEFAULT_MASTER_INFOPORT)
            == HConstants.DEFAULT_MASTER_INFOPORT) {
      conf.setInt(HConstants.MASTER_INFO_PORT, -1);
      LOG.debug("Config property {} changed to -1", HConstants.MASTER_INFO_PORT);
    }
    if (conf.getInt(HConstants.REGIONSERVER_PORT, HConstants.DEFAULT_REGIONSERVER_PORT)
            == HConstants.DEFAULT_REGIONSERVER_PORT) {
      conf.setInt(HConstants.REGIONSERVER_PORT, -1);
      LOG.debug("Config property {} changed to -1", HConstants.REGIONSERVER_PORT);
    }
  }

  // Every cluster is a local cluster until we start DFS
  // Note that conf could be null, but this.conf will not be
  String dataTestDir = getDataTestDir().toString();
  this.conf.set("fs.defaultFS","file:///");
  this.conf.set(HConstants.HBASE_DIR, "file://" + dataTestDir);
  LOG.debug("Setting {} to {}", HConstants.HBASE_DIR, dataTestDir);
  this.conf.setBoolean(CommonFSUtils.UNSAFE_STREAM_CAPABILITY_ENFORCE,false);
}

public HBaseTestingUtility(Configuration conf) {
  this.conf = conf;

  // a hbase checksum verification failure will cause unit tests to fail
  ChecksumUtil.generateExceptionForChecksumFailureForTest(true);
  setHDFSClientRetryProperty();
}

public HBaseTestingUtility(Configuration conf) {
  this.conf = conf;

  // a hbase checksum verification failure will cause unit tests to fail
  ChecksumUtil.generateExceptionForChecksumFailureForTest(true);
  setHDFSClientRetryProperty();
}

public HBaseTestingUtility(Configuration conf) {
  this.conf = conf;

  // a hbase checksum verification failure will cause unit tests to fail
  ChecksumUtil.generateExceptionForChecksumFailureForTest(true);
  setHDFSClientRetryProperty();
}

public HBaseTestingUtility(Configuration conf) {
  this.conf = conf;

  // a hbase checksum verification failure will cause unit tests to fail
  ChecksumUtil.generateExceptionForChecksumFailureForTest(true);
  setHDFSClientRetryProperty();
}

public HBaseTestingUtility(Configuration conf) {
  super(conf);

  // a hbase checksum verification failure will cause unit tests to fail
  ChecksumUtil.generateExceptionForChecksumFailureForTest(true);
}

public HBaseTestingUtility(Configuration conf) {
  super(conf);

  // a hbase checksum verification failure will cause unit tests to fail
  ChecksumUtil.generateExceptionForChecksumFailureForTest(true);
}

public HBaseTestingUtility(Configuration conf) {
  super(conf);

  // a hbase checksum verification failure will cause unit tests to fail
  ChecksumUtil.generateExceptionForChecksumFailureForTest(true);
}

public HBaseTestingUtility(Configuration conf) {
  super(conf);

  // a hbase checksum verification failure will cause unit tests to fail
  ChecksumUtil.generateExceptionForChecksumFailureForTest(true);
}

public HBaseTestingUtility(Configuration conf) {
  super(conf);

  // a hbase checksum verification failure will cause unit tests to fail
  ChecksumUtil.generateExceptionForChecksumFailureForTest(true);
}

public HBaseTestingUtility(Configuration conf) {
  this.conf = conf;

  // a hbase checksum verification failure will cause unit tests to fail
  ChecksumUtil.generateExceptionForChecksumFailureForTest(true);
}