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

Class org.apache.hadoop.hbase.client.HBaseAdmin

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

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.

    }
  }


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

View Full Code Here

  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

        Thread.sleep(2000);


        admin.split(Bytes.toBytes(tableName), Bytes.toBytes(40));
        Thread.sleep(2000);


        admin.balancer();
        Thread.sleep(2000);


        printRegions(tableName);


        sql = "SELECT count(*) FROM SplitTest";

View Full Code Here

          ready = false;
          break;
        }
      }
      if (!ready) {
        admin.balancer();
        Thread.sleep(100);
      }
    }
  }

View Full Code Here

  public static class ForceBalancerAction extends Action {
    @Override
    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

    }
  }


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

View Full Code Here

      }
    }


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

View Full Code Here

  public static class ForceBalancerAction extends Action {
    @Override
    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

  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

    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

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.