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 and Description
protected static String	baseNamespaceDir
private static int	BATCH_SIZE
static HBaseClassTestRule	CLASS_RULE
protected static byte[]	FAM_NAME1
protected static byte[]	FAM_NAME2
protected static String	hfileArchiveDir
private static 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 org.apache.hadoop.hbase.TableName	TABLE_NAME1
protected static 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 HBaseTestingUtility	TEST_UTIL

Constructor Summary

Constructors

Constructor and Description
TestReplicationSink()

Method Summary

Modifier and Type	Method and 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.Cell> cells)
private 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 n
void	testFailedReplicationSinkMetrics() Test failure metrics produced for failed replication edits
void	testLargeEditsPutDelete()
void	testMixedDeletes() Insert then do different types of deletes n
void	testMixedPutDelete() Insert a mix of puts and deletes n
void	testMixedPutTables() Insert to 2 different tables n
void	testReplicateEntriesForHFiles() Test replicateEntries with a bulk load entry for 25 HFiles
void	testRethrowRetriesExhaustedWithDetailsException()

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

BATCH_SIZE

private static final int BATCH_SIZE

See Also:

Constant Field Values

TEST_UTIL

protected static final HBaseTestingUtility 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 Detail

TestReplicationSink

public TestReplicationSink()

Method Detail

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 n

Throws:

Exception

testMixedPutDelete

public void testMixedPutDelete()
                        throws Exception

Insert a mix of puts and deletes n

Throws:

Exception

testLargeEditsPutDelete

public void testLargeEditsPutDelete()
                             throws Exception

Throws:

Exception

testMixedPutTables

public void testMixedPutTables()
                        throws Exception

Insert to 2 different tables n

Throws:

Exception

testMixedDeletes

public void testMixedDeletes()
                      throws Exception

Insert then do different types of deletes n

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. n

Throws:

Exception

testRethrowRetriesExhaustedWithDetailsException

public void testRethrowRetriesExhaustedWithDetailsException()
                                                     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.Cell> cells)

createWALEntryBuilder

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