Package org.apache.hadoop.hbase.client

Class AbstractTestAsyncTableRegionReplicasRead

java.lang.Object

org.apache.hadoop.hbase.client.AbstractTestAsyncTableRegionReplicasRead

Direct Known Subclasses:

TestAsyncTableRegionReplicasGet, TestAsyncTableRegionReplicasScan

public abstract class AbstractTestAsyncTableRegionReplicasRead
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final class	AbstractTestAsyncTableRegionReplicasRead.FailPrimaryGetCP

Field Summary

Fields

Modifier and Type	Field	Description
protected static org.apache.hadoop.hbase.client.AsyncConnection	ASYNC_CONN
protected static boolean	FAIL_PRIMARY_GET
protected static byte[]	FAMILY
Supplier<org.apache.hadoop.hbase.client.AsyncTable<?>>	getTable
protected static byte[]	QUALIFIER
protected static int	REPLICA_COUNT
protected static ConcurrentMap<Integer,AtomicInteger>	REPLICA_ID_TO_COUNT
protected static byte[]	ROW
protected static org.apache.hadoop.hbase.TableName	TABLE_NAME
protected static final HBaseTestingUtility	TEST_UTIL
org.junit.rules.TestName	testName
protected static byte[]	VALUE

Constructor Summary

Constructors

Constructor	Description
AbstractTestAsyncTableRegionReplicasRead()

Method Summary

Modifier and Type	Method	Description
private static boolean	allReplicasHaveRow(byte[] row)
protected static int	getPrimaryGetCount()
private static org.apache.hadoop.hbase.client.AsyncTable<?>	getRawTable()
protected static int	getSecondaryGetCount()
private static org.apache.hadoop.hbase.client.AsyncTable<?>	getTable()
static List<Object[]>	params()
protected abstract void	readAndCheck(org.apache.hadoop.hbase.client.AsyncTable<?> table, int replicaId)
protected static void	startClusterAndCreateTable()
static void	tearDownAfterClass()
void	testNoReplicaRead()
void	testReadSpecificReplica()
void	testReplicaRead()
protected static void	waitUntilAllReplicasHaveRow(byte[] row)

Methods inherited from class java.lang.Object

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

Field Details

TEST_UTIL

protected static final HBaseTestingUtility TEST_UTIL

TABLE_NAME

protected static org.apache.hadoop.hbase.TableName TABLE_NAME

FAMILY

protected static byte[] FAMILY

QUALIFIER

protected static byte[] QUALIFIER

ROW

protected static byte[] ROW

VALUE

protected static byte[] VALUE

REPLICA_COUNT

protected static int REPLICA_COUNT

ASYNC_CONN

protected static org.apache.hadoop.hbase.client.AsyncConnection ASYNC_CONN

testName

public org.junit.rules.TestName testName

getTable

public Supplier<org.apache.hadoop.hbase.client.AsyncTable<?>> getTable

FAIL_PRIMARY_GET

protected static volatile boolean FAIL_PRIMARY_GET

REPLICA_ID_TO_COUNT

protected static ConcurrentMap<Integer,AtomicInteger> REPLICA_ID_TO_COUNT

Constructor Details

AbstractTestAsyncTableRegionReplicasRead

public AbstractTestAsyncTableRegionReplicasRead()

Method Details

getRawTable

private static org.apache.hadoop.hbase.client.AsyncTable<?> getRawTable()

getTable

private static org.apache.hadoop.hbase.client.AsyncTable<?> getTable()

params

public static List<Object[]> params()

allReplicasHaveRow

private static boolean allReplicasHaveRow(byte[] row)
                                   throws IOException

Throws:

IOException

startClusterAndCreateTable

protected static void startClusterAndCreateTable()
                                          throws Exception

Throws:

Exception

waitUntilAllReplicasHaveRow

protected static void waitUntilAllReplicasHaveRow(byte[] row)
                                           throws IOException

Throws:

IOException

tearDownAfterClass

public static void tearDownAfterClass()
                               throws Exception

Throws:

Exception

getSecondaryGetCount

protected static int getSecondaryGetCount()

getPrimaryGetCount

protected static int getPrimaryGetCount()

readAndCheck

protected abstract void readAndCheck(org.apache.hadoop.hbase.client.AsyncTable<?> table,
 int replicaId)
                              throws Exception

Throws:

Exception

testNoReplicaRead

public void testNoReplicaRead()
                       throws Exception

Throws:

Exception

testReplicaRead

public void testReplicaRead()
                     throws Exception

Throws:

Exception

testReadSpecificReplica

public void testReadSpecificReplica()
                             throws Exception

Throws:

Exception