org.apache.hadoop.hbase.HBaseTestingUtility.shutdownMiniMapReduceCluster()方法的使用及代码示例

x33g5p2x  于2022-01-20 转载在 其他  
字(2.9k)|赞(0)|评价(0)|浏览(129)

本文整理了Java中org.apache.hadoop.hbase.HBaseTestingUtility.shutdownMiniMapReduceCluster()方法的一些代码示例,展示了HBaseTestingUtility.shutdownMiniMapReduceCluster()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。HBaseTestingUtility.shutdownMiniMapReduceCluster()方法的具体详情如下:
包路径:org.apache.hadoop.hbase.HBaseTestingUtility
类名称:HBaseTestingUtility
方法名:shutdownMiniMapReduceCluster

HBaseTestingUtility.shutdownMiniMapReduceCluster介绍

[英]Stops the previously started MiniMRCluster.
[中]停止以前启动的MiniMRCluster

代码示例

代码示例来源:origin: apache/hbase

@AfterClass
public static void tearDownAfterClass() throws Exception {
 TEST_UTIL.shutdownMiniMapReduceCluster();
 TEST_UTIL.shutdownMiniCluster();
}

代码示例来源:origin: apache/hbase

hbt.shutdownMiniMapReduceCluster();

代码示例来源:origin: apache/hbase

/**
 * @throws Exception if deleting the archive directory or shutting down the mini cluster fails
 */
@AfterClass
public static void tearDown() throws Exception {
 try{
  SnapshotTestingUtils.deleteAllSnapshots(TEST_UTIL.getHBaseAdmin());
 } catch (Exception e) {
 }
 SnapshotTestingUtils.deleteArchiveDirectory(TEST_UTIL);
 if (useSecondCluster) {
  TEST_UTIL2.shutdownMiniCluster();
 }
 TEST_UTIL.shutdownMiniCluster();
 TEST_UTIL.shutdownMiniMapReduceCluster();
}

代码示例来源:origin: KylinOLAP/Kylin

/**
 * Shutdown the minicluster; 
 */
public static void shutdownMiniCluster() {
  logger.info("Going to shutdown mini cluster.");
  try {
    UTIL.shutdownMiniMapReduceCluster();
  } catch (Exception e) {
    e.printStackTrace();
  }
  try {
    UTIL.shutdownMiniCluster();
  } catch (Exception e) {
    e.printStackTrace();
  }
}

代码示例来源:origin: apache/phoenix

@Override
  public Void call() throws Exception {
    long startTime = System.currentTimeMillis();
    if (u != null) {
      try {
        u.shutdownMiniMapReduceCluster();
      } catch (Throwable t) {
        logger.error(
          "Exception caught when shutting down mini map reduce cluster", t);
      } finally {
        try {
          u.shutdownMiniCluster();
        } catch (Throwable t) {
          logger.error("Exception caught when shutting down mini cluster", t);
        } finally {
          try {
            ConnectionFactory.shutdown();
          } finally {
            logger.info(
              "Time in seconds spent in shutting down mini cluster with "
                  + numTables + " tables: "
                  + (System.currentTimeMillis() - startTime) / 1000);
          }
        }
      }
    }
    return null;
  }
});

代码示例来源:origin: KylinOLAP/Kylin

testUtil.shutdownMiniMapReduceCluster();
testUtil.shutdownMiniCluster();

代码示例来源:origin: com.aliyun.hbase/alihbase-mapreduce

@AfterClass
public static void tearDownAfterClass() throws Exception {
 TEST_UTIL.shutdownMiniMapReduceCluster();
 TEST_UTIL.shutdownMiniCluster();
}

代码示例来源:origin: XiaoMi/themis

@AfterClass
 public static void tearDownAfterClass() throws Exception {
  TransactionTestBase.tearDownAfterClass();
  if (TEST_UTIL != null) {
   TEST_UTIL.shutdownMiniMapReduceCluster();
  }
 }
}

代码示例来源:origin: org.apache.hbase/hbase-mapreduce

@AfterClass
public static void tearDownAfterClass() throws Exception {
 TEST_UTIL.shutdownMiniMapReduceCluster();
 TEST_UTIL.shutdownMiniCluster();
}

代码示例来源:origin: com.aliyun.hbase/alihbase-mapreduce

hbt.shutdownMiniMapReduceCluster();

代码示例来源:origin: org.apache.hbase/hbase-mapreduce

hbt.shutdownMiniMapReduceCluster();

相关文章

HBaseTestingUtility类方法