public class TestHRegionReplayEvents
extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
static Configuration |
CONF |
protected byte[] |
cq |
protected java.lang.String |
method |
TestName |
name |
protected byte[] |
row |
protected byte[] |
row2 |
protected byte[] |
tableName |
Constructor and Description |
---|
TestHRegionReplayEvents() |
Modifier and Type | Method and Description |
---|---|
void |
setup() |
void |
tearDown() |
void |
testOnlyReplayingFlushStartDoesNotHoldUpRegionClose()
Tests a case where we replay only a flush start marker, then the region is closed.
|
void |
testRefreshStoreFiles() |
void |
testRegionReadsEnabledFlag()
Tests the reads enabled flag for the region.
|
void |
testRegionReplicaSecondaryCannotFlush() |
void |
testReplayBulkLoadEvent()
Tests replaying region open markers from primary region.
|
void |
testReplayFlushCommitMarkerLargerThanFlushStartMarker()
Tests the case where we prepare a flush with some seqId and we receive a flush commit marker
larger than the previous flush start marker.
|
void |
testReplayFlushCommitMarkerSmallerThanFlushStartMarker()
Tests the case where we prepare a flush with some seqId and we receive a flush commit marker
less than the previous flush start marker.
|
void |
testReplayFlushCommitMarkerWithoutFlushStartMarker(boolean droppableMemstore)
Tests the case where we receive a flush commit before receiving any flush prepare markers
|
void |
testReplayFlushCommitMarkerWithoutFlushStartMarkerDroppableMemstore()
Tests the case where we receive a flush commit before receiving any flush prepare markers.
|
void |
testReplayFlushCommitMarkerWithoutFlushStartMarkerNonDroppableMemstore()
Tests the case where we receive a flush commit before receiving any flush prepare markers.
|
void |
testReplayFlushesAndCompactions() |
void |
testReplayFlushSeqIds() |
void |
testReplayFlushStartMarkers()
Tests cases where we prepare a flush with some seqId and we receive other flush start markers
equal to, greater or less than the previous flush start marker.
|
void |
testReplayingBulkLoadEventWithFileAlreadyDeleted() |
void |
testReplayingCompactionWithFileAlreadyDeleted() |
void |
testReplayingFlushCommitWithFileAlreadyDeleted() |
void |
testReplayingFlushRequestRestoresReadsEnabledState()
Test the case where the secondary region replica is not in reads enabled state because it is
waiting for a flush or region open marker from primary region.
|
void |
testReplayingFlushRestoresReadsEnabledState()
Test the case where the secondary region replica is not in reads enabled state because it is
waiting for a flush or region open marker from primary region.
|
void |
testReplayingFlushWithEmptyMemstoreRestoresReadsEnabledState()
Test the case where the secondary region replica is not in reads enabled state because it is
waiting for a flush or region open marker from primary region.
|
void |
testReplayingRegionOpenEventRestoresReadsEnabledState()
Test the case where the secondary region replica is not in reads enabled state because it is
waiting for a flush or region open marker from primary region.
|
void |
testReplayingRegionOpenEventWithFileAlreadyDeleted() |
void |
testReplayRegionOpenEvent()
Tests replaying region open markers from primary region.
|
void |
testReplayRegionOpenEventAfterFlushStart()
Tests the case where we replay a region open event after a flush start but before receiving
flush commit
|
void |
testSecondaryRegionDoesNotWriteRegionEventsToWAL()
Tests that a region opened in secondary mode would not write region open / close
events to its WAL.
|
void |
testSeqIdsFromReplay() |
void |
testSkippingEditsWithSmallerSeqIdAfterRegionOpenEvent()
Tests whether edits coming in for replay are skipped which have smaller seq id than the seqId
of the last replayed region open event.
|
void |
testWriteFlushRequestMarker()
Tests the case where a request for flush cache is sent to the region, but region cannot flush.
|
public TestName name
public static Configuration CONF
protected byte[] tableName
protected java.lang.String method
protected final byte[] row
protected final byte[] row2
protected byte[] cq
public void setup() throws java.io.IOException
java.io.IOException
public void tearDown() throws java.lang.Exception
java.lang.Exception
public void testRegionReplicaSecondaryCannotFlush() throws java.io.IOException
java.io.IOException
public void testOnlyReplayingFlushStartDoesNotHoldUpRegionClose() throws java.io.IOException
java.io.IOException
public void testReplayFlushesAndCompactions() throws java.io.IOException
java.io.IOException
public void testReplayFlushStartMarkers() throws java.io.IOException
java.io.IOException
public void testReplayFlushCommitMarkerSmallerThanFlushStartMarker() throws java.io.IOException
java.io.IOException
public void testReplayFlushCommitMarkerLargerThanFlushStartMarker() throws java.io.IOException
java.io.IOException
public void testReplayFlushCommitMarkerWithoutFlushStartMarkerDroppableMemstore() throws java.io.IOException
java.io.IOException
public void testReplayFlushCommitMarkerWithoutFlushStartMarkerNonDroppableMemstore() throws java.io.IOException
java.io.IOException
public void testReplayFlushCommitMarkerWithoutFlushStartMarker(boolean droppableMemstore) throws java.io.IOException
java.io.IOException
public void testReplayRegionOpenEvent() throws java.io.IOException
java.io.IOException
public void testReplayRegionOpenEventAfterFlushStart() throws java.io.IOException
java.io.IOException
public void testSkippingEditsWithSmallerSeqIdAfterRegionOpenEvent() throws java.io.IOException
java.io.IOException
public void testReplayFlushSeqIds() throws java.io.IOException
java.io.IOException
public void testSeqIdsFromReplay() throws java.io.IOException
java.io.IOException
public void testSecondaryRegionDoesNotWriteRegionEventsToWAL() throws java.io.IOException
java.io.IOException
public void testRegionReadsEnabledFlag() throws java.io.IOException
java.io.IOException
public void testWriteFlushRequestMarker() throws java.io.IOException
java.io.IOException
public void testReplayingFlushRequestRestoresReadsEnabledState() throws java.io.IOException
java.io.IOException
public void testReplayingFlushRestoresReadsEnabledState() throws java.io.IOException
java.io.IOException
public void testReplayingFlushWithEmptyMemstoreRestoresReadsEnabledState() throws java.io.IOException
java.io.IOException
public void testReplayingRegionOpenEventRestoresReadsEnabledState() throws java.io.IOException
java.io.IOException
public void testRefreshStoreFiles() throws java.io.IOException
java.io.IOException
public void testReplayBulkLoadEvent() throws java.io.IOException
java.io.IOException
public void testReplayingFlushCommitWithFileAlreadyDeleted() throws java.io.IOException
java.io.IOException
public void testReplayingCompactionWithFileAlreadyDeleted() throws java.io.IOException
java.io.IOException
public void testReplayingRegionOpenEventWithFileAlreadyDeleted() throws java.io.IOException
java.io.IOException
public void testReplayingBulkLoadEventWithFileAlreadyDeleted() throws java.io.IOException
java.io.IOException