Package org.apache.hadoop.hbase
Class ConnectionExtension
java.lang.Object
org.apache.hadoop.hbase.ConnectionExtension
- All Implemented Interfaces:
org.junit.jupiter.api.extension.AfterAllCallback,org.junit.jupiter.api.extension.BeforeAllCallback,org.junit.jupiter.api.extension.Extension
public final class ConnectionExtension
extends Object
implements org.junit.jupiter.api.extension.BeforeAllCallback, org.junit.jupiter.api.extension.AfterAllCallback
An
Extension that manages the lifecycle of an instance of AsyncConnection.
Use in combination with MiniClusterExtension, for example:
{
public class TestMyClass {
@Order(1)
@RegisterExtension
private static final MiniClusterExtension miniClusterExtension =
miniClusterExtension.newBuilder().build();
@Order(2)
@RegisterExtension
private static final ConnectionExtension connectionExtension =
ConnectionExtension.createAsyncConnectionExtension(
miniClusterExtension::createConnection);
}
-
Field Summary
FieldsModifier and TypeFieldDescriptionprivate org.apache.hadoop.hbase.client.AsyncConnectionprivate final Supplier<CompletableFuture<org.apache.hadoop.hbase.client.AsyncConnection>>private org.apache.hadoop.hbase.client.Connectionprivate final Supplier<org.apache.hadoop.hbase.client.Connection> -
Constructor Summary
ConstructorsModifierConstructorDescriptionprivateConnectionExtension(Supplier<org.apache.hadoop.hbase.client.Connection> connectionSupplier, Supplier<CompletableFuture<org.apache.hadoop.hbase.client.AsyncConnection>> asyncConnectionSupplier) -
Method Summary
Modifier and TypeMethodDescriptionvoidafterAll(org.junit.jupiter.api.extension.ExtensionContext context) voidbeforeAll(org.junit.jupiter.api.extension.ExtensionContext context) static ConnectionExtensioncreateAsyncConnectionExtension(Supplier<CompletableFuture<org.apache.hadoop.hbase.client.AsyncConnection>> asyncConnectionSupplier) static ConnectionExtensioncreateConnectionExtension(Supplier<org.apache.hadoop.hbase.client.Connection> connectionSupplier) static ConnectionExtensioncreateConnectionExtension(Supplier<org.apache.hadoop.hbase.client.Connection> connectionSupplier, Supplier<CompletableFuture<org.apache.hadoop.hbase.client.AsyncConnection>> asyncConnectionSupplier) org.apache.hadoop.hbase.client.AsyncConnectionorg.apache.hadoop.hbase.client.Connection
-
Field Details
-
connectionSupplier
-
asyncConnectionSupplier
private final Supplier<CompletableFuture<org.apache.hadoop.hbase.client.AsyncConnection>> asyncConnectionSupplier -
connection
-
asyncConnection
-
-
Constructor Details
-
ConnectionExtension
private ConnectionExtension(Supplier<org.apache.hadoop.hbase.client.Connection> connectionSupplier, Supplier<CompletableFuture<org.apache.hadoop.hbase.client.AsyncConnection>> asyncConnectionSupplier)
-
-
Method Details
-
createConnectionExtension
public static ConnectionExtension createConnectionExtension(Supplier<org.apache.hadoop.hbase.client.Connection> connectionSupplier) -
createAsyncConnectionExtension
public static ConnectionExtension createAsyncConnectionExtension(Supplier<CompletableFuture<org.apache.hadoop.hbase.client.AsyncConnection>> asyncConnectionSupplier) -
createConnectionExtension
public static ConnectionExtension createConnectionExtension(Supplier<org.apache.hadoop.hbase.client.Connection> connectionSupplier, Supplier<CompletableFuture<org.apache.hadoop.hbase.client.AsyncConnection>> asyncConnectionSupplier) -
getConnection
-
getAsyncConnection
-
beforeAll
- Specified by:
beforeAllin interfaceorg.junit.jupiter.api.extension.BeforeAllCallback
-
afterAll
- Specified by:
afterAllin interfaceorg.junit.jupiter.api.extension.AfterAllCallback
-