Java 类org.apache.hadoop.hbase.client.backoff.ClientBackoffPolicy 实例源码

项目：ditb 文件：TestClientPushback.java

@BeforeClass
public static void setupCluster() throws Exception{
  Configuration conf = UTIL.getConfiguration();
  // enable backpressure
  conf.setBoolean(HConstants.ENABLE_CLIENT_BACKPRESSURE, true);
  // use the exponential backoff policy
  conf.setClass(ClientBackoffPolicy.BACKOFF_POLICY_CLASS, ExponentialClientBackoffPolicy.class,
    ClientBackoffPolicy.class);
  // turn the memstore size way down so we don't need to write a lot to see changes in memstore
  // load
  conf.setLong(HConstants.HREGION_MEMSTORE_FLUSH_SIZE, flushSizeBytes);
  // ensure we block the flushes when we are double that flushsize
  conf.setLong(HConstants.HREGION_MEMSTORE_BLOCK_MULTIPLIER, HConstants.DEFAULT_HREGION_MEMSTORE_BLOCK_MULTIPLIER);
  conf.setBoolean(CLIENT_SIDE_METRICS_ENABLED_KEY, true);
  UTIL.startMiniCluster();
  UTIL.createTable(tableName, family);
}

项目：pbase 文件：TestClientPushback.java

@BeforeClass
public static void setupCluster() throws Exception{
  Configuration conf = UTIL.getConfiguration();
  // enable backpressure
  conf.setBoolean(HConstants.ENABLE_CLIENT_BACKPRESSURE, true);
  // use the exponential backoff policy
  conf.setClass(ClientBackoffPolicy.BACKOFF_POLICY_CLASS, ExponentialClientBackoffPolicy.class,
    ClientBackoffPolicy.class);
  // turn the memstore size way down so we don't need to write a lot to see changes in memstore
  // load
  conf.setLong(HConstants.HREGION_MEMSTORE_FLUSH_SIZE, flushSizeBytes);
  // ensure we block the flushes when we are double that flushsize
  conf.setLong("hbase.hregion.memstore.block.multiplier", 2);

  UTIL.startMiniCluster();
  UTIL.createTable(tableName, family);
}

项目：hbase 文件：TestClientPushback.java

@BeforeClass
public static void setupCluster() throws Exception{
  Configuration conf = UTIL.getConfiguration();
  // enable backpressure
  conf.setBoolean(HConstants.ENABLE_CLIENT_BACKPRESSURE, true);
  // use the exponential backoff policy
  conf.setClass(ClientBackoffPolicy.BACKOFF_POLICY_CLASS, ExponentialClientBackoffPolicy.class,
    ClientBackoffPolicy.class);
  // turn the memstore size way down so we don't need to write a lot to see changes in memstore
  // load
  conf.setLong(HConstants.HREGION_MEMSTORE_FLUSH_SIZE, flushSizeBytes);
  // ensure we block the flushes when we are double that flushsize
  conf.setLong(HConstants.HREGION_MEMSTORE_BLOCK_MULTIPLIER, HConstants.DEFAULT_HREGION_MEMSTORE_BLOCK_MULTIPLIER);
  conf.setBoolean(CLIENT_SIDE_METRICS_ENABLED_KEY, true);
  UTIL.startMiniCluster(1);
  UTIL.createTable(tableName, family);
}

项目：ditb 文件：ConnectionAdapter.java

@Override
public ClientBackoffPolicy getBackoffPolicy() {
  return wrappedConnection.getBackoffPolicy();
}

项目：ditb 文件：ConnectionManager.java

@Override
public ClientBackoffPolicy getBackoffPolicy() {
  return this.backoffPolicy;
}

项目：pbase 文件：ConnectionAdapter.java

@Override
public ClientBackoffPolicy getBackoffPolicy() {
  return wrappedConnection.getBackoffPolicy();
}

项目：pbase 文件：ConnectionManager.java

@Override
public ClientBackoffPolicy getBackoffPolicy() {
    return this.backoffPolicy;
}

项目：hbase 文件：ConnectionImplementation.java

@Override
public ClientBackoffPolicy getBackoffPolicy() {
  return this.backoffPolicy;
}

项目：ditb 文件：ClusterConnection.java

/**
 * @return the configured client backoff policy
 */
ClientBackoffPolicy getBackoffPolicy();

项目：pbase 文件：ClusterConnection.java

/**
 * @return the configured client backoff policy
 */
ClientBackoffPolicy getBackoffPolicy();

项目：hbase 文件：ClusterConnection.java

/**
 * @return the configured client backoff policy
 */
ClientBackoffPolicy getBackoffPolicy();