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

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

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

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();
}

相关文章

HBaseTestingUtility类方法