List of balancer() Examples

Examples of balancer()

org.apache.hadoop.hbase.client.Admin.balancer()
Invoke the balancer. Will run the balancer and if regions to move, it will go ahead and do the reassignments. Can NOT run for various reasons. Check logs. @return True if balancer ran, false otherwise.
org.apache.hadoop.hbase.client.HBaseAdmin.balancer()
Invoke the balancer. Will run the balancer and if regions to move, it will go ahead and do the reassignments. Can NOT run for various reasons. Check logs. @return True if balancer ran, false otherwise.

Examples of org.apache.hadoop.hbase.client.HBaseAdmin.balancer()

  public static class ForceBalancerAction extends Action {
    @Override
    public void perform() throws Exception {
      LOG.info("Balancing regions");
      HBaseAdmin admin = this.context.getHBaseIntegrationTestingUtility().getHBaseAdmin();
      boolean result = admin.balancer();
      if (!result) {
        LOG.error("Balancer didn't succeed");
      }
    }
  }

View Full Code Here

Examples of org.apache.hadoop.hbase.client.HBaseAdmin.balancer()

    String indexTableName = "testBalanceClusterFromAdminBalancer" + Constants.INDEX_TABLE_SUFFIX;
    waitUntilIndexTableCreated(master, indexTableName);
    admin.disableTable(tableName);
    admin.enableTable(tableName);
    admin.balanceSwitch(true);
    admin.balancer();
    boolean isRegionsColocated = checkForColocation(master, tableName, indexTableName);
    assertTrue("User regions and index regions should colocate.", isRegionsColocated);
  }


  @Test(timeout = 180000)

View Full Code Here

Examples of org.apache.hadoop.hbase.client.HBaseAdmin.balancer()

        "testByTableBalanceClusterFromAdminBalancer" + Constants.INDEX_TABLE_SUFFIX;
    waitUntilIndexTableCreated(master, indexTableName);
    admin.disableTable(tableName);
    admin.enableTable(tableName);
    admin.balanceSwitch(true);
    admin.balancer();
    int totalNumRegions = 21;
    Thread.sleep(10000);
    List<Pair<byte[], ServerName>> iTableStartKeysAndLocations = null;
    do {
      iTableStartKeysAndLocations = getStartKeysAndLocations(master, indexTableName);

View Full Code Here

Examples of org.apache.hadoop.hbase.client.HBaseAdmin.balancer()

  public static class ForceBalancerAction extends Action {
    @Override
    public void perform() throws Exception {
      LOG.info("Balancing regions");
      HBaseAdmin admin = this.context.getHaseIntegrationTestingUtility().getHBaseAdmin();
      boolean result = admin.balancer();
      if (!result) {
        LOG.error("Balancer didn't succeed");
      }
    }
  }

View Full Code Here

Examples of org.apache.hadoop.hbase.client.HBaseAdmin.balancer()

    }
  }


  protected void forceBalancer() throws Exception {
    HBaseAdmin admin = this.context.getHBaseIntegrationTestingUtility().getHBaseAdmin();
    boolean result = admin.balancer();
    if (!result) {
      LOG.error("Balancer didn't succeed");
    }
  }

View Full Code Here

Examples of org.apache.hadoop.hbase.client.HBaseAdmin.balancer()

  public static class ForceBalancerAction extends Action {
    @Override
    public void perform() throws Exception {
      LOG.info("Balancing regions");
      HBaseAdmin admin = this.context.getHaseIntegrationTestingUtility().getHBaseAdmin();
      boolean result = admin.balancer();
      if (!result) {
        LOG.error("Balancer didn't succeed");
      }
    }
  }

View Full Code Here

0 1

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.