Package org.apache.hadoop.hbase.replication

Class TestMultiSlaveReplication

java.lang.Object

org.apache.hadoop.hbase.replication.TestMultiSlaveReplication

@Tag("org.apache.hadoop.hbase.testclassification.ReplicationTests") @Tag("org.apache.hadoop.hbase.testclassification.LargeTests")
public class TestMultiSlaveReplication
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
private static org.apache.hadoop.conf.Configuration	conf1
private static org.apache.hadoop.conf.Configuration	conf2
private static org.apache.hadoop.conf.Configuration	conf3
private static final byte[]	famName
private static final org.slf4j.Logger	LOG
private static final int	NB_RETRIES
private static final byte[]	noRepfamName
private static final byte[]	row
private static final byte[]	row1
private static final byte[]	row2
private static final byte[]	row3
private static final long	SLEEP_TIME
private static org.apache.hadoop.hbase.client.TableDescriptor	table
private static final org.apache.hadoop.hbase.TableName	tableName
private static HBaseTestingUtil	utility1
private static HBaseTestingUtil	utility2
private static HBaseTestingUtil	utility3

Constructor Summary

Constructors

Constructor	Description
TestMultiSlaveReplication()

Method Summary

Modifier and Type	Method	Description
private void	checkRow(byte[] row, int count, org.apache.hadoop.hbase.client.Table... tables)
private void	checkWithWait(byte[] row, int count, org.apache.hadoop.hbase.client.Table table)
private void	deleteAndWait(byte[] row, org.apache.hadoop.hbase.client.Table source, org.apache.hadoop.hbase.client.Table... targets)
private void	putAndWait(byte[] row, byte[] fam, org.apache.hadoop.hbase.client.Table source, org.apache.hadoop.hbase.client.Table... targets)
private void	rollWALAndWait(HBaseTestingUtil utility, org.apache.hadoop.hbase.TableName table, byte[] row)
static void	setUpBeforeClass()
void	testMultiSlaveReplication()

Methods inherited from class java.lang.Object

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

Field Details

LOG

private static final org.slf4j.Logger LOG

conf1

private static org.apache.hadoop.conf.Configuration conf1

conf2

private static org.apache.hadoop.conf.Configuration conf2

conf3

private static org.apache.hadoop.conf.Configuration conf3

utility1

private static HBaseTestingUtil utility1

utility2

private static HBaseTestingUtil utility2

utility3

private static HBaseTestingUtil utility3

SLEEP_TIME

private static final long SLEEP_TIME

See Also:

• Constant Field Values

NB_RETRIES

private static final int NB_RETRIES

See Also:

• Constant Field Values

tableName

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

famName

private static final byte[] famName

row

private static final byte[] row

row1

private static final byte[] row1

row2

private static final byte[] row2

row3

private static final byte[] row3

noRepfamName

private static final byte[] noRepfamName

table

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

Constructor Details

TestMultiSlaveReplication

public TestMultiSlaveReplication()

Method Details

setUpBeforeClass

@BeforeAll
public static void setUpBeforeClass()
                             throws Exception

Throws:

Exception

testMultiSlaveReplication

@Test
public void testMultiSlaveReplication()
                               throws Exception

Throws:

Exception

rollWALAndWait

private void rollWALAndWait(HBaseTestingUtil utility,
 org.apache.hadoop.hbase.TableName table,
 byte[] row)
                     throws IOException

Throws:

IOException

checkWithWait

private void checkWithWait(byte[] row,
 int count,
 org.apache.hadoop.hbase.client.Table table)
                    throws Exception

Throws:

Exception

checkRow

private void checkRow(byte[] row,
 int count,
 org.apache.hadoop.hbase.client.Table... tables)
               throws IOException

Throws:

IOException

deleteAndWait

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

Throws:

Exception

putAndWait

private void putAndWait(byte[] row,
 byte[] fam,
 org.apache.hadoop.hbase.client.Table source,
 org.apache.hadoop.hbase.client.Table... targets)
                 throws Exception

Throws:

Exception