org.apache.hadoop.hbase

Class ClearUserNamespacesAndTablesRule

java.lang.Object

org.junit.rules.ExternalResource

org.apache.hadoop.hbase.ClearUserNamespacesAndTablesRule

All Implemented Interfaces:

org.junit.rules.TestRule

public class ClearUserNamespacesAndTablesRule
extends org.junit.rules.ExternalResource

A TestRule that clears all user namespaces and tables before the test executes. Can be used in either the Rule or ClassRule positions. Lazily realizes the provided AsyncConnection so as to avoid initialization races with other Rules. Does not close() provided connection instance when finished.

Use in combination with MiniClusterRule and ConnectionRule, for example:

 {
   @code
   public class TestMyClass {
     @ClassRule
     public static final MiniClusterRule miniClusterRule = MiniClusterRule.newBuilder().build();

     private final ConnectionRule connectionRule =
       new ConnectionRule(miniClusterRule::createConnection);
     private final ClearUserNamespacesAndTablesRule clearUserNamespacesAndTablesRule =
       new ClearUserNamespacesAndTablesRule(connectionRule::getConnection);

     @Rule
     public TestRule rule =
       RuleChain.outerRule(connectionRule).around(clearUserNamespacesAndTablesRule);
   }
 }
 

Field Summary

Fields

Modifier and Type	Field and Description
private org.apache.hadoop.hbase.client.AsyncAdmin	admin
private Supplier<org.apache.hadoop.hbase.client.AsyncConnection>	connectionSupplier
private static org.slf4j.Logger	logger

Constructor Summary

Constructors

Constructor and Description
ClearUserNamespacesAndTablesRule(Supplier<org.apache.hadoop.hbase.client.AsyncConnection> connectionSupplier)

Method Summary

Modifier and Type	Method and Description
protected void	before()
private CompletableFuture<Void>	clearTablesAndNamespaces()
private CompletableFuture<Void>	deleteNamespace(String namespace)
private CompletableFuture<Void>	deleteTable(org.apache.hadoop.hbase.TableName tableName)
private CompletableFuture<Void>	deleteUserNamespaces()
private CompletableFuture<Void>	deleteUserTables()
private CompletableFuture<Void>	disableIfEnabled(org.apache.hadoop.hbase.TableName tableName)
private CompletableFuture<Void>	disableTable(org.apache.hadoop.hbase.TableName tableName)
private CompletableFuture<Boolean>	isTableEnabled(org.apache.hadoop.hbase.TableName tableName)
private CompletableFuture<List<org.apache.hadoop.hbase.TableName>>	listTableNames()
private CompletableFuture<List<String>>	listUserNamespaces()

Methods inherited from class org.junit.rules.ExternalResource

after, apply

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

logger

private static final org.slf4j.Logger logger

connectionSupplier

private final Supplier<org.apache.hadoop.hbase.client.AsyncConnection> connectionSupplier

admin

private org.apache.hadoop.hbase.client.AsyncAdmin admin

Constructor Detail

ClearUserNamespacesAndTablesRule

public ClearUserNamespacesAndTablesRule(Supplier<org.apache.hadoop.hbase.client.AsyncConnection> connectionSupplier)

Method Detail

before

protected void before()
               throws Throwable

Overrides:

before in class org.junit.rules.ExternalResource

Throws:

Throwable

clearTablesAndNamespaces

private CompletableFuture<Void> clearTablesAndNamespaces()

deleteUserTables

private CompletableFuture<Void> deleteUserTables()

listTableNames

private CompletableFuture<List<org.apache.hadoop.hbase.TableName>> listTableNames()

isTableEnabled

private CompletableFuture<Boolean> isTableEnabled(org.apache.hadoop.hbase.TableName tableName)

disableIfEnabled

private CompletableFuture<Void> disableIfEnabled(org.apache.hadoop.hbase.TableName tableName)

disableTable

private CompletableFuture<Void> disableTable(org.apache.hadoop.hbase.TableName tableName)

deleteTable

private CompletableFuture<Void> deleteTable(org.apache.hadoop.hbase.TableName tableName)

listUserNamespaces

private CompletableFuture<List<String>> listUserNamespaces()

deleteNamespace

private CompletableFuture<Void> deleteNamespace(String namespace)

deleteUserNamespaces

private CompletableFuture<Void> deleteUserNamespaces()