Package org.apache.hadoop.hbase.regionserver

Class TestKeepDeletes

java.lang.Object

org.apache.hadoop.hbase.regionserver.TestKeepDeletes

@Tag("org.apache.hadoop.hbase.testclassification.RegionServerTests") @Tag("org.apache.hadoop.hbase.testclassification.MediumTests")
public class TestKeepDeletes
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
private final byte[]	c0
private final byte[]	c1
(package private) HBaseTestingUtil	hbu
private String	name
private final byte[]	T0
private final byte[]	T1
private final byte[]	T2
private final byte[]	T3
private final byte[]	T4
private final byte[]	T5
private final byte[]	T6

Constructor Summary

Constructors

Constructor	Description
TestKeepDeletes()

Method Summary

Modifier and Type	Method	Description
private void	checkGet(org.apache.hadoop.hbase.regionserver.Region region, byte[] row, byte[] fam, byte[] col, long time, byte[]... vals)
private void	checkResult(org.apache.hadoop.hbase.client.Result r, byte[] fam, byte[] col, byte[]... vals)
private int	countDeleteMarkers(org.apache.hadoop.hbase.regionserver.HRegion region)
void	setUp(org.junit.jupiter.api.TestInfo testInfo)
void	tearDown()
void	testBasicScenario()	Make sure that deleted rows are retained.
void	testDeleteMarkerExpiration()	Test delete marker removal from store files.
void	testDeleteMarkerExpirationEmptyStore()	Verify that delete markers are removed from an otherwise empty store.
void	testDeleteMarkerVersioning()	Verify that column/version delete makers are sorted with their respective puts and removed correctly by versioning (i.e.
void	testRanges()	Verify correct range demarcation
void	testRawScan()	Verify that "raw" scanning mode return delete markers and deletes rows.
void	testRawScanWithColumns()	The ExplicitColumnTracker does not support "raw" scanning.
void	testRawScanWithoutKeepingDeletes()	Even when the store does not keep deletes a "raw" scan will return everything it can find (unless discarding cells is guaranteed to have no effect).
void	testWithMinVersions()	Test keeping deleted rows together with min versions set
void	testWithMixedCFs()	Verify scenarios with multiple CFs and columns
void	testWithOldRow()	Test delete marker removal from store files.
void	testWithoutKeepingDeletes()	basic verification of existing behavior
void	testWithTTL()	Test keeping deleted rows together with min versions set

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

hbu

HBaseTestingUtil hbu

T0

private final byte[] T0

T1

private final byte[] T1

T2

private final byte[] T2

T3

private final byte[] T3

T4

private final byte[] T4

T5

private final byte[] T5

T6

private final byte[] T6

c0

private final byte[] c0

c1

private final byte[] c1

name

private String name

Constructor Details

TestKeepDeletes

public TestKeepDeletes()

Method Details

setUp

@BeforeEach
public void setUp(org.junit.jupiter.api.TestInfo testInfo)
           throws Exception

Throws:

Exception

tearDown

@AfterEach
public void tearDown()
              throws Exception

Throws:

Exception

testBasicScenario

@Test
public void testBasicScenario()
                       throws Exception

Make sure that deleted rows are retained. Family delete markers are deleted. Column Delete markers are versioned Time range scan of deleted rows are possible

Throws:

Exception

testRawScanWithoutKeepingDeletes

@Test
public void testRawScanWithoutKeepingDeletes()
                                      throws Exception

Even when the store does not keep deletes a "raw" scan will return everything it can find (unless discarding cells is guaranteed to have no effect). Assuming this the desired behavior. Could also disallow "raw" scanning if the store does not have KEEP_DELETED_CELLS enabled. (can be changed easily)

Throws:

Exception

testWithoutKeepingDeletes

@Test
public void testWithoutKeepingDeletes()
                               throws Exception

basic verification of existing behavior

Throws:

Exception

testRawScanWithColumns

@Test
public void testRawScanWithColumns()
                            throws Exception

The ExplicitColumnTracker does not support "raw" scanning.

Throws:

Exception

testRawScan

@Test
public void testRawScan()
                 throws Exception

Verify that "raw" scanning mode return delete markers and deletes rows.

Throws:

Exception

testDeleteMarkerExpirationEmptyStore

@Test
public void testDeleteMarkerExpirationEmptyStore()
                                          throws Exception

Verify that delete markers are removed from an otherwise empty store.

Throws:

Exception

testDeleteMarkerExpiration

@Test
public void testDeleteMarkerExpiration()
                                throws Exception

Test delete marker removal from store files.

Throws:

Exception

testWithOldRow

@Test
public void testWithOldRow()
                    throws Exception

Test delete marker removal from store files.

Throws:

Exception

testRanges

@Test
public void testRanges()
                throws Exception

Verify correct range demarcation

Throws:

Exception

testDeleteMarkerVersioning

@Test
public void testDeleteMarkerVersioning()
                                throws Exception

Verify that column/version delete makers are sorted with their respective puts and removed correctly by versioning (i.e. not relying on the store earliestPutTS).

Throws:

Exception

testWithMixedCFs

@Test
public void testWithMixedCFs()
                      throws Exception

Verify scenarios with multiple CFs and columns

Throws:

Exception

testWithMinVersions

@Test
public void testWithMinVersions()
                         throws Exception

Test keeping deleted rows together with min versions set

Throws:

Exception

testWithTTL

@Test
public void testWithTTL()
                 throws Exception

Test keeping deleted rows together with min versions set

Throws:

Exception

checkGet

private void checkGet(org.apache.hadoop.hbase.regionserver.Region region,
 byte[] row,
 byte[] fam,
 byte[] col,
 long time,
 byte[]... vals)
               throws IOException

Throws:

IOException

countDeleteMarkers

private int countDeleteMarkers(org.apache.hadoop.hbase.regionserver.HRegion region)
                        throws IOException

Throws:

IOException

checkResult

private void checkResult(org.apache.hadoop.hbase.client.Result r,
 byte[] fam,
 byte[] col,
 byte[]... vals)