Examples of org.apache.hadoop.hbase.HBaseTestingUtility.startMiniCluster()

Class org.apache.hadoop.hbase.HBaseTestingUtility

Examples of org.apache.hadoop.hbase.HBaseTestingUtility.startMiniCluster()

org.apache.hadoop.hbase.HBaseTestingUtility.startMiniCluster()
Start up a minicluster of hbase, dfs, and zookeeper. @throws Exception @return Mini hbase cluster instance created. @see {@link #shutdownMiniDFSCluster()}

    Configuration conf = HBaseConfiguration.create();
    conf.setBoolean("hbase.assignment.usezk", false);


    // Start the cluster
    HBaseTestingUtility TEST_UTIL = new HBaseTestingUtility(conf);
    TEST_UTIL.startMiniCluster(NUM_MASTERS, NUM_RS);
    MiniHBaseCluster cluster = TEST_UTIL.getHBaseCluster();
    log("Cluster started");


    // get all the master threads
    List<MasterThread> masterThreads = cluster.getMasterThreads();

View Full Code Here

    htu.getConfiguration().setInt("dfs.replication", 1);
    htu.getConfiguration().setLong("hbase.hregion.max.filesize", 322122547200L);
    MiniHBaseCluster cluster = null;


    try {
      cluster = htu.startMiniCluster(1, regionServersCount, dataNodeHosts);
      byte [][] families = {cf_essential, cf_joined};


      TableName tableName = TableName.valueOf(this.getClass().getSimpleName());
      HTableDescriptor desc = new HTableDescriptor(tableName);
      for(byte[] family : families) {

View Full Code Here

    conf.setClass("hbase.coprocessor.regionserver.classes", CPRegionServerObserver.class,
      RegionServerObserver.class);


    // Start the cluster
    HBaseTestingUtility TEST_UTIL = new HBaseTestingUtility(conf);
    TEST_UTIL.startMiniCluster(NUM_MASTERS, NUM_RS);
    Admin admin = new HBaseAdmin(conf);
    try {
      MiniHBaseCluster cluster = TEST_UTIL.getHBaseCluster();
      HRegionServer regionServer = cluster.getRegionServer(0);
      RegionServerCoprocessorHost cpHost = regionServer.getRegionServerCoprocessorHost();

View Full Code Here


  @BeforeClass
  public static void setUp() throws Exception {
    HBaseTestingUtility util = new HBaseTestingUtility();


    util.startMiniCluster(1);


    Admin admin = util.getHBaseAdmin();
    destroy(admin, HBASE_TABLE_NAME);
    create(admin, HBASE_TABLE_NAME, FAMILY_A, FAMILY_B);
    admin.close();

View Full Code Here

    log("Starting cluster");
    Configuration conf = HBaseConfiguration.create();
    conf.setInt("hbase.master.assignment.timeoutmonitor.period", 2000);
    conf.setInt("hbase.master.assignment.timeoutmonitor.timeout", 5000);
    HBaseTestingUtility TEST_UTIL = new HBaseTestingUtility(conf);
    TEST_UTIL.startMiniCluster(NUM_MASTERS, NUM_RS);
    MiniHBaseCluster cluster = TEST_UTIL.getHBaseCluster();
    log("Waiting for active/ready master");
    cluster.waitForActiveAndReadyMaster();
    ZooKeeperWatcher zkw = new ZooKeeperWatcher(conf, "testRollingRestart",
        null);

View Full Code Here

    conf.setInt("hbase.master.wait.on.regionservers.mintostart", 3);
    conf.setInt("hbase.master.wait.on.regionservers.maxtostart", 3);


    // Start the cluster
    HBaseTestingUtility TEST_UTIL = new HBaseTestingUtility(conf);
    TEST_UTIL.startMiniCluster(NUM_MASTERS, NUM_RS);
    MiniHBaseCluster cluster = TEST_UTIL.getHBaseCluster();


    // get all the master threads
    List<MasterThread> masterThreads = cluster.getMasterThreads();

View Full Code Here

    conf.setInt("hbase.master.wait.on.regionservers.mintostart", 3);
    conf.setInt("hbase.master.wait.on.regionservers.maxtostart", 3);


    // Start the cluster
    HBaseTestingUtility TEST_UTIL = new HBaseTestingUtility(conf);
    TEST_UTIL.startMiniCluster(NUM_MASTERS, NUM_RS);
    MiniHBaseCluster cluster = TEST_UTIL.getHBaseCluster();
    log("Cluster started");


    // Create a ZKW to use in the test
    ZooKeeperWatcher zkw = new ZooKeeperWatcher(TEST_UTIL.getConfiguration(),

View Full Code Here

    conf.setInt("hbase.master.wait.on.regionservers.mintostart", 1);
    conf.setInt("hbase.master.wait.on.regionservers.maxtostart", 2);


    // Create and start the cluster
    HBaseTestingUtility TEST_UTIL = new HBaseTestingUtility(conf);
    TEST_UTIL.startMiniCluster(NUM_MASTERS, NUM_RS);
    MiniHBaseCluster cluster = TEST_UTIL.getHBaseCluster();
    log("Cluster started");


    // Create a ZKW to use in the test
    ZooKeeperWatcher zkw = new ZooKeeperWatcher(TEST_UTIL.getConfiguration(),

View Full Code Here


    // make sure everything is setup correctly
    IndexManagementUtil.ensureMutableIndexingCorrectlyConfigured(conf);


    // start the cluster with 2 rs
    util.startMiniCluster(2);


    HBaseAdmin admin = util.getHBaseAdmin();
    // setup the index
    byte[] family = Bytes.toBytes("family");
    byte[] qual = Bytes.toBytes("qualifier");

View Full Code Here

      // start the minicluster
      HBaseTestingUtility util = new HBaseTestingUtility(conf);
      // set replication required parameter
      ConfigUtil.setReplicationConfigIfAbsent(conf);
      try {
          util.startMiniCluster();


          // setup the primary table
          @SuppressWarnings("deprecation")
          HTableDescriptor desc = new HTableDescriptor(
                  "testDoesNotStartRegionServerForUnsupportedCompressionAndVersion");

View Full Code Here

0 1 2 3 4 5 6 7 8 9

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.