Package org.apache.hadoop.hbase.client

Class TestReplicasClient

java.lang.Object

org.apache.hadoop.hbase.client.TestReplicasClient

@Tag("org.apache.hadoop.hbase.testclassification.LargeTests") @Tag("org.apache.hadoop.hbase.testclassification.ClientTests")
public class TestReplicasClient
extends Object

Tests for region replicas. Sad that we cannot isolate these without bringing up a whole cluster. See TestRegionServerNoMaster.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	TestReplicasClient.SlowMeCopro	This copro is used to synchronize the tests.

Field Summary

Fields

Modifier and Type	Field	Description
private static final byte[]	f
private static org.apache.hadoop.hbase.client.RegionInfo	hriPrimary
private static org.apache.hadoop.hbase.client.RegionInfo	hriSecondary
private static final HBaseTestingUtil	HTU
private static final org.slf4j.Logger	LOG
private static final int	REFRESH_PERIOD
private static final byte[]	row
private static org.apache.hadoop.hbase.ServerName	rsServerName
private org.apache.hadoop.hbase.client.Table	table
private static org.apache.hadoop.hbase.TableName	TABLE_NAME

Constructor Summary

Constructors

Constructor	Description
TestReplicasClient()

Method Summary

Modifier and Type	Method	Description
void	after()
static void	afterClass()
private void	assertScanMetrics(org.apache.hadoop.hbase.client.Scan scan, org.apache.hadoop.hbase.client.RegionInfo regionInfo, boolean isStale)
void	before()
static void	beforeClass()
private void	checkRegionIsClosed(String encodedRegionName)
private void	checkRegionIsOpened(org.apache.hadoop.hbase.client.RegionInfo hri)
private void	closeRegion(org.apache.hadoop.hbase.client.RegionInfo hri)
private void	flushRegion(org.apache.hadoop.hbase.client.RegionInfo regionInfo)
private org.apache.hadoop.hbase.regionserver.HRegionServer	getRS()
private boolean	isRegionOpened(org.apache.hadoop.hbase.client.RegionInfo hri)
private void	openRegion(org.apache.hadoop.hbase.client.RegionInfo hri)
void	testFlushPrimary()
void	testFlushSecondary()
void	testFlushTable()
void	testGetNoResultNoStaleRegionWithReplica()
void	testGetNoResultNotStaleSleepRegionWithReplica()
void	testGetNoResultStaleRegionWithReplica()
void	testHedgedRead()
void	testLocations()
void	testScanMetricsByRegion()
void	testUseRegionWithoutReplica()
void	testUseRegionWithReplica()

Methods inherited from class java.lang.Object

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

Field Details

LOG

private static final org.slf4j.Logger LOG

TABLE_NAME

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

table

private org.apache.hadoop.hbase.client.Table table

row

private static final byte[] row

hriPrimary

private static org.apache.hadoop.hbase.client.RegionInfo hriPrimary

hriSecondary

private static org.apache.hadoop.hbase.client.RegionInfo hriSecondary

HTU

private static final HBaseTestingUtil HTU

f

private static final byte[] f

REFRESH_PERIOD

private static final int REFRESH_PERIOD

See Also:

• Constant Field Values

rsServerName

private static org.apache.hadoop.hbase.ServerName rsServerName

Constructor Details

TestReplicasClient

public TestReplicasClient()

Method Details

beforeClass

@BeforeAll
public static void beforeClass()
                        throws Exception

Throws:

Exception

afterClass

@AfterAll
public static void afterClass()
                       throws Exception

Throws:

Exception

before

@BeforeEach
public void before()
            throws IOException

Throws:

IOException

after

@AfterEach
public void after()
           throws IOException,
org.apache.zookeeper.KeeperException

Throws:

IOException

org.apache.zookeeper.KeeperException

getRS

private org.apache.hadoop.hbase.regionserver.HRegionServer getRS()

openRegion

private void openRegion(org.apache.hadoop.hbase.client.RegionInfo hri)
                 throws Exception

Throws:

Exception

closeRegion

private void closeRegion(org.apache.hadoop.hbase.client.RegionInfo hri)
                  throws Exception

Throws:

Exception

checkRegionIsOpened

private void checkRegionIsOpened(org.apache.hadoop.hbase.client.RegionInfo hri)
                          throws Exception

Throws:

Exception

isRegionOpened

private boolean isRegionOpened(org.apache.hadoop.hbase.client.RegionInfo hri)
                        throws Exception

Throws:

Exception

checkRegionIsClosed

private void checkRegionIsClosed(String encodedRegionName)
                          throws Exception

Throws:

Exception

flushRegion

private void flushRegion(org.apache.hadoop.hbase.client.RegionInfo regionInfo)
                  throws IOException

Throws:

IOException

testUseRegionWithoutReplica

@Test
public void testUseRegionWithoutReplica()
                                 throws Exception

Throws:

Exception

testLocations

@Test
public void testLocations()
                   throws Exception

Throws:

Exception

testGetNoResultNoStaleRegionWithReplica

@Test
public void testGetNoResultNoStaleRegionWithReplica()
                                             throws Exception

Throws:

Exception

testGetNoResultStaleRegionWithReplica

@Test
public void testGetNoResultStaleRegionWithReplica()
                                           throws Exception

Throws:

Exception

testGetNoResultNotStaleSleepRegionWithReplica

@Test
public void testGetNoResultNotStaleSleepRegionWithReplica()
                                                   throws Exception

Throws:

Exception

testFlushTable

@Test
public void testFlushTable()
                    throws Exception

Throws:

Exception

testFlushPrimary

@Test
public void testFlushPrimary()
                      throws Exception

Throws:

Exception

testFlushSecondary

@Test
public void testFlushSecondary()
                        throws Exception

Throws:

Exception

testUseRegionWithReplica

@Test
public void testUseRegionWithReplica()
                              throws Exception

Throws:

Exception

testHedgedRead

@Test
public void testHedgedRead()
                    throws Exception

Throws:

Exception

testScanMetricsByRegion

@Test
public void testScanMetricsByRegion()
                             throws Exception

Throws:

Exception

assertScanMetrics

private void assertScanMetrics(org.apache.hadoop.hbase.client.Scan scan,
 org.apache.hadoop.hbase.client.RegionInfo regionInfo,
 boolean isStale)
                        throws IOException

Throws:

IOException