org.apache.hadoop.hbase

Class ConnectionRule

java.lang.Object

org.junit.rules.ExternalResource

org.apache.hadoop.hbase.ConnectionRule

All Implemented Interfaces:

org.junit.rules.TestRule

public class ConnectionRule
extends org.junit.rules.ExternalResource

A Rule that manages the lifecycle of an instance of AsyncConnection. Can be used in either the Rule or ClassRule positions.

Use in combination with MiniClusterRule, for example:

{@code
   public class TestMyClass {
     private static final MiniClusterRule miniClusterRule = MiniClusterRule.newBuilder().build();
     private static final ConnectionRule connectionRule =
       new ConnectionRule(miniClusterRule::createConnection);

Field Summary

Fields

Modifier and Type	Field and Description
private org.apache.hadoop.hbase.client.AsyncConnection	connection
private Supplier<CompletableFuture<org.apache.hadoop.hbase.client.AsyncConnection>>	connectionSupplier

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
protected void	after()
protected void	before()
org.apache.hadoop.hbase.client.AsyncConnection	getConnection()

Methods inherited from class org.junit.rules.ExternalResource

apply

Methods inherited from class java.lang.Object

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

Field Detail

connectionSupplier

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

connection

private org.apache.hadoop.hbase.client.AsyncConnection connection

Constructor Detail

ConnectionRule

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

Method Detail

getConnection

public org.apache.hadoop.hbase.client.AsyncConnection getConnection()

before

protected void before()
               throws Throwable

Overrides:

before in class org.junit.rules.ExternalResource

Throws:

Throwable

after

protected void after()

Overrides:

after in class org.junit.rules.ExternalResource