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 final 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 =
       ConnectionRule.createAsyncConnectionRule(miniClusterRule::createConnection);

     @ClassRule
     public static final TestRule rule =
       RuleChain.outerRule(miniClusterRule).around(connectionRule);
   }
 }
 

Field Summary

Fields

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

Constructor Summary

Constructors

Modifier	Constructor and Description
private	ConnectionRule(Supplier<org.apache.hadoop.hbase.client.Connection> connectionSupplier, Supplier<CompletableFuture<org.apache.hadoop.hbase.client.AsyncConnection>> asyncConnectionSupplier)

Method Summary

Modifier and Type	Method and Description
protected void	after()
protected void	before()
static ConnectionRule	createAsyncConnectionRule(Supplier<CompletableFuture<org.apache.hadoop.hbase.client.AsyncConnection>> asyncConnectionSupplier)
static ConnectionRule	createConnectionRule(Supplier<org.apache.hadoop.hbase.client.Connection> connectionSupplier)
static ConnectionRule	createConnectionRule(Supplier<org.apache.hadoop.hbase.client.Connection> connectionSupplier, Supplier<CompletableFuture<org.apache.hadoop.hbase.client.AsyncConnection>> asyncConnectionSupplier)
org.apache.hadoop.hbase.client.AsyncConnection	getAsyncConnection()
org.apache.hadoop.hbase.client.Connection	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<org.apache.hadoop.hbase.client.Connection> connectionSupplier

asyncConnectionSupplier

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

connection

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

asyncConnection

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

Constructor Detail

ConnectionRule

private ConnectionRule(Supplier<org.apache.hadoop.hbase.client.Connection> connectionSupplier,
                       Supplier<CompletableFuture<org.apache.hadoop.hbase.client.AsyncConnection>> asyncConnectionSupplier)

Method Detail

createConnectionRule

public static ConnectionRule createConnectionRule(Supplier<org.apache.hadoop.hbase.client.Connection> connectionSupplier)

createAsyncConnectionRule

public static ConnectionRule createAsyncConnectionRule(Supplier<CompletableFuture<org.apache.hadoop.hbase.client.AsyncConnection>> asyncConnectionSupplier)

createConnectionRule

public static ConnectionRule createConnectionRule(Supplier<org.apache.hadoop.hbase.client.Connection> connectionSupplier,
                                                  Supplier<CompletableFuture<org.apache.hadoop.hbase.client.AsyncConnection>> asyncConnectionSupplier)

getConnection

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

getAsyncConnection

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

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