Package org.apache.hadoop.hbase.client

Class TestAsyncTableRegionReplicasScan

java.lang.Object

org.apache.hadoop.hbase.client.AbstractTestAsyncTableRegionReplicasRead

org.apache.hadoop.hbase.client.TestAsyncTableRegionReplicasScan

@Tag("org.apache.hadoop.hbase.testclassification.MediumTests") @Tag("org.apache.hadoop.hbase.testclassification.ClientTests")
public class TestAsyncTableRegionReplicasScan
extends AbstractTestAsyncTableRegionReplicasRead

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.hadoop.hbase.client.AbstractTestAsyncTableRegionReplicasRead

AbstractTestAsyncTableRegionReplicasRead.FailPrimaryGetCP

Field Summary

Fields

Modifier and Type	Field	Description
private static int	ROW_COUNT

Fields inherited from class org.apache.hadoop.hbase.client.AbstractTestAsyncTableRegionReplicasRead

ASYNC_CONN, FAIL_PRIMARY_GET, FAMILY, getTable, QUALIFIER, REPLICA_COUNT, REPLICA_ID_TO_COUNT, ROW, TABLE_NAME, TEST_UTIL, VALUE

Constructor Summary

Constructors

Constructor	Description
TestAsyncTableRegionReplicasScan(Supplier<org.apache.hadoop.hbase.client.AsyncTable<?>> getTable)

Method Summary

Modifier and Type	Method	Description
private static byte[]	getRow(int i)
private static byte[]	getValue(int i)
protected void	readAndCheck(org.apache.hadoop.hbase.client.AsyncTable<?> table, int replicaId)
static void	setUpBeforeClass()

Methods inherited from class org.apache.hadoop.hbase.client.AbstractTestAsyncTableRegionReplicasRead

getPrimaryGetCount, getRawTable, getSecondaryGetCount, getTable, parameters, startClusterAndCreateTable, tearDownAfterClass, testNoReplicaRead, testReadSpecificReplica, testReplicaRead, waitUntilAllReplicasHaveRow

Methods inherited from class java.lang.Object

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

Field Details

ROW_COUNT

private static int ROW_COUNT

Constructor Details

TestAsyncTableRegionReplicasScan

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

Method Details

getRow

private static byte[] getRow(int i)

getValue

private static byte[] getValue(int i)

setUpBeforeClass

@BeforeAll
public static void setUpBeforeClass()
                             throws Exception

Throws:

Exception

readAndCheck

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

Specified by:

readAndCheck in class AbstractTestAsyncTableRegionReplicasRead

Throws:

IOException