Package org.apache.hadoop.hbase.client

Class TestTimestampsFilter

java.lang.Object

org.apache.hadoop.hbase.client.TestTimestampsFilter

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

Run tests related to TimestampsFilter using HBase client APIs. Sets up the HBase mini cluster once at start. Each creates a table named for the method and does its stuff against that.

Field Summary

Fields

Modifier and Type	Field	Description
private static final org.slf4j.Logger	LOG
private String	methodName
private static final HBaseTestingUtil	TEST_UTIL

Constructor Summary

Constructors

Constructor	Description
TestTimestampsFilter()

Method Summary

Modifier and Type	Method	Description
private void	checkOneCell(org.apache.hadoop.hbase.Cell kv, byte[] cf, int rowIdx, int colIdx, long ts)	Assert that the passed in KeyValue has expected contents for the specified row, column & timestamp.
private void	deleteOneVersion(org.apache.hadoop.hbase.client.Table ht, byte[] cf, int rowIdx, int colIdx, long version)	For row/column specified by rowIdx/colIdx, delete the cell corresponding to the specified version.
private org.apache.hadoop.hbase.Cell[]	getNVersions(org.apache.hadoop.hbase.client.Table ht, byte[] cf, int rowIdx, int colIdx, List<Long> versions)	Uses the TimestampFilter on a Get to request a specified list of versions for the row/column specified by rowIdx & colIdx.
private void	putNVersions(org.apache.hadoop.hbase.client.Table ht, byte[] cf, int rowIdx, int colIdx, long versionStart, long versionEnd)	Insert in specific row/column versions with timestamps versionStart..versionEnd.
private org.apache.hadoop.hbase.client.Result[]	scanNVersions(org.apache.hadoop.hbase.client.Table ht, byte[] cf, int startRowIdx, int endRowIdx, List<Long> versions)	Uses the TimestampFilter on a Scan to request a specified list of versions for the rows from startRowIdx to endRowIdx (both inclusive).
void	setUp()
static void	setUpBeforeClass()
void	setUpMethodName(org.junit.jupiter.api.TestInfo testInfo)
void	tearDown()
static void	tearDownAfterClass()
void	testMultiColumns()
void	testTimestampsFilter()	Test from client side for TimestampsFilter.
void	testWithVersionDeletes()	Test TimestampsFilter in the presence of version deletes.
private void	testWithVersionDeletes(boolean flushTables)
private void	verifyInsertedValues(org.apache.hadoop.hbase.client.Table ht, byte[] cf)

Methods inherited from class java.lang.Object

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

Field Details

LOG

private static final org.slf4j.Logger LOG

TEST_UTIL

private static final HBaseTestingUtil TEST_UTIL

methodName

private String methodName

Constructor Details

TestTimestampsFilter

public TestTimestampsFilter()

Method Details

setUpMethodName

@BeforeEach
public void setUpMethodName(org.junit.jupiter.api.TestInfo testInfo)

setUpBeforeClass

@BeforeAll
public static void setUpBeforeClass()
                             throws Exception

Throws:

Exception

tearDownAfterClass

@AfterAll
public static void tearDownAfterClass()
                               throws Exception

Throws:

Exception

setUp

@BeforeEach
public void setUp()
           throws Exception

Throws:

Exception

tearDown

@AfterEach
public void tearDown()
              throws Exception

Throws:

Exception

testTimestampsFilter

@Test
public void testTimestampsFilter()
                          throws Exception

Test from client side for TimestampsFilter. The TimestampsFilter provides the ability to request cells (KeyValues) whose timestamp/version is in the specified list of timestamps/version.

Throws:

Exception

testMultiColumns

@Test
public void testMultiColumns()
                      throws Exception

Throws:

Exception

testWithVersionDeletes

@Test
public void testWithVersionDeletes()
                            throws Exception

Test TimestampsFilter in the presence of version deletes.

Throws:

Exception

testWithVersionDeletes

private void testWithVersionDeletes(boolean flushTables)
                             throws IOException

Throws:

IOException

verifyInsertedValues

private void verifyInsertedValues(org.apache.hadoop.hbase.client.Table ht,
 byte[] cf)
                           throws IOException

Throws:

IOException

checkOneCell

private void checkOneCell(org.apache.hadoop.hbase.Cell kv,
 byte[] cf,
 int rowIdx,
 int colIdx,
 long ts)

Assert that the passed in KeyValue has expected contents for the specified row, column & timestamp.

getNVersions

private org.apache.hadoop.hbase.Cell[] getNVersions(org.apache.hadoop.hbase.client.Table ht,
 byte[] cf,
 int rowIdx,
 int colIdx,
 List<Long> versions)
                                             throws IOException

Uses the TimestampFilter on a Get to request a specified list of versions for the row/column specified by rowIdx & colIdx.

Throws:

IOException

scanNVersions

private org.apache.hadoop.hbase.client.Result[] scanNVersions(org.apache.hadoop.hbase.client.Table ht,
 byte[] cf,
 int startRowIdx,
 int endRowIdx,
 List<Long> versions)
                                                       throws IOException

Uses the TimestampFilter on a Scan to request a specified list of versions for the rows from startRowIdx to endRowIdx (both inclusive).

Throws:

IOException

putNVersions

private void putNVersions(org.apache.hadoop.hbase.client.Table ht,
 byte[] cf,
 int rowIdx,
 int colIdx,
 long versionStart,
 long versionEnd)
                   throws IOException

Insert in specific row/column versions with timestamps versionStart..versionEnd.

Throws:

IOException

deleteOneVersion

private void deleteOneVersion(org.apache.hadoop.hbase.client.Table ht,
 byte[] cf,
 int rowIdx,
 int colIdx,
 long version)
                       throws IOException

For row/column specified by rowIdx/colIdx, delete the cell corresponding to the specified version.

Throws:

IOException