Java 类org.apache.hadoop.hbase.regionserver.HRegionServer 实例源码

项目：ditb 文件：BaseRunner.java

public void init(String additionalConf) throws IOException {
  configuration = HBaseConfiguration.create();
  HRegionServer.loadWinterConf(configuration, additionalConf);
  conn = ConnectionFactory.createConnection(configuration);
  IndexTableRelation relation;
  if (IndexType.isUserDefinedIndex(indexType))
    relation = getUserDefinedIndexTableRelation(tableName, indexType);
  else relation = getRegularIndexTableRelation(tableName, indexType);
  admin = new IndexTableAdmin(configuration, conn, relation);
  if (indexType == IndexType.LCIndex) admin.setLCIndexRange(getLCIndexRangeStr());
  //    admin.createTable(false, false);

  byte[][] splits = new byte[10][];
  for (int i = 0; i < 10; i++) {
    splits[i] = Bytes.toBytes(i * 1000);
  }
  admin.createTable(true, true, splits);
}

项目：ditb 文件：AbstractWorkload.java

public AbstractWorkload(String descFilePath) throws IOException {
  this.descFilePath = descFilePath;
  // load parameters from descFile
  paramMap = new HashMap<>();
  loadParamsFromFile();
  // init params
  nbRegion = loadIntParam("region.number", 10);
  nbLCStatRange = loadIntParam("lcindex.range.number", 1000);
  scanFilterDir = loadStringParam("scan.filter.dir", "/tmp/should-assign");
  scanRunTimes = loadIntParam("scan.run.times", 1);
  scanCacheSize = loadIntParam("scan.cache.size", 100);
  mdBucketThreshold = loadIntParam("md.bucket.threshold", 1000);
  tableName = TableName.valueOf(loadStringParam("table.name", "tbl_x"));
  nbTotalColumns = loadIntParam("total.columns.number", 20);
  nbExistingRows = loadIntParam("number.existing.rows", 100);
  skipFilterPrefix = loadStringParam("skip.filter.prefix", "skip");
  // init hbase conf
  conf = HBaseConfiguration.create();
  if (paramMap.containsKey("hbase.conf.path")) conf.addResource(paramMap.get("hbase.conf.path"));
  if (paramMap.containsKey("hbase.conf.path.additional"))
    HRegionServer.loadWinterConf(conf, paramMap.get("hbase.conf.path.additional"));
}

项目：ditb 文件：LocalHBaseCluster.java

@SuppressWarnings("unchecked")
public JVMClusterUtil.RegionServerThread addRegionServer(
    Configuration config, final int index)
throws IOException {
  // Create each regionserver with its own Configuration instance so each has
  // its HConnection instance rather than share (see HBASE_INSTANCES down in
  // the guts of HConnectionManager.

  // Also, create separate CoordinatedStateManager instance per Server.
  // This is special case when we have to have more than 1 CoordinatedStateManager
  // within 1 process.
  CoordinatedStateManager cp = CoordinatedStateManagerFactory.getCoordinatedStateManager(conf);

  JVMClusterUtil.RegionServerThread rst =
      JVMClusterUtil.createRegionServerThread(config, cp, (Class<? extends HRegionServer>) conf
          .getClass(HConstants.REGION_SERVER_IMPL, this.regionServerClass), index);

  this.regionThreads.add(rst);
  return rst;
}

项目：ditb 文件：ServerManager.java

/**
  * @param sn
  * @return Admin interface for the remote regionserver named <code>sn</code>
  * @throws IOException
  * @throws RetriesExhaustedException wrapping a ConnectException if failed
  */
private AdminService.BlockingInterface getRsAdmin(final ServerName sn)
throws IOException {
  AdminService.BlockingInterface admin = this.rsAdmins.get(sn);
  if (admin == null) {
    LOG.debug("New admin connection to " + sn.toString());
    if (sn.equals(master.getServerName()) && master instanceof HRegionServer) {
      // A master is also a region server now, see HBASE-10569 for details
      admin = ((HRegionServer)master).getRSRpcServices();
    } else {
      admin = this.connection.getAdmin(sn);
    }
    this.rsAdmins.put(sn, admin);
  }
  return admin;
}

项目：ditb 文件：JVMClusterUtil.java

/**
 * Creates a {@link RegionServerThread}.
 * Call 'start' on the returned thread to make it run.
 * @param c Configuration to use.
 * @param cp consensus provider to use
 * @param hrsc Class to create.
 * @param index Used distinguishing the object returned.
 * @throws IOException
 * @return Region server added.
 */
public static JVMClusterUtil.RegionServerThread createRegionServerThread(
    final Configuration c, CoordinatedStateManager cp, final Class<? extends HRegionServer> hrsc,
    final int index)
throws IOException {
  HRegionServer server;
  try {

    Constructor<? extends HRegionServer> ctor = hrsc.getConstructor(Configuration.class,
    CoordinatedStateManager.class);
    ctor.setAccessible(true);
    server = ctor.newInstance(c, cp);
  } catch (InvocationTargetException ite) {
    Throwable target = ite.getTargetException();
    throw new RuntimeException("Failed construction of RegionServer: " +
      hrsc.toString() + ((target.getCause() != null)?
        target.getCause().getMessage(): ""), target);
  } catch (Exception e) {
    IOException ioe = new IOException();
    ioe.initCause(e);
    throw ioe;
  }
  return new JVMClusterUtil.RegionServerThread(server, index);
}

项目：ditb 文件：TestMasterReplication.java

@Test(timeout = 180000, expected = ServiceException.class)
public void testReplicateWALEntryWhenReplicationIsDisabled() throws Exception {
  LOG.info("testSimplePutDelete");
  baseConfiguration.setBoolean(HConstants.REPLICATION_ENABLE_KEY, false);
  Table[] htables = null;
  try {
    startMiniClusters(1);
    createTableOnClusters(table);
    htables = getHTablesOnClusters(tableName);

    HRegionServer rs = utilities[0].getRSForFirstRegionInTable(tableName);
    RSRpcServices rsrpc = new RSRpcServices(rs);
    rsrpc.replicateWALEntry(null, null);
  } finally {
    close(htables);
    shutDownMiniClusters();
  }
}

项目：ditb 文件：TestScannerTimeout.java

/**
 * Test that scanner can continue even if the region server it was reading
 * from failed. Before 2772, it reused the same scanner id.
 * @throws Exception
 */
@Test(timeout=300000)
public void test2772() throws Exception {
  LOG.info("START************ test2772");
  HRegionServer rs = TEST_UTIL.getRSForFirstRegionInTable(TABLE_NAME);
  Scan scan = new Scan();
  // Set a very high timeout, we want to test what happens when a RS
  // fails but the region is recovered before the lease times out.
  // Since the RS is already created, this conf is client-side only for
  // this new table
  Configuration conf = new Configuration(TEST_UTIL.getConfiguration());
  conf.setInt(HConstants.HBASE_CLIENT_SCANNER_TIMEOUT_PERIOD, SCANNER_TIMEOUT * 100);
  Table higherScanTimeoutTable = new HTable(conf, TABLE_NAME);
  ResultScanner r = higherScanTimeoutTable.getScanner(scan);
  // This takes way less than SCANNER_TIMEOUT*100
  rs.abort("die!");
  Result[] results = r.next(NB_ROWS);
  assertEquals(NB_ROWS, results.length);
  r.close();
  higherScanTimeoutTable.close();
  LOG.info("END ************ test2772");

}