Package org.apache.hadoop.hbase.client

Class TestMultipleTimestamps

java.lang.Object

org.apache.hadoop.hbase.client.TestMultipleTimestamps

@Tag("org.apache.hadoop.hbase.testclassification.LargeTests") @Tag("org.apache.hadoop.hbase.testclassification.ClientTests")
public class TestMultipleTimestamps
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
TestMultipleTimestamps()

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	deleteAllVersionsBefore(org.apache.hadoop.hbase.client.Table ht, byte[] cf, int rowIdx, int colIdx, long version)	For row/column specified by rowIdx/colIdx, delete all cells preceeding the specified version.
private void	deleteColumn(org.apache.hadoop.hbase.client.Table ht, byte[] cf, int rowIdx, int colIdx)
private void	deleteFamily(org.apache.hadoop.hbase.client.Table ht, byte[] cf, int rowIdx)
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	put(org.apache.hadoop.hbase.client.Table ht, byte[] cf, Integer[] rowIndexes, Integer[] columnIndexes, Long[] versions)
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.ResultScanner	scan(org.apache.hadoop.hbase.client.Table ht, byte[] cf, Integer[] rowIndexes, Integer[] columnIndexes, Long[] versions, int maxVersions)
void	setUp(org.junit.jupiter.api.TestInfo testInfo)
static void	setUpBeforeClass()
static void	tearDownAfterClass()
void	testReseeksWithMultipleColumnMultipleTimestamp()
void	testReseeksWithMultipleColumnOneTimestamp()
void	testReseeksWithMultipleFiles()
void	testReseeksWithOneColumnMiltipleTimestamp()
void	testWithColumnDeletes()
void	testWithFamilyDeletes()
void	testWithMultipleVersionDeletes()
void	testWithVersionDeletes()
void	testWithVersionDeletes(boolean flushTables)

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

TestMultipleTimestamps

public TestMultipleTimestamps()

Method Details

setUp

@BeforeEach
public void setUp(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

testReseeksWithOneColumnMiltipleTimestamp

@Test
public void testReseeksWithOneColumnMiltipleTimestamp()
                                               throws IOException

Throws:

IOException

testReseeksWithMultipleColumnOneTimestamp

@Test
public void testReseeksWithMultipleColumnOneTimestamp()
                                               throws IOException

Throws:

IOException

testReseeksWithMultipleColumnMultipleTimestamp

@Test
public void testReseeksWithMultipleColumnMultipleTimestamp()
                                                    throws IOException

Throws:

IOException

testReseeksWithMultipleFiles

@Test
public void testReseeksWithMultipleFiles()
                                  throws IOException

Throws:

IOException

testWithVersionDeletes

@Test
public void testWithVersionDeletes()
                            throws Exception

Throws:

Exception

testWithVersionDeletes

public void testWithVersionDeletes(boolean flushTables)
                            throws IOException

Throws:

IOException

testWithMultipleVersionDeletes

@Test
public void testWithMultipleVersionDeletes()
                                    throws IOException

Throws:

IOException

testWithColumnDeletes

@Test
public void testWithColumnDeletes()
                           throws IOException

Throws:

IOException

testWithFamilyDeletes

@Test
public void testWithFamilyDeletes()
                           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

scan

private org.apache.hadoop.hbase.client.ResultScanner scan(org.apache.hadoop.hbase.client.Table ht,
 byte[] cf,
 Integer[] rowIndexes,
 Integer[] columnIndexes,
 Long[] versions,
 int maxVersions)
                                                   throws IOException

Throws:

IOException

put

private void put(org.apache.hadoop.hbase.client.Table ht,
 byte[] cf,
 Integer[] rowIndexes,
 Integer[] columnIndexes,
 Long[] versions)
          throws IOException

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

deleteAllVersionsBefore

private void deleteAllVersionsBefore(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 all cells preceeding the specified version.

Throws:

IOException

deleteColumn

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

Throws:

IOException

deleteFamily

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

Throws:

IOException