本文整理了Java中org.apache.hadoop.hbase.HBaseTestingUtility.truncateTable()
方法的一些代码示例,展示了HBaseTestingUtility.truncateTable()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。HBaseTestingUtility.truncateTable()
方法的具体详情如下:
包路径:org.apache.hadoop.hbase.HBaseTestingUtility
类名称:HBaseTestingUtility
方法名:truncateTable
[英]Truncate a table using the admin command. Effectively disables, deletes, and recreates the table. For previous behavior of issuing row deletes, see deleteTableData. Expressly does not preserve regions of existing table.
[中]使用admin命令截断表。有效地禁用、删除和重新创建表。有关以前发出行删除的行为,请参见deleteTableData。不保留现有表的区域。
代码示例来源:origin: apache/hbase
/**
* Truncate a table using the admin command.
* Effectively disables, deletes, and recreates the table.
* For previous behavior of issuing row deletes, see
* deleteTableData.
* Expressly does not preserve regions of existing table.
* @param tableName table which must exist.
* @return HTable for the new table
*/
public Table truncateTable(final TableName tableName) throws IOException {
return truncateTable(tableName, false);
}
代码示例来源:origin: apache/hbase
@After
public void tearDown() throws IOException {
TEST_UTIL.truncateTable(TABLE_NAME);
}
代码示例来源:origin: apache/hbase
/**
* all rowKeys are fit in the last region.
* @throws IOException
*/
@Test
public void testSmallReversedScan01() throws IOException {
String[][] keysCases = new String[][] {
{ "d0", "d1", "d2", "d3" }, // all rowKeys fit in the last region.
{ "a0", "a1", "a2", "a3" }, // all rowKeys fit in the first region.
{ "a0", "b1", "c2", "d3" }, // each region with a rowKey
};
for (int caseIndex = 0; caseIndex < keysCases.length; caseIndex++) {
testSmallReversedScanInternal(keysCases[caseIndex]);
TEST_UTIL.truncateTable(TABLE_NAME);
}
}
代码示例来源:origin: apache/hbase
@Test
public void testTruncateTable() throws Exception {
final TableName tableName = TableName.valueOf(name.getMethodName());
TEST_UTIL.createTable(tableName, Bytes.toBytes("f"), splitKeys);
TEST_UTIL.waitUntilAllRegionsAssigned(tableName);
// All regions should have favored nodes
checkIfFavoredNodeInformationIsCorrect(tableName);
List<HRegionInfo> regions = admin.getTableRegions(tableName);
TEST_UTIL.truncateTable(tableName, true);
checkNoFNForDeletedTable(regions);
checkIfFavoredNodeInformationIsCorrect(tableName);
regions = admin.getTableRegions(tableName);
TEST_UTIL.truncateTable(tableName, false);
checkNoFNForDeletedTable(regions);
TEST_UTIL.deleteTable(tableName);
}
代码示例来源:origin: apache/hbase
@Test
public void testTruncatePerms() throws Exception {
try {
List<UserPermission> existingPerms = AccessControlClient.getUserPermissions(
systemUserConnection, TEST_TABLE.getNameAsString());
assertTrue(existingPerms != null);
assertTrue(existingPerms.size() > 1);
TEST_UTIL.getAdmin().disableTable(TEST_TABLE);
TEST_UTIL.truncateTable(TEST_TABLE);
TEST_UTIL.waitTableAvailable(TEST_TABLE);
List<UserPermission> perms = AccessControlClient.getUserPermissions(
systemUserConnection, TEST_TABLE.getNameAsString());
assertTrue(perms != null);
assertEquals(existingPerms.size(), perms.size());
} catch (Throwable e) {
throw new HBaseIOException(e);
}
}
代码示例来源:origin: org.apache.hbase/hbase-server
/**
* Truncate a table using the admin command.
* Effectively disables, deletes, and recreates the table.
* For previous behavior of issuing row deletes, see
* deleteTableData.
* Expressly does not preserve regions of existing table.
* @param tableName table which must exist.
* @return HTable for the new table
*/
public Table truncateTable(final TableName tableName) throws IOException {
return truncateTable(tableName, false);
}
代码示例来源:origin: kite-sdk/kite
public static void truncateTables(Collection<String> tableNames)
throws IOException {
for (String tableName : tableNames) {
util.truncateTable(Bytes.toBytes(tableName));
}
}
}
代码示例来源:origin: kite-sdk/kite
@After
public void after() throws Exception {
HBaseTestUtils.util.truncateTable(Bytes.toBytes(tableName));
HBaseTestUtils.util.truncateTable(Bytes.toBytes(managedTableName));
}
代码示例来源:origin: kite-sdk/kite
@After
public void after() throws Exception {
HBaseTestUtils.util.truncateTable(Bytes.toBytes(tableName));
HBaseTestUtils.util.truncateTable(Bytes.toBytes(managedTableName));
}
代码示例来源:origin: kite-sdk/kite
@After
public void after() throws Exception {
HBaseTestUtils.util.truncateTable(Bytes.toBytes(tableName));
HBaseTestUtils.util.truncateTable(Bytes.toBytes(managedTableName));
}
代码示例来源:origin: kite-sdk/kite
@After
public void after() throws Exception {
tablePool.close();
HBaseTestUtils.util.truncateTable(Bytes.toBytes(tableName));
HBaseTestUtils.util.truncateTable(Bytes.toBytes(compositeTableName));
HBaseTestUtils.util.truncateTable(Bytes.toBytes(incrementTableName));
HBaseTestUtils.util.truncateTable(Bytes.toBytes(managedTableName));
}
代码示例来源:origin: org.apache.hbase/hbase-server
@After
public void tearDown() throws IOException {
TEST_UTIL.truncateTable(TABLE_NAME);
}
代码示例来源:origin: kite-sdk/kite
@After
public void after() throws Exception {
repo.delete("default", tableName);
HBaseTestUtils.util.truncateTable(Bytes.toBytes(tableName));
HBaseTestUtils.util.truncateTable(Bytes.toBytes(managedTableName));
}
代码示例来源:origin: kite-sdk/kite
@After
public void after() throws Exception {
((HBaseActionModifiable) ds).clearAllModifiers();
repo.delete("default", tableName);
HBaseTestUtils.util.truncateTable(Bytes.toBytes(tableName));
HBaseTestUtils.util.truncateTable(Bytes.toBytes(managedTableName));
}
代码示例来源:origin: kite-sdk/kite
@AfterClass
public static void afterClass() throws Exception {
HBaseTestUtils.util.deleteTable(Bytes.toBytes(tableName));
HBaseTestUtils.util.truncateTable(Bytes.toBytes(managedTableName));
}
代码示例来源:origin: kite-sdk/kite
@After
public void after() throws Exception {
tablePool.close();
HBaseTestUtils.util.deleteTable(Bytes.toBytes(tableName));
HBaseTestUtils.util.truncateTable(Bytes.toBytes(managedTableName));
}
代码示例来源:origin: cdapio/cdap
@After
public void after() throws Exception {
testingUtility.truncateTable(hTable.getTableName());
}
代码示例来源:origin: kite-sdk/kite
@Before
public void beforeTest() throws Exception {
HBaseTestUtils.util.truncateTable(Bytes.toBytes(tableName));
tablePool = new HTablePool(HBaseTestUtils.getConf(), 10);
}
代码示例来源:origin: org.apache.hbase/hbase-server
/**
* all rowKeys are fit in the last region.
* @throws IOException
*/
@Test
public void testSmallReversedScan01() throws IOException {
String[][] keysCases = new String[][] {
{ "d0", "d1", "d2", "d3" }, // all rowKeys fit in the last region.
{ "a0", "a1", "a2", "a3" }, // all rowKeys fit in the first region.
{ "a0", "b1", "c2", "d3" }, // each region with a rowKey
};
for (int caseIndex = 0; caseIndex < keysCases.length; caseIndex++) {
testSmallReversedScanInternal(keysCases[caseIndex]);
TEST_UTIL.truncateTable(TABLE_NAME);
}
}
代码示例来源:origin: org.apache.hbase/hbase-server
@Test
public void testTruncateTable() throws Exception {
final TableName tableName = TableName.valueOf(name.getMethodName());
TEST_UTIL.createTable(tableName, Bytes.toBytes("f"), splitKeys);
TEST_UTIL.waitUntilAllRegionsAssigned(tableName);
// All regions should have favored nodes
checkIfFavoredNodeInformationIsCorrect(tableName);
List<HRegionInfo> regions = admin.getTableRegions(tableName);
TEST_UTIL.truncateTable(tableName, true);
checkNoFNForDeletedTable(regions);
checkIfFavoredNodeInformationIsCorrect(tableName);
regions = admin.getTableRegions(tableName);
TEST_UTIL.truncateTable(tableName, false);
checkNoFNForDeletedTable(regions);
TEST_UTIL.deleteTable(tableName);
}
内容来源于网络,如有侵权,请联系作者删除!