public class TestReplicationSink extends Object
Modifier and Type | Field and Description |
---|---|
protected static String |
baseNamespaceDir |
protected static byte[] |
FAM_NAME1 |
protected static byte[] |
FAM_NAME2 |
protected static String |
hfileArchiveDir |
protected static String |
replicationClusterId |
protected static ReplicationSink |
SINK |
protected static Stoppable |
STOPPABLE |
protected static TableName |
TABLE_NAME1 |
protected static TableName |
TABLE_NAME2 |
protected static Table |
table1 |
protected static Table |
table2 |
protected static HBaseTestingUtility |
TEST_UTIL |
Constructor and Description |
---|
TestReplicationSink() |
Modifier and Type | Method and Description |
---|---|
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 |
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
|
protected static final HBaseTestingUtility TEST_UTIL
protected static ReplicationSink SINK
protected static final TableName TABLE_NAME1
protected static final TableName TABLE_NAME2
protected static final byte[] FAM_NAME1
protected static final byte[] FAM_NAME2
protected static Table table1
protected static Stoppable STOPPABLE
protected static Table table2
protected static String baseNamespaceDir
protected static String hfileArchiveDir
protected static String replicationClusterId
public void testBatchSink() throws Exception
Exception
public void testMixedPutDelete() throws Exception
Exception
public void testMixedPutTables() throws Exception
Exception
public void testMixedDeletes() throws Exception
Exception
public void testApplyDeleteBeforePut() throws Exception
Exception