本文整理了Java中org.apache.hadoop.hbase.HBaseTestingUtility.cleanupDataTestDirOnTestFS()
方法的一些代码示例,展示了HBaseTestingUtility.cleanupDataTestDirOnTestFS()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。HBaseTestingUtility.cleanupDataTestDirOnTestFS()
方法的具体详情如下:
包路径:org.apache.hadoop.hbase.HBaseTestingUtility
类名称:HBaseTestingUtility
方法名:cleanupDataTestDirOnTestFS
[英]Cleans the test data directory on the test filesystem.
[中]清除测试文件系统上的测试数据目录。
代码示例来源:origin: apache/hbase
@AfterClass
public static void afterClass() throws Exception {
TEST_UTIL.cleanupDataTestDirOnTestFS();
TEST_UTIL.shutdownMiniCluster();
}
代码示例来源:origin: apache/hbase
util.cleanupDataTestDirOnTestFS(table.getNameAsString());
代码示例来源:origin: apache/hbase
util.cleanupDataTestDirOnTestFS(table);
代码示例来源:origin: apache/hbase
util.cleanupDataTestDirOnTestFS(table.getNameAsString());
代码示例来源:origin: apache/hbase
util.cleanupDataTestDirOnTestFS(table.getNameAsString());
代码示例来源:origin: apache/hbase
TEST_UTIL.cleanupDataTestDirOnTestFS();
代码示例来源:origin: org.apache.hbase/hbase-mapreduce
util.cleanupDataTestDirOnTestFS(table.getNameAsString());
代码示例来源:origin: com.aliyun.hbase/alihbase-mapreduce
util.cleanupDataTestDirOnTestFS(table.getNameAsString());
代码示例来源:origin: com.aliyun.hbase/alihbase-mapreduce
util.cleanupDataTestDirOnTestFS(table);
代码示例来源:origin: org.apache.hbase/hbase-mapreduce
util.cleanupDataTestDirOnTestFS(table);
代码示例来源:origin: com.aliyun.hbase/alihbase-mapreduce
util.cleanupDataTestDirOnTestFS(table.getNameAsString());
代码示例来源:origin: org.apache.hbase/hbase-mapreduce
util.cleanupDataTestDirOnTestFS(table.getNameAsString());
代码示例来源:origin: org.apache.hbase/hbase-mapreduce
util.cleanupDataTestDirOnTestFS(table.getNameAsString());
代码示例来源:origin: com.aliyun.hbase/alihbase-mapreduce
util.cleanupDataTestDirOnTestFS(table.getNameAsString());
代码示例来源:origin: atlanmod/NeoEMF
/**
* Closes the mini-cluster and cleans all resources related to it.
*/
private static void close() {
try {
Log.info("Shutting down the Hadoop mini-cluster...");
hbase.shutdownMiniCluster();
hbase.cleanupTestDir();
hbase.cleanupDataTestDirOnTestFS();
reset();
}
catch (Throwable ignored) {
}
}
代码示例来源:origin: org.apache.hbase/hbase-mapreduce
TEST_UTIL.cleanupDataTestDirOnTestFS();
代码示例来源:origin: com.aliyun.hbase/alihbase-mapreduce
TEST_UTIL.cleanupDataTestDirOnTestFS();
代码示例来源:origin: org.apache.hbase/hbase-mapreduce
@Test
public void testSyncTable() throws Exception {
final TableName sourceTableName = TableName.valueOf(name.getMethodName() + "_source");
final TableName targetTableName = TableName.valueOf(name.getMethodName() + "_target");
Path testDir = TEST_UTIL.getDataTestDirOnTestFS("testSyncTable");
writeTestData(sourceTableName, targetTableName);
hashSourceTable(sourceTableName, testDir);
Counters syncCounters = syncTables(sourceTableName, targetTableName, testDir);
assertEqualTables(90, sourceTableName, targetTableName);
assertEquals(60, syncCounters.findCounter(Counter.ROWSWITHDIFFS).getValue());
assertEquals(10, syncCounters.findCounter(Counter.SOURCEMISSINGROWS).getValue());
assertEquals(10, syncCounters.findCounter(Counter.TARGETMISSINGROWS).getValue());
assertEquals(50, syncCounters.findCounter(Counter.SOURCEMISSINGCELLS).getValue());
assertEquals(50, syncCounters.findCounter(Counter.TARGETMISSINGCELLS).getValue());
assertEquals(20, syncCounters.findCounter(Counter.DIFFERENTCELLVALUES).getValue());
TEST_UTIL.deleteTable(sourceTableName);
TEST_UTIL.deleteTable(targetTableName);
TEST_UTIL.cleanupDataTestDirOnTestFS();
}
代码示例来源:origin: com.aliyun.hbase/alihbase-mapreduce
@Test
public void testSyncTable() throws Exception {
final TableName sourceTableName = TableName.valueOf(name.getMethodName() + "_source");
final TableName targetTableName = TableName.valueOf(name.getMethodName() + "_target");
Path testDir = TEST_UTIL.getDataTestDirOnTestFS("testSyncTable");
writeTestData(sourceTableName, targetTableName);
hashSourceTable(sourceTableName, testDir);
Counters syncCounters = syncTables(sourceTableName, targetTableName, testDir);
assertEqualTables(90, sourceTableName, targetTableName);
assertEquals(60, syncCounters.findCounter(Counter.ROWSWITHDIFFS).getValue());
assertEquals(10, syncCounters.findCounter(Counter.SOURCEMISSINGROWS).getValue());
assertEquals(10, syncCounters.findCounter(Counter.TARGETMISSINGROWS).getValue());
assertEquals(50, syncCounters.findCounter(Counter.SOURCEMISSINGCELLS).getValue());
assertEquals(50, syncCounters.findCounter(Counter.TARGETMISSINGCELLS).getValue());
assertEquals(20, syncCounters.findCounter(Counter.DIFFERENTCELLVALUES).getValue());
TEST_UTIL.deleteTable(sourceTableName);
TEST_UTIL.deleteTable(targetTableName);
TEST_UTIL.cleanupDataTestDirOnTestFS();
}
内容来源于网络,如有侵权,请联系作者删除!