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

Class TestReplicationSink

java.lang.Object

org.apache.hadoop.hbase.replication.regionserver.TestReplicationSink

public class TestReplicationSink
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
protected static String	baseNamespaceDir
private static final int	BATCH_SIZE
static final HBaseClassTestRule	CLASS_RULE
protected static final byte[]	FAM_NAME1
protected static final byte[]	FAM_NAME2
protected static String	hfileArchiveDir
private static final org.slf4j.Logger	LOG
protected static String	replicationClusterId
protected static org.apache.hadoop.hbase.replication.regionserver.ReplicationSink	SINK
protected static org.apache.hadoop.hbase.Stoppable	STOPPABLE
protected static final org.apache.hadoop.hbase.TableName	TABLE_NAME1
protected static final org.apache.hadoop.hbase.TableName	TABLE_NAME2
protected static org.apache.hadoop.hbase.client.Table	table1
protected static org.apache.hadoop.hbase.client.Table	table2
protected static final HBaseTestingUtil	TEST_UTIL

Constructor Summary

Constructors

Constructor	Description
TestReplicationSink()

Method Summary

Modifier and Type	Method	Description
private org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.WALEntry	createEntry(org.apache.hadoop.hbase.TableName table, int row, org.apache.hadoop.hbase.KeyValue.Type type, List<org.apache.hadoop.hbase.ExtendedCell> cells)
static org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.WALEntry.Builder	createWALEntryBuilder(org.apache.hadoop.hbase.TableName table)
void	setUp()
static void	setUpBeforeClass()
static void	tearDownAfterClass()
void	testApplyDeleteBeforePut()	Puts are buffered, but this tests when a delete (not-buffered) is applied before the actual Put that creates it.
void	testBatchSink()	Insert a whole batch of entries
void	testFailedReplicationSinkMetrics()	Test failure metrics produced for failed replication edits
void	testLargeEditsPutDelete()
void	testMixedDeletes()	Insert then do different types of deletes
void	testMixedPutDelete()	Insert a mix of puts and deletes
void	testMixedPutTables()	Insert to 2 different tables
void	testReplicateEntriesForHFiles()	Test replicateEntries with a bulk load entry for 25 HFiles
void	testRethrowRetriesExhaustedException()

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

BATCH_SIZE

private static final int BATCH_SIZE

See Also:

• Constant Field Values

TEST_UTIL

protected static final HBaseTestingUtil TEST_UTIL

SINK

protected static org.apache.hadoop.hbase.replication.regionserver.ReplicationSink SINK

TABLE_NAME1

protected static final org.apache.hadoop.hbase.TableName TABLE_NAME1

TABLE_NAME2

protected static final org.apache.hadoop.hbase.TableName TABLE_NAME2

FAM_NAME1

protected static final byte[] FAM_NAME1

FAM_NAME2

protected static final byte[] FAM_NAME2

table1

protected static org.apache.hadoop.hbase.client.Table table1

STOPPABLE

protected static org.apache.hadoop.hbase.Stoppable STOPPABLE

table2

protected static org.apache.hadoop.hbase.client.Table table2

baseNamespaceDir

protected static String baseNamespaceDir

hfileArchiveDir

protected static String hfileArchiveDir

replicationClusterId

protected static String replicationClusterId

Constructor Details

TestReplicationSink

public TestReplicationSink()

Method Details

setUpBeforeClass

public static void setUpBeforeClass()
                             throws Exception

Throws:

Exception

tearDownAfterClass

public static void tearDownAfterClass()
                               throws Exception

Throws:

Exception

setUp

public void setUp()
           throws Exception

Throws:

Exception

testBatchSink

public void testBatchSink()
                   throws Exception

Insert a whole batch of entries

Throws:

Exception

testMixedPutDelete

public void testMixedPutDelete()
                        throws Exception

Insert a mix of puts and deletes

Throws:

Exception

testLargeEditsPutDelete

public void testLargeEditsPutDelete()
                             throws Exception

Throws:

Exception

testMixedPutTables

public void testMixedPutTables()
                        throws Exception

Insert to 2 different tables

Throws:

Exception

testMixedDeletes

public void testMixedDeletes()
                      throws Exception

Insert then do different types of deletes

Throws:

Exception

testApplyDeleteBeforePut

public void testApplyDeleteBeforePut()
                              throws Exception

Puts are buffered, but this tests when a delete (not-buffered) is applied before the actual Put that creates it.

Throws:

Exception

testRethrowRetriesExhaustedException

public void testRethrowRetriesExhaustedException()
                                          throws Exception

Throws:

Exception

testReplicateEntriesForHFiles

public void testReplicateEntriesForHFiles()
                                   throws Exception

Test replicateEntries with a bulk load entry for 25 HFiles

Throws:

Exception

testFailedReplicationSinkMetrics

public void testFailedReplicationSinkMetrics()
                                      throws IOException

Test failure metrics produced for failed replication edits

Throws:

IOException

createEntry

private org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.WALEntry createEntry(org.apache.hadoop.hbase.TableName table,
 int row,
 org.apache.hadoop.hbase.KeyValue.Type type,
 List<org.apache.hadoop.hbase.ExtendedCell> cells)

createWALEntryBuilder

public static org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.WALEntry.Builder createWALEntryBuilder(org.apache.hadoop.hbase.TableName table)