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.HRegionInfo	hriPrimary
private static org.apache.hadoop.hbase.HRegionInfo	hriSecondary
private static HBaseTestingUtility	HTU
private static org.slf4j.Logger	LOG
private static int	NB_SERVERS
private static int	REFRESH_PERIOD
private static byte[]	row
private static org.apache.hadoop.hbase.client.Table	table

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.HRegionInfo hri)
private void	closeRegion(org.apache.hadoop.hbase.HRegionInfo hri)
private void	flushRegion(org.apache.hadoop.hbase.HRegionInfo regionInfo)
private org.apache.hadoop.hbase.regionserver.HRegionServer	getRS()
private boolean	isRegionOpened(org.apache.hadoop.hbase.HRegionInfo hri)
private void	openRegion(org.apache.hadoop.hbase.HRegionInfo 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	testCancelOfMultiGet()
void	testCancelOfScan()
void	testFlushPrimary()
void	testFlushSecondary()
void	testFlushTable()
void	testGetNoResultNoStaleRegionWithReplica()
void	testGetNoResultNotStaleSleepRegionWithReplica()
void	testGetNoResultStaleRegionWithReplica()
void	testHedgedRead()
void	testLocations()
void	testReverseScanWithReplicas()
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

NB_SERVERS

private static final int NB_SERVERS

See Also:

Constant Field Values

table

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

row

private static final byte[] row

hriPrimary

private static org.apache.hadoop.hbase.HRegionInfo hriPrimary

hriSecondary

private static org.apache.hadoop.hbase.HRegionInfo 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.HRegionInfo hri)
                 throws Exception

Throws:

Exception

closeRegion

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

Throws:

Exception

checkRegionIsOpened

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

Throws:

Exception

isRegionOpened

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

Throws:

Exception

checkRegionIsClosed

private void checkRegionIsClosed(String encodedRegionName)
                          throws Exception

Throws:

Exception

flushRegion

private void flushRegion(org.apache.hadoop.hbase.HRegionInfo 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

testCancelOfMultiGet

public void testCancelOfMultiGet()
                          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

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