org.apache.hadoop.hbase.client

Class TestReplicaWithCluster

java.lang.Object

org.apache.hadoop.hbase.client.TestReplicaWithCluster

public class TestReplicaWithCluster
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	TestReplicaWithCluster.RegionServerHostingPrimayMetaRegionSlowOrStopCopro This copro is used to slow down the primary meta region scan a bit
static class	TestReplicaWithCluster.RegionServerStoppedCopro This copro is used to simulate region server down exception for Get and Scan
static class	TestReplicaWithCluster.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 HBaseTestingUtility	HTU
private static HBaseTestingUtility	HTU2
private static org.slf4j.Logger	LOG
private static int	META_SCAN_TIMEOUT_IN_MILLISEC
private static int	NB_SERVERS
private static int	REFRESH_PERIOD
private static byte[]	row

Constructor Summary

Constructors

Constructor and Description
TestReplicaWithCluster()

Method Summary

Modifier and Type	Method and Description
static void	afterClass()
static void	beforeClass()
void	testBulkLoad()
void	testChangeTable()
void	testCreateDeleteTable()
void	testGetRegionLocationFromPrimaryMetaRegion()
void	testReplicaAndReplication()
void	testReplicaGetWithAsyncRpcClientImpl()
void	testReplicaGetWithPrimaryAndMetaDown()
void	testReplicaGetWithPrimaryDown()
void	testReplicaScanWithPrimaryDown()

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

row

private static final byte[] row

HTU

private static final HBaseTestingUtility HTU

HTU2

private static HBaseTestingUtility HTU2

f

private static final byte[] f

REFRESH_PERIOD

private static final int REFRESH_PERIOD

See Also:

Constant Field Values

META_SCAN_TIMEOUT_IN_MILLISEC

private static final int META_SCAN_TIMEOUT_IN_MILLISEC

See Also:

Constant Field Values

Constructor Detail

TestReplicaWithCluster

public TestReplicaWithCluster()

Method Detail

beforeClass

public static void beforeClass()
                        throws Exception

Throws:

Exception

afterClass

public static void afterClass()
                       throws Exception

Throws:

Exception

testCreateDeleteTable

public void testCreateDeleteTable()
                           throws IOException

Throws:

IOException

testChangeTable

public void testChangeTable()
                     throws Exception

Throws:

Exception

testReplicaAndReplication

public void testReplicaAndReplication()
                               throws Exception

Throws:

Exception

testBulkLoad

public void testBulkLoad()
                  throws IOException

Throws:

IOException

testReplicaGetWithPrimaryDown

public void testReplicaGetWithPrimaryDown()
                                   throws IOException

Throws:

IOException

testReplicaScanWithPrimaryDown

public void testReplicaScanWithPrimaryDown()
                                    throws IOException

Throws:

IOException

testReplicaGetWithAsyncRpcClientImpl

public void testReplicaGetWithAsyncRpcClientImpl()
                                          throws IOException

Throws:

IOException

testGetRegionLocationFromPrimaryMetaRegion

public void testGetRegionLocationFromPrimaryMetaRegion()
                                                throws IOException,
                                                       InterruptedException

Throws:

IOException

InterruptedException

testReplicaGetWithPrimaryAndMetaDown

public void testReplicaGetWithPrimaryAndMetaDown()
                                          throws IOException,
                                                 InterruptedException

Throws:

IOException

InterruptedException