Package org.apache.hadoop.hbase.replication

Class TestNamespaceReplication

java.lang.Object

org.apache.hadoop.hbase.replication.TestReplicationBase

org.apache.hadoop.hbase.replication.TestNamespaceReplication

public class TestNamespaceReplication
extends TestReplicationBase

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.hadoop.hbase.replication.TestReplicationBase

TestReplicationBase.ReplicationEndpointTest

Field Summary

Fields

Modifier and Type	Field	Description
private static org.apache.hadoop.hbase.client.Admin	admin1
private static org.apache.hadoop.hbase.client.Admin	admin2
static final HBaseClassTestRule	CLASS_RULE
private static org.apache.hadoop.hbase.client.Connection	connection1
private static org.apache.hadoop.hbase.client.Connection	connection2
private static final byte[]	f1Name
private static final byte[]	f2Name
private static final org.slf4j.Logger	LOG
private static String	ns1
private static String	ns2
boolean	serialPeer
private static final org.apache.hadoop.hbase.TableName	tabAName
private static final org.apache.hadoop.hbase.TableName	tabBName
private static final byte[]	val

Fields inherited from class org.apache.hadoop.hbase.replication.TestReplicationBase

CONF_WITH_LOCALFS, CONF1, CONF2, famName, hbaseAdmin, htable1, htable2, NB_RETRIES, NB_ROWS_IN_BATCH, NB_ROWS_IN_BIG_BATCH, noRepfamName, NUM_SLAVES1, NUM_SLAVES2, PEER_ID2, replicateCount, replicatedEntries, row, SLEEP_TIME, tableName, UTIL1, UTIL2

Constructor Summary

Constructors

Constructor	Description
TestNamespaceReplication()

Method Summary

Modifier and Type	Method	Description
private void	delete(org.apache.hadoop.hbase.client.Table source, byte[] row, byte[]... families)
private void	ensureRowExisted(org.apache.hadoop.hbase.client.Table target, byte[] row, byte[]... families)
private void	ensureRowNotExisted(org.apache.hadoop.hbase.client.Table target, byte[] row, byte[]... families)
protected boolean	isSerialPeer()
static List<Boolean>	parameters()
private void	put(org.apache.hadoop.hbase.client.Table source, byte[] row, byte[]... families)
static void	setUpBeforeClass()
static void	tearDownAfterClass()
void	testNamespaceReplication()

Methods inherited from class org.apache.hadoop.hbase.replication.TestReplicationBase

addPeer, cleanUp, configureClusters, createTable, getClusterKey, isSyncPeer, loadData, loadData, removePeer, restartSourceCluster, restartTargetHBaseCluster, runSimplePutDeleteTest, runSmallBatchTest, setUpBase, setupConfig, stopAllRegionServers, tearDownBase, waitForReplication, waitForReplication

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

LOG

private static final org.slf4j.Logger LOG

ns1

private static String ns1

ns2

private static String ns2

tabAName

private static final org.apache.hadoop.hbase.TableName tabAName

tabBName

private static final org.apache.hadoop.hbase.TableName tabBName

f1Name

private static final byte[] f1Name

f2Name

private static final byte[] f2Name

val

private static final byte[] val

connection1

private static org.apache.hadoop.hbase.client.Connection connection1

connection2

private static org.apache.hadoop.hbase.client.Connection connection2

admin1

private static org.apache.hadoop.hbase.client.Admin admin1

admin2

private static org.apache.hadoop.hbase.client.Admin admin2

serialPeer

public boolean serialPeer

Constructor Details

TestNamespaceReplication

public TestNamespaceReplication()

Method Details

isSerialPeer

protected boolean isSerialPeer()

Overrides:

isSerialPeer in class TestReplicationBase

parameters

public static List<Boolean> parameters()

setUpBeforeClass

public static void setUpBeforeClass()
                             throws Exception

Throws:

Exception

tearDownAfterClass

public static void tearDownAfterClass()
                               throws Exception

Throws:

Exception

testNamespaceReplication

public void testNamespaceReplication()
                              throws Exception

Throws:

Exception

put

private void put(org.apache.hadoop.hbase.client.Table source,
 byte[] row,
 byte[]... families)
          throws Exception

Throws:

Exception

delete

private void delete(org.apache.hadoop.hbase.client.Table source,
 byte[] row,
 byte[]... families)
             throws Exception

Throws:

Exception

ensureRowExisted

private void ensureRowExisted(org.apache.hadoop.hbase.client.Table target,
 byte[] row,
 byte[]... families)
                       throws Exception

Throws:

Exception

ensureRowNotExisted

private void ensureRowNotExisted(org.apache.hadoop.hbase.client.Table target,
 byte[] row,
 byte[]... families)
                          throws Exception

Throws:

Exception