public class TestReplicationSink extends Object
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
|
public void testBatchSink() throws Exception
Exception
public void testMixedPutDelete() throws Exception
Exception
public void testMixedPutTables() throws Exception
Exception
public void testMixedDeletes() throws Exception
Exception