Package org.apache.hadoop.hbase.replication.regionserver

Class TestRegionReplicaReplicationEndpointNoMaster

java.lang.Object

org.apache.hadoop.hbase.replication.regionserver.TestRegionReplicaReplicationEndpointNoMaster

public class TestRegionReplicaReplicationEndpointNoMaster
extends Object

Tests RegionReplicaReplicationEndpoint. Unlike TestRegionReplicaReplicationEndpoint this class contains lower level tests using callables.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	TestRegionReplicaReplicationEndpointNoMaster.WALEditCopro

Field Summary

Fields

Modifier and Type	Field	Description
static final HBaseClassTestRule	CLASS_RULE
(package private) static ConcurrentLinkedQueue<org.apache.hadoop.hbase.wal.WAL.Entry>	entries
private static final byte[]	f
private static org.apache.hadoop.hbase.HRegionInfo	hriPrimary
private static org.apache.hadoop.hbase.HRegionInfo	hriSecondary
private static final HBaseTestingUtility	HTU
private static final int	NB_SERVERS
private static final byte[]	row
private static org.apache.hadoop.hbase.regionserver.HRegionServer	rs0
private static org.apache.hadoop.hbase.regionserver.HRegionServer	rs1
private static org.apache.hadoop.hbase.client.Table	table
private static org.apache.hadoop.hbase.TableName	tableName

Constructor Summary

Constructors

Constructor	Description
TestRegionReplicaReplicationEndpointNoMaster()

Method Summary

Modifier and Type	Method	Description
void	after()
static void	afterClass()
void	before()
static void	beforeClass()
private void	replicateUsingCallable(org.apache.hadoop.hbase.client.ClusterConnection connection, Queue<org.apache.hadoop.hbase.wal.WAL.Entry> entries)
void	testRegionReplicaReplicationEndpointReplicate()
void	testReplayCallable()
void	testReplayCallableWithRegionMove()

Methods inherited from class java.lang.Object

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

Field Details

CLASS_RULE

public static final HBaseClassTestRule CLASS_RULE

NB_SERVERS

private static final int NB_SERVERS

See Also:

• Constant Field Values

tableName

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

table

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

row

private static final byte[] row

rs0

private static org.apache.hadoop.hbase.regionserver.HRegionServer rs0

rs1

private static org.apache.hadoop.hbase.regionserver.HRegionServer rs1

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

entries

static ConcurrentLinkedQueue<org.apache.hadoop.hbase.wal.WAL.Entry> entries

Constructor Details

TestRegionReplicaReplicationEndpointNoMaster

public TestRegionReplicaReplicationEndpointNoMaster()

Method Details

beforeClass

public static void beforeClass()
                        throws Exception

Throws:

Exception

afterClass

public static void afterClass()
                       throws Exception

Throws:

Exception

before

public void before()
            throws Exception

Throws:

Exception

after

public void after()
           throws Exception

Throws:

Exception

testReplayCallable

public void testReplayCallable()
                        throws Exception

Throws:

Exception

replicateUsingCallable

private void replicateUsingCallable(org.apache.hadoop.hbase.client.ClusterConnection connection,
 Queue<org.apache.hadoop.hbase.wal.WAL.Entry> entries)
                             throws IOException,
RuntimeException

Throws:

IOException

RuntimeException

testReplayCallableWithRegionMove

public void testReplayCallableWithRegionMove()
                                      throws Exception

Throws:

Exception

testRegionReplicaReplicationEndpointReplicate

public void testRegionReplicaReplicationEndpointReplicate()
                                                   throws Exception

Throws:

Exception