org.apache.hadoop.hbase.client

Class TestReplicasClient

java.lang.Object

org.apache.hadoop.hbase.client.TestReplicasClient

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 and Description
static class	TestReplicasClient.SlowMeCopro This copro is used to synchronize the tests.

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor and Description
TestReplicasClient()

Method Summary

Modifier and Type	Method and Description
void	after()
static void	afterClass()
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)
private void	runMultipleScansOfOneType(boolean reversed, boolean small)
private void	scanWithReplicas(boolean reversed, boolean small, org.apache.hadoop.hbase.client.Consistency consistency, int caching, long maxResultSize, byte[] startRow, int numRows, int numCols, boolean staleExpected, boolean slowNext)
void	testCancelOfScan()
void	testFlushPrimary()
void	testFlushSecondary()
void	testFlushTable()
void	testGetNoResultNoStaleRegionWithReplica()
void	testGetNoResultNotStaleSleepRegionWithReplica()
void	testGetNoResultStaleRegionWithReplica()
void	testHedgedRead()
void	testLocations()
void	testReverseScanOnSpecificReplica()
void	testReverseScanWithReplicas()
void	testScanOnSpecificReplica()
void	testScanWithReplicas()
void	testSmallScanWithReplicas()
void	testUseRegionWithoutReplica()
void	testUseRegionWithReplica()

Methods inherited from class java.lang.Object

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

Field Detail

CLASS_RULE

public static final HBaseClassTestRule CLASS_RULE

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 HBaseTestingUtility HTU

f

private static final byte[] f

REFRESH_PERIOD

private static final int REFRESH_PERIOD

See Also:

Constant Field Values

Constructor Detail

TestReplicasClient

public TestReplicasClient()

Method Detail

beforeClass

public static void beforeClass()
                        throws Exception

Throws:

Exception

afterClass

public static void afterClass()
                       throws Exception

Throws:

Exception

before

public void before()
            throws IOException

Throws:

IOException

after

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

public void testUseRegionWithoutReplica()
                                 throws Exception

Throws:

Exception

testLocations

public void testLocations()
                   throws Exception

Throws:

Exception

testGetNoResultNoStaleRegionWithReplica

public void testGetNoResultNoStaleRegionWithReplica()
                                             throws Exception

Throws:

Exception

testGetNoResultStaleRegionWithReplica

public void testGetNoResultStaleRegionWithReplica()
                                           throws Exception

Throws:

Exception

testGetNoResultNotStaleSleepRegionWithReplica

public void testGetNoResultNotStaleSleepRegionWithReplica()
                                                   throws Exception

Throws:

Exception

testFlushTable

public void testFlushTable()
                    throws Exception

Throws:

Exception

testFlushPrimary

public void testFlushPrimary()
                      throws Exception

Throws:

Exception

testFlushSecondary

public void testFlushSecondary()
                        throws Exception

Throws:

Exception

testUseRegionWithReplica

public void testUseRegionWithReplica()
                              throws Exception

Throws:

Exception

testHedgedRead

public void testHedgedRead()
                    throws Exception

Throws:

Exception

testScanWithReplicas

public void testScanWithReplicas()
                          throws Exception

Throws:

Exception

testSmallScanWithReplicas

public void testSmallScanWithReplicas()
                               throws Exception

Throws:

Exception

testReverseScanWithReplicas

public void testReverseScanWithReplicas()
                                 throws Exception

Throws:

Exception

testCancelOfScan

public void testCancelOfScan()
                      throws Exception

Throws:

Exception

testScanOnSpecificReplica

public void testScanOnSpecificReplica()
                               throws Exception

Throws:

Exception

testReverseScanOnSpecificReplica

public void testReverseScanOnSpecificReplica()
                                      throws Exception

Throws:

Exception

runMultipleScansOfOneType

private void runMultipleScansOfOneType(boolean reversed,
                                       boolean small)
                                throws Exception

Throws:

Exception

scanWithReplicas

private void scanWithReplicas(boolean reversed,
                              boolean small,
                              org.apache.hadoop.hbase.client.Consistency consistency,
                              int caching,
                              long maxResultSize,
                              byte[] startRow,
                              int numRows,
                              int numCols,
                              boolean staleExpected,
                              boolean slowNext)
                       throws Exception

Throws:

Exception