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

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

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

org.apache.hadoop.hbase.client.HBaseAdmin.split()
Split a table or an individual region. Asynchronous operation. @param tableNameOrRegionName table or region to split @throws IOException if a remote or network exception occurs @throws InterruptedException

    List<HRegionInfo> regionsOfTable1 =
        UTIL.getMiniHBaseCluster().getMaster().getAssignmentManager()
            .getRegionsOfTable(userTableName.getBytes());
    HRegionInfo hRegionInfo1 = regionsOfTable1.get(0);


    admin.split(hRegionInfo1.getRegionName(), "row3".getBytes());
    List<HRegionInfo> mainTableRegions1 =
        UTIL.getMiniHBaseCluster().getMaster().getAssignmentManager()
            .getRegionsOfTable(userTableName.getBytes());


    List<HRegionInfo> indexTableRegions1 =

View Full Code Here

            byte[] tableName = Bytes.toBytes(ATABLE_NAME);
            admin = conn.unwrap(PhoenixConnection.class).getQueryServices().getAdmin();
            HTable htable = (HTable)conn.unwrap(PhoenixConnection.class).getQueryServices().getTable(tableName);
            htable.clearRegionCache();
            int nRegions = htable.getRegionLocations().size();
            admin.split(tableName, ByteUtil.concat(Bytes.toBytes(tenantId), Bytes.toBytes("00A" + Character.valueOf((char)('3' + nextRunCount()))+ ts))); // vary split point with test run
            int retryCount = 0;
            do {
                Thread.sleep(2000);
                retryCount++;
                //htable.clearRegionCache();

View Full Code Here


          // we have a good region, time to split!
          byte[] split = dr.getSecond();
          LOG.debug("Splitting at " + splitAlgo.rowToStr(split));
          HBaseAdmin admin = new HBaseAdmin(table.getConfiguration());
          admin.split(table.getTableName(), split);


          LinkedList<Pair<byte[], byte[]>> finished = Lists.newLinkedList();
          LinkedList<Pair<byte[], byte[]>> local_finished = Lists.newLinkedList();
          if (conf.getBoolean("split.verify", true)) {
            // we need to verify and rate-limit our splits

View Full Code Here


          // we have a good region, time to split!
          byte[] split = dr.getSecond();
          LOG.debug("Splitting at " + splitAlgo.rowToStr(split));
          HBaseAdmin admin = new HBaseAdmin(table.getConfiguration());
          admin.split(table.getTableName(), split);


          LinkedList<Pair<byte[], byte[]>> finished = Lists.newLinkedList();
          LinkedList<Pair<byte[], byte[]>> local_finished = Lists.newLinkedList();
          if (conf.getBoolean("split.verify", true)) {
            // we need to verify and rate-limit our splits

View Full Code Here

      HRegionInfo hri = location.getRegionInfo();


      // do a regular split
      HBaseAdmin admin = TEST_UTIL.getHBaseAdmin();
      byte[] regionName = location.getRegionInfo().getRegionName();
      admin.split(location.getRegionInfo().getRegionName(), Bytes.toBytes("BM"));
      TestEndToEndSplitTransaction.blockUntilRegionSplit(
          TEST_UTIL.getConfiguration(), 60000, regionName, true);


      // TODO: fixHdfsHoles does not work against splits, since the parent dir lingers on
      // for some time until children references are deleted. HBCK erroneously sees this as

View Full Code Here

      HRegionInfo hri = location.getRegionInfo();


      // do a regular split
      HBaseAdmin admin = TEST_UTIL.getHBaseAdmin();
      byte[] regionName = location.getRegionInfo().getRegionName();
      admin.split(location.getRegionInfo().getRegionName(), Bytes.toBytes("BM"));
      TestEndToEndSplitTransaction.blockUntilRegionSplit(
          TEST_UTIL.getConfiguration(), 60000, regionName, true);


      PairOfSameType<HRegionInfo> daughters = HRegionInfo.getDaughterRegions(meta.get(new Get(regionName)));

View Full Code Here

          // we have a good region, time to split!
          byte[] split = dr.getSecond();
          LOG.debug("Splitting at " + splitAlgo.rowToStr(split));
          HBaseAdmin admin = new HBaseAdmin(table.getConfiguration());
          try {
            admin.split(table.getTableName(), split);
          } finally {
            admin.close();
          }


          LinkedList<Pair<byte[], byte[]>> finished = Lists.newLinkedList();

View Full Code Here

    table.flushCommits();
    // get the initial layout (should just be one region)
    Map<HRegionInfo,HServerAddress> m = table.getRegionsInfo();
    assertEquals(m.size(), 1);
    // tell the master to split the table
    admin.split(TABLE);
    // give some time for the split to happen
    try {
      Thread.sleep(15 * 1000);
    } catch (InterruptedException e) {
      LOG.warn(StringUtils.stringifyException(e));

View Full Code Here

            byte[] tableName = Bytes.toBytes(ATABLE_NAME);
            admin = conn.unwrap(PhoenixConnection.class).getQueryServices().getAdmin();
            HTable htable = (HTable) conn.unwrap(PhoenixConnection.class).getQueryServices().getTable(tableName);
            htable.clearRegionCache();
            int nRegions = htable.getRegionLocations().size();
            admin.split(tableName, ByteUtil.concat(Bytes.toBytes(tenantId), Bytes.toBytes("00A" + Character.valueOf((char) ('3' + nextRunCount())) + ts))); // vary split point with test run
            int retryCount = 0;
            do {
                Thread.sleep(2000);
                retryCount++;
                //htable.clearRegionCache();

View Full Code Here

            
            HBaseAdmin admin = driver.getConnectionQueryServices(getUrl(), TestUtil.TEST_PROPERTIES).getAdmin();
            HMaster master = getUtility().getHBaseCluster().getMaster();
            for (int i = 1; i < 5; i++) {
                
                admin.split(Bytes.toBytes(DATA_TABLE_NAME), ByteUtil.concat(Bytes.toBytes(strings[3*i])));
                List<HRegionInfo> regionsOfUserTable =
                        master.getAssignmentManager().getRegionStates().getRegionsOfTable(TableName.valueOf(DATA_TABLE_NAME));


                while (regionsOfUserTable.size() != (4+i)) {
                    Thread.sleep(100);

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.