Package org.apache.hadoop.hbase.regionserver

Class TestKeepDeletes

java.lang.Object

org.apache.hadoop.hbase.regionserver.TestKeepDeletes

public class TestKeepDeletes
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
private final byte[]	c0
private final byte[]	c1
static final HBaseClassTestRule	CLASS_RULE
(package private) HBaseTestingUtility	hbu
org.junit.rules.TestName	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()
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

CLASS_RULE

public static final HBaseClassTestRule CLASS_RULE

hbu

HBaseTestingUtility 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

public org.junit.rules.TestName name

Constructor Details

TestKeepDeletes

public TestKeepDeletes()

Method Details

setUp

public void setUp()
           throws Exception

Throws:

Exception

tearDown

public void tearDown()
              throws Exception

Throws:

Exception

testBasicScenario

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

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

public void testWithoutKeepingDeletes()
                               throws Exception

basic verification of existing behavior

Throws:

Exception

testRawScanWithColumns

public void testRawScanWithColumns()
                            throws Exception

The ExplicitColumnTracker does not support "raw" scanning.

Throws:

Exception

testRawScan

public void testRawScan()
                 throws Exception

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

Throws:

Exception

testDeleteMarkerExpirationEmptyStore

public void testDeleteMarkerExpirationEmptyStore()
                                          throws Exception

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

Throws:

Exception

testDeleteMarkerExpiration

public void testDeleteMarkerExpiration()
                                throws Exception

Test delete marker removal from store files.

Throws:

Exception

testWithOldRow

public void testWithOldRow()
                    throws Exception

Test delete marker removal from store files.

Throws:

Exception

testRanges

public void testRanges()
                throws Exception

Verify correct range demarcation

Throws:

Exception

testDeleteMarkerVersioning

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

public void testWithMixedCFs()
                      throws Exception

Verify scenarios with multiple CFs and columns

Throws:

Exception

testWithMinVersions

public void testWithMinVersions()
                         throws Exception

Test keeping deleted rows together with min versions set

Throws:

Exception

testWithTTL

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)