Package org.apache.hadoop.hbase

Class MiniClusterRule

java.lang.Object

org.junit.rules.ExternalResource

org.apache.hadoop.hbase.MiniClusterRule

All Implemented Interfaces:

org.junit.rules.TestRule

public final class MiniClusterRule
extends org.junit.rules.ExternalResource

A TestRule that manages an instance of the SingleProcessHBaseCluster. Can be used in either the Rule or ClassRule positions. Built on top of an instance of HBaseTestingUtil, so be weary of intermixing direct use of that class with this Rule.

Use in combination with ConnectionRule, for example:

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

     @Rule
     public final ConnectionRule connectionRule =
       ConnectionRule.createAsyncConnectionRule(miniClusterRule::createAsyncConnection);
   }
 }
 

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	MiniClusterRule.Builder	A builder for fluent composition of a new MiniClusterRule.

Field Summary

Fields

Modifier and Type	Field	Description
private SingleProcessHBaseCluster	miniCluster
private final StartTestingClusterOption	miniClusterOptions
private final HBaseTestingUtil	testingUtility

Constructor Summary

Constructors

Modifier	Constructor	Description
private	MiniClusterRule(org.apache.hadoop.conf.Configuration conf, StartTestingClusterOption miniClusterOptions)

Method Summary

Modifier and Type	Method	Description
protected void	after()
protected void	before()
CompletableFuture<org.apache.hadoop.hbase.client.AsyncConnection>	createAsyncConnection()	Create a AsyncConnection to the managed SingleProcessHBaseCluster.
org.apache.hadoop.hbase.client.Connection	createConnection()	Create a Connection to the managed SingleProcessHBaseCluster.
HBaseTestingUtil	getTestingUtility()	Returns the underlying instance of HBaseTestingUtil
static MiniClusterRule.Builder	newBuilder()

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 Details

testingUtility

private final HBaseTestingUtil testingUtility

miniClusterOptions

private final StartTestingClusterOption miniClusterOptions

miniCluster

private SingleProcessHBaseCluster miniCluster

Constructor Details

MiniClusterRule

private MiniClusterRule(org.apache.hadoop.conf.Configuration conf,
 StartTestingClusterOption miniClusterOptions)

Method Details

newBuilder

public static MiniClusterRule.Builder newBuilder()

getTestingUtility

public HBaseTestingUtil getTestingUtility()

Returns the underlying instance of HBaseTestingUtil

createConnection

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

Create a Connection to the managed SingleProcessHBaseCluster. It's up to the caller to close() the connection when finished.

createAsyncConnection

public CompletableFuture<org.apache.hadoop.hbase.client.AsyncConnection> createAsyncConnection()

Create a AsyncConnection to the managed SingleProcessHBaseCluster. It's up to the caller to close() the connection when finished.

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