public class TestReplicationSink
extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
protected static java.lang.String |
baseNamespaceDir |
protected static byte[] |
FAM_NAME1 |
protected static byte[] |
FAM_NAME2 |
protected static java.lang.String |
hfileArchiveDir |
protected static java.lang.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 java.lang.String baseNamespaceDir
protected static java.lang.String hfileArchiveDir
protected static java.lang.String replicationClusterId
public static void setUpBeforeClass() throws java.lang.Exception
java.lang.Exception
public static void tearDownAfterClass() throws java.lang.Exception
java.lang.Exception
public void setUp() throws java.lang.Exception
java.lang.Exception
public void testBatchSink() throws java.lang.Exception
java.lang.Exception
public void testMixedPutDelete() throws java.lang.Exception
java.lang.Exception
public void testMixedPutTables() throws java.lang.Exception
java.lang.Exception
public void testMixedDeletes() throws java.lang.Exception
java.lang.Exception
public void testApplyDeleteBeforePut() throws java.lang.Exception
java.lang.Exception
public void testReplicateEntriesForHFiles() throws java.lang.Exception
java.lang.Exception