本文整理了Java中org.apache.hadoop.hbase.HBaseTestingUtility.shutdownMiniMapReduceCluster()
方法的一些代码示例,展示了HBaseTestingUtility.shutdownMiniMapReduceCluster()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。HBaseTestingUtility.shutdownMiniMapReduceCluster()
方法的具体详情如下:
包路径:org.apache.hadoop.hbase.HBaseTestingUtility
类名称: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();
内容来源于网络,如有侵权,请联系作者删除!