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

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

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

org.apache.hadoop.hbase.client.HBaseAdmin.move()
Move the region r to dest. @param encodedRegionName The encoded region name; i.e. the hash that makesup the region name suffix: e.g. if regionname is TestTable,0094429456,1289497600452.527db22f95c8a9e0116f0cc13c680396., then the encoded region name is: 527db22f95c8a9e0116f0cc13c680396. @param destServerName The servername of the destination regionserver. Ifpassed the empty byte array we'll assign to a random server. A server name is made of host, port and startcode. Here is an example: host187.example.com,60020,1289493121758 @throws UnknownRegionException Thrown if we can't find a region namedencodedRegionName @throws ZooKeeperConnectionException @throws MasterNotRunningException

      public Object run() throws Exception {
        HBaseAdmin admin = new HBaseAdmin(conf);
        List<HRegionInfo> tableRegions = admin.getTableRegions(Bytes.toBytes("testMoveRegionOp"));
        if (tableRegions.size() > 0) {
          HRegionInfo regionMoved = tableRegions.get(0);
          admin.move(regionMoved.getEncodedNameAsBytes(), null);
        }
        return null;
      }
    };

View Full Code Here

        HBaseAdmin admin = new HBaseAdmin(conf);
        List<HRegionInfo> tableRegions =
            admin.getTableRegions(Bytes.toBytes("testMoveRegionOp_idx"));
        if (tableRegions.size() > 0) {
          HRegionInfo regionMoved = tableRegions.get(0);
          admin.move(regionMoved.getEncodedNameAsBytes(), null);
        }
        return null;
      }
    };

View Full Code Here


    List<byte[]> regions2 = UTIL.getMetaTableRows(Bytes.toBytes(userTableName2 + "_idx"));
    List<byte[]> regionsEncod2 = getEncodedNames(regions2);


    for (int i = 0; i < 2; i++) {
      admin.move(regionsEncod.get(i), null);
      admin.move(regionsEncod1.get(i), null);
      admin.move(regionsEncod2.get(i), null);
    }


    ZKAssign.blockUntilNoRIT(zkw);

View Full Code Here

    List<byte[]> regions2 = UTIL.getMetaTableRows(Bytes.toBytes(userTableName2 + "_idx"));
    List<byte[]> regionsEncod2 = getEncodedNames(regions2);


    for (int i = 0; i < 2; i++) {
      admin.move(regionsEncod.get(i), null);
      admin.move(regionsEncod1.get(i), null);
      admin.move(regionsEncod2.get(i), null);
    }


    ZKAssign.blockUntilNoRIT(zkw);
    SecondaryIndexColocator colocator = new SecondaryIndexColocator(config);

View Full Code Here

    List<byte[]> regionsEncod2 = getEncodedNames(regions2);


    for (int i = 0; i < 2; i++) {
      admin.move(regionsEncod.get(i), null);
      admin.move(regionsEncod1.get(i), null);
      admin.move(regionsEncod2.get(i), null);
    }


    ZKAssign.blockUntilNoRIT(zkw);
    SecondaryIndexColocator colocator = new SecondaryIndexColocator(config);
    colocator.setUp();

View Full Code Here

    cluster.getRegionServer(1).getServerName();
    Random random = new Random();
    for (HRegionInfo hRegionInfo : tableRegions) {
      int regionNumber = random.nextInt(numRegions);
      ServerName serverName = cluster.getRegionServer(regionNumber).getServerName();
      admin.move(hRegionInfo.getEncodedNameAsBytes(), Bytes.toBytes(serverName.getServerName()));
    }
    ZKAssign.blockUntilNoRIT(zkw);
    boolean isRegionColocated =
        checkForColocation(master, "testRegionMove", "testRegionMove"
            + Constants.INDEX_TABLE_SUFFIX);

View Full Code Here

        Random random = new Random();
        for (HRegionInfo regionInfo:regions) {
          try {
            byte[] destServerName =
              Bytes.toBytes(servers[random.nextInt(servers.length)].getServerName());
            admin.move(regionInfo.getRegionName(), destServerName);
          } catch (Exception e) {
            LOG.debug("Error moving region", e);
          }
        }
        Thread.sleep(sleepTime);

View Full Code Here

      LOG.info("Moving " + victimRegions.size() + " regions from " + victimServers.size()
          + " servers to " + targetServers.size() + " different servers");
      HBaseAdmin admin = this.context.getHaseIntegrationTestingUtility().getHBaseAdmin();
      for (byte[] victimRegion : victimRegions) {
        int targetIx = random.nextInt(targetServers.size());
        admin.move(victimRegion, targetServers.get(targetIx));
      }
    }
  }


  public static class ForceBalancerAction extends Action {

View Full Code Here

        && !destServerName.equals(serverName));


      TEST_UTIL.deleteTable(table);


      try {
        admin.move(hri.getEncodedNameAsBytes(),
          Bytes.toBytes(destServerName.getServerName()));
        fail("We should not find the region");
      } catch (IOException ioe) {
        assertTrue(ioe instanceof UnknownRegionException);
      }

View Full Code Here

        assertTrue(rsToBeKilled != null);
        
        regions = admin.getTableRegions(indexTable);
        final HRegionInfo indexRegion = regions.get(0);
        final ServerName dstRS = rsToBeKilled;
        admin.move(indexRegion.getEncodedNameAsBytes(), Bytes.toBytes(rsToBeKilled.getServerName()));
        this.util.waitFor(30000, 200, new Waiter.Predicate<Exception>() {
            @Override
            public boolean evaluate() throws Exception {
              ServerName sn = cluster.getServerHoldingRegion(indexRegion.getRegionName());
              return (sn != null && sn.equals(dstRS));

View Full Code Here

0 1 2 3 4 5

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.