1. 包列表
  2. 类列表
  3. org.apache.hadoop.hbase.test.MetricsAssertHelper

Java 类org.apache.hadoop.hbase.test.MetricsAssertHelper 实例源码

项目：ditb    文件：TestRegionServerMetrics.java    
@BeforeClass
public static void startCluster() throws Exception {
  metricsHelper = CompatibilityFactory.getInstance(MetricsAssertHelper.class);
  TEST_UTIL = new HBaseTestingUtility();
  conf = TEST_UTIL.getConfiguration();
  conf.getLong("hbase.splitlog.max.resubmit", 0);
  // Make the failure test faster
  conf.setInt("zookeeper.recovery.retry", 0);
  conf.setInt(HConstants.REGIONSERVER_INFO_PORT, -1);

  TEST_UTIL.startMiniCluster(1, 1);
  cluster = TEST_UTIL.getHBaseCluster();

  cluster.waitForActiveAndReadyMaster();

  while (cluster.getLiveRegionServerThreads().size() < 1) {
    Threads.sleep(100);
  }

  rs = cluster.getRegionServer(0);
  metricsRegionServer = rs.getRegionServerMetrics();
  serverSource = metricsRegionServer.getMetricsSource();
}
项目：ditb    文件：TestRemoveRegionMetrics.java    
@BeforeClass
public static void startCluster() throws Exception {
  metricsHelper = CompatibilityFactory.getInstance(MetricsAssertHelper.class);
  TEST_UTIL = new HBaseTestingUtility();
  conf = TEST_UTIL.getConfiguration();
  conf.getLong("hbase.splitlog.max.resubmit", 0);
  // Make the failure test faster
  conf.setInt("zookeeper.recovery.retry", 0);
  conf.setInt(HConstants.REGIONSERVER_INFO_PORT, -1);

  TEST_UTIL.startMiniCluster(1, 2);
  cluster = TEST_UTIL.getHBaseCluster();

  cluster.waitForActiveAndReadyMaster();

  while (cluster.getLiveRegionServerThreads().size() < 2) {
    Threads.sleep(100);
  }
}
项目：pbase    文件：TestRegionServerMetrics.java    
@BeforeClass
public static void startCluster() throws Exception {
  metricsHelper = CompatibilityFactory.getInstance(MetricsAssertHelper.class);
  TEST_UTIL = new HBaseTestingUtility();
  conf = TEST_UTIL.getConfiguration();
  conf.getLong("hbase.splitlog.max.resubmit", 0);
  // Make the failure test faster
  conf.setInt("zookeeper.recovery.retry", 0);
  conf.setInt(HConstants.REGIONSERVER_INFO_PORT, -1);

  TEST_UTIL.startMiniCluster(1, 1);
  cluster = TEST_UTIL.getHBaseCluster();

  cluster.waitForActiveAndReadyMaster();

  while (cluster.getLiveRegionServerThreads().size() < 1) {
    Threads.sleep(100);
  }

  rs = cluster.getRegionServer(0);
  metricsRegionServer = rs.getRegionServerMetrics();
  serverSource = metricsRegionServer.getMetricsSource();
}
项目：HIndex    文件：TestRegionServerMetrics.java    
@BeforeClass
public static void startCluster() throws Exception {
  metricsHelper = CompatibilityFactory.getInstance(MetricsAssertHelper.class);
  TEST_UTIL = new HBaseTestingUtility();
  conf = TEST_UTIL.getConfiguration();
  conf.getLong("hbase.splitlog.max.resubmit", 0);
  // Make the failure test faster
  conf.setInt("zookeeper.recovery.retry", 0);
  conf.setInt(HConstants.REGIONSERVER_INFO_PORT, -1);

  TEST_UTIL.startMiniCluster(1, 1);
  cluster = TEST_UTIL.getHBaseCluster();

  cluster.waitForActiveAndReadyMaster();

  while (cluster.getLiveRegionServerThreads().size() < 1) {
    Threads.sleep(100);
  }

  rs = cluster.getRegionServer(0);
  metricsRegionServer = rs.getMetrics();
  serverSource = metricsRegionServer.getMetricsSource();
}
项目：hbase    文件：MiniHBaseCluster.java    
/**
 * @param rsPorts Ports that RegionServer should use; pass ports if you want to test cluster
 *   restart where for sure the regionservers come up on same address+port (but
 *   just with different startcode); by default mini hbase clusters choose new
 *   arbitrary ports on each cluster start.
 * @throws IOException
 * @throws InterruptedException
 */
public MiniHBaseCluster(Configuration conf, int numMasters, int numRegionServers,
       List<Integer> rsPorts,
       Class<? extends HMaster> masterClass,
       Class<? extends MiniHBaseCluster.MiniHBaseClusterRegionServer> regionserverClass)
    throws IOException, InterruptedException {
  super(conf);
  conf.set(HConstants.MASTER_PORT, "0");
  if (conf.getInt(HConstants.MASTER_INFO_PORT, 0) != -1) {
    conf.set(HConstants.MASTER_INFO_PORT, "0");
  }

  // Hadoop 2
  CompatibilityFactory.getInstance(MetricsAssertHelper.class).init();

  init(numMasters, numRegionServers, rsPorts, masterClass, regionserverClass);
  this.initialClusterStatus = getClusterStatus();
}
项目：hbase    文件：TestRemoveRegionMetrics.java    
@BeforeClass
public static void startCluster() throws Exception {
  metricsHelper = CompatibilityFactory.getInstance(MetricsAssertHelper.class);
  TEST_UTIL = new HBaseTestingUtility();
  conf = TEST_UTIL.getConfiguration();
  conf.getLong("hbase.splitlog.max.resubmit", 0);
  // Make the failure test faster
  conf.setInt("zookeeper.recovery.retry", 0);
  conf.setInt(HConstants.REGIONSERVER_INFO_PORT, -1);

  TEST_UTIL.startMiniCluster(1, 2);
  cluster = TEST_UTIL.getHBaseCluster();

  cluster.waitForActiveAndReadyMaster();

  while (cluster.getLiveRegionServerThreads().size() < 2) {
    Threads.sleep(100);
  }
}
项目：PyroDB    文件：TestRegionServerMetrics.java    
@BeforeClass
public static void startCluster() throws Exception {
  metricsHelper = CompatibilityFactory.getInstance(MetricsAssertHelper.class);
  TEST_UTIL = new HBaseTestingUtility();
  conf = TEST_UTIL.getConfiguration();
  conf.getLong("hbase.splitlog.max.resubmit", 0);
  // Make the failure test faster
  conf.setInt("zookeeper.recovery.retry", 0);
  conf.setInt(HConstants.REGIONSERVER_INFO_PORT, -1);

  TEST_UTIL.startMiniCluster(1, 1);
  cluster = TEST_UTIL.getHBaseCluster();

  cluster.waitForActiveAndReadyMaster();

  while (cluster.getLiveRegionServerThreads().size() < 1) {
    Threads.sleep(100);
  }

  rs = cluster.getRegionServer(0);
  metricsRegionServer = rs.getRegionServerMetrics();
  serverSource = metricsRegionServer.getMetricsSource();
}
项目：c5    文件：TestRegionServerMetrics.java    
@BeforeClass
public static void startCluster() throws Exception {
  metricsHelper = CompatibilityFactory.getInstance(MetricsAssertHelper.class);
  TEST_UTIL = new HBaseTestingUtility();
  conf = TEST_UTIL.getConfiguration();
  conf.getLong("hbase.splitlog.max.resubmit", 0);
  // Make the failure test faster
  conf.setInt("zookeeper.recovery.retry", 0);
  conf.setInt(HConstants.REGIONSERVER_INFO_PORT, -1);

  TEST_UTIL.startMiniCluster(1, 1);
  cluster = TEST_UTIL.getHBaseCluster();

  cluster.waitForActiveAndReadyMaster();

  while (cluster.getLiveRegionServerThreads().size() < 1) {
    Threads.sleep(100);
  }

  rs = cluster.getRegionServer(0);
  metricsRegionServer = rs.getMetrics();
  serverSource = metricsRegionServer.getMetricsSource();
}
项目：DominoHBase    文件：TestRegionServerMetrics.java    
@BeforeClass
public static void startCluster() throws Exception {
  metricsHelper = CompatibilityFactory.getInstance(MetricsAssertHelper.class);
  TEST_UTIL = new HBaseTestingUtility();
  conf = TEST_UTIL.getConfiguration();
  conf.getLong("hbase.splitlog.max.resubmit", 0);
  // Make the failure test faster
  conf.setInt("zookeeper.recovery.retry", 0);
  conf.setInt(HConstants.REGIONSERVER_INFO_PORT, -1);

  TEST_UTIL.startMiniCluster(1, 1);
  cluster = TEST_UTIL.getHBaseCluster();

  cluster.waitForActiveAndReadyMaster();

  while (cluster.getLiveRegionServerThreads().size() < 1) {
    Threads.sleep(100);
  }

  rs = cluster.getRegionServer(0);
  metricsRegionServer = rs.getMetrics();
  serverSource = metricsRegionServer.getMetricsSource();
}
项目：ditb    文件：MiniHBaseCluster.java    
public MiniHBaseCluster(Configuration conf, int numMasters, int numRegionServers,
       Class<? extends HMaster> masterClass,
       Class<? extends MiniHBaseCluster.MiniHBaseClusterRegionServer> regionserverClass)
    throws IOException, InterruptedException {
  super(conf);
  conf.set(HConstants.MASTER_PORT, "0");

  // Hadoop 2
  CompatibilityFactory.getInstance(MetricsAssertHelper.class).init();

  init(numMasters, numRegionServers, masterClass, regionserverClass);
  this.initialClusterStatus = getClusterStatus();
}
项目：pbase    文件：MiniHBaseCluster.java    
public MiniHBaseCluster(Configuration conf, int numMasters, int numRegionServers,
       Class<? extends HMaster> masterClass,
       Class<? extends MiniHBaseCluster.MiniHBaseClusterRegionServer> regionserverClass)
    throws IOException, InterruptedException {
  super(conf);
  conf.set(HConstants.MASTER_PORT, "0");

  // Hadoop 2
  CompatibilityFactory.getInstance(MetricsAssertHelper.class).init();

  init(numMasters, numRegionServers, masterClass, regionserverClass);
  this.initialClusterStatus = getClusterStatus();
}
项目：HIndex    文件：MiniHBaseCluster.java    
public MiniHBaseCluster(Configuration conf, int numMasters, int numRegionServers,
       Class<? extends HMaster> masterClass,
       Class<? extends MiniHBaseCluster.MiniHBaseClusterRegionServer> regionserverClass)
    throws IOException, InterruptedException {
  super(conf);
  conf.set(HConstants.MASTER_PORT, "0");

  // Hadoop 2
  CompatibilityFactory.getInstance(MetricsAssertHelper.class).init();

  init(numMasters, numRegionServers, masterClass, regionserverClass);
  this.initialClusterStatus = getClusterStatus();
}
项目：hbase    文件：TestRegionServerMetrics.java    
@BeforeClass
public static void startCluster() throws Exception {
  metricsHelper = CompatibilityFactory.getInstance(MetricsAssertHelper.class);
  TEST_UTIL = new HBaseTestingUtility();
  TABLES_ON_MASTER = LoadBalancer.isTablesOnMaster(TEST_UTIL.getConfiguration());
  conf = TEST_UTIL.getConfiguration();
  conf.getLong("hbase.splitlog.max.resubmit", 0);
  // Make the failure test faster
  conf.setInt("zookeeper.recovery.retry", 0);
  // testMobMetrics creates few hfiles and manages compaction manually.
  conf.setInt("hbase.hstore.compactionThreshold", 100);
  conf.setInt("hbase.hstore.compaction.max", 100);
  conf.setInt(HConstants.REGIONSERVER_INFO_PORT, -1);

  TEST_UTIL.startMiniCluster(1, 1);
  cluster = TEST_UTIL.getHBaseCluster();
  cluster.waitForActiveAndReadyMaster();
  admin = TEST_UTIL.getAdmin();
  connection = TEST_UTIL.getConnection();

  while (cluster.getLiveRegionServerThreads().isEmpty() &&
      cluster.getRegionServer(0) == null &&
      rs.getRegionServerMetrics() == null) {
    Threads.sleep(100);
  }
  rs = cluster.getRegionServer(0);
  metricsRegionServer = rs.getRegionServerMetrics();
  serverSource = metricsRegionServer.getMetricsSource();
}
项目：PyroDB    文件：MiniHBaseCluster.java    
public MiniHBaseCluster(Configuration conf, int numMasters, int numRegionServers,
       Class<? extends HMaster> masterClass,
       Class<? extends MiniHBaseCluster.MiniHBaseClusterRegionServer> regionserverClass)
    throws IOException, InterruptedException {
  super(conf);
  conf.set(HConstants.MASTER_PORT, "0");

  // Hadoop 2
  CompatibilityFactory.getInstance(MetricsAssertHelper.class).init();

  init(numMasters, numRegionServers, masterClass, regionserverClass);
  this.initialClusterStatus = getClusterStatus();
}
项目：c5    文件：MiniHBaseCluster.java    
public MiniHBaseCluster(Configuration conf, int numMasters, int numRegionServers,
       Class<? extends HMaster> masterClass,
       Class<? extends MiniHBaseCluster.MiniHBaseClusterRegionServer> regionserverClass)
    throws IOException, InterruptedException {
  super(conf);
  conf.set(HConstants.MASTER_PORT, "0");

  // Hadoop 2
  CompatibilityFactory.getInstance(MetricsAssertHelper.class).init();

  init(numMasters, numRegionServers, masterClass, regionserverClass);
  this.initialClusterStatus = getClusterStatus();
}