org.apache.hadoop.hbase.client

Class TestMultipleTimestamps

java.lang.Object

org.apache.hadoop.hbase.client.TestMultipleTimestamps

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 and Description
static HBaseClassTestRule	CLASS_RULE
private static org.slf4j.Logger	LOG
org.junit.rules.TestName	name
private static HBaseTestingUtility	TEST_UTIL

Constructor Summary

Constructors

Constructor and Description
TestMultipleTimestamps()

Method Summary

Modifier and Type	Method and 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()
static void	setUpBeforeClass()
void	tearDown()
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 Detail

CLASS_RULE

public static final HBaseClassTestRule CLASS_RULE

LOG

private static final org.slf4j.Logger LOG

TEST_UTIL

private static final HBaseTestingUtility TEST_UTIL

name

public org.junit.rules.TestName name

Constructor Detail

TestMultipleTimestamps

public TestMultipleTimestamps()

Method Detail

setUpBeforeClass

public static void setUpBeforeClass()
                             throws Exception

Throws:

Exception

tearDownAfterClass

public static void tearDownAfterClass()
                               throws Exception

Throws:

Exception

setUp

public void setUp()
           throws Exception

Throws:

Exception

tearDown

public void tearDown()
              throws Exception

Throws:

Exception

testReseeksWithOneColumnMiltipleTimestamp

public void testReseeksWithOneColumnMiltipleTimestamp()
                                               throws IOException

Throws:

IOException

testReseeksWithMultipleColumnOneTimestamp

public void testReseeksWithMultipleColumnOneTimestamp()
                                               throws IOException

Throws:

IOException

testReseeksWithMultipleColumnMultipleTimestamp

public void testReseeksWithMultipleColumnMultipleTimestamp()
                                                    throws IOException

Throws:

IOException

testReseeksWithMultipleFiles

public void testReseeksWithMultipleFiles()
                                  throws IOException

Throws:

IOException

testWithVersionDeletes

public void testWithVersionDeletes()
                            throws Exception

Throws:

Exception

testWithVersionDeletes

public void testWithVersionDeletes(boolean flushTables)
                            throws IOException

Throws:

IOException

testWithMultipleVersionDeletes

public void testWithMultipleVersionDeletes()
                                    throws IOException

Throws:

IOException

testWithColumnDeletes

public void testWithColumnDeletes()
                           throws IOException

Throws:

IOException

testWithFamilyDeletes

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