Package org.apache.hadoop.hbase.mob

Class TestExpiredMobFileCleanerChore

java.lang.Object

org.apache.hadoop.hbase.mob.TestExpiredMobFileCleanerChore

public class TestExpiredMobFileCleanerChore
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
private static org.apache.hadoop.hbase.client.Admin	admin
static final HBaseClassTestRule	CLASS_RULE
private static final String	family
private static org.apache.hadoop.hbase.mob.MobFileCleanerChore	mobFileCleanerChore
private static final byte[]	qf
private static final byte[]	row1
private static final byte[]	row2
private static final byte[]	row3
private static org.apache.hadoop.hbase.client.BufferedMutator	table
private static org.apache.hadoop.hbase.client.BufferedMutator	table2
private static final org.apache.hadoop.hbase.TableName	tableName
private static final org.apache.hadoop.hbase.TableName	tableName2
private static final HBaseTestingUtil	TEST_UTIL

Constructor Summary

Constructors

Constructor	Description
TestExpiredMobFileCleanerChore()

Method Summary

Modifier and Type	Method	Description
void	cleanUp()
private static void	init()
private static byte[]	makeDummyData(int size)
private static void	modifyColumnExpiryDays(int expireDays)
private static void	putKVAndFlush(org.apache.hadoop.hbase.client.BufferedMutator table, byte[] row, byte[] value, long ts, org.apache.hadoop.hbase.TableName tableName)
private static int	secondsOfDay()
static void	setUp()
static void	tearDown()
private static void	testCleanerInternal()	Creates a 3 day old hfile and an 1 day old hfile then sets expiry to 2 days.
void	testCleanerMultiThread()
void	testCleanerSingleThread()

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

TEST_UTIL

private static final HBaseTestingUtil TEST_UTIL

tableName

private static final org.apache.hadoop.hbase.TableName tableName

tableName2

private static final org.apache.hadoop.hbase.TableName tableName2

family

private static final String family

See Also:

• Constant Field Values

row1

private static final byte[] row1

row2

private static final byte[] row2

row3

private static final byte[] row3

qf

private static final byte[] qf

table

private static org.apache.hadoop.hbase.client.BufferedMutator table

admin

private static org.apache.hadoop.hbase.client.Admin admin

table2

private static org.apache.hadoop.hbase.client.BufferedMutator table2

mobFileCleanerChore

private static org.apache.hadoop.hbase.mob.MobFileCleanerChore mobFileCleanerChore

Constructor Details

TestExpiredMobFileCleanerChore

public TestExpiredMobFileCleanerChore()

Method Details

setUp

public static void setUp()
                  throws Exception

Throws:

Exception

cleanUp

public void cleanUp()
             throws IOException

Throws:

IOException

tearDown

public static void tearDown()
                     throws Exception

Throws:

Exception

testCleanerSingleThread

public void testCleanerSingleThread()
                             throws Exception

Throws:

Exception

testCleanerMultiThread

public void testCleanerMultiThread()
                            throws Exception

Throws:

Exception

init

private static void init()
                  throws Exception

Throws:

Exception

modifyColumnExpiryDays

private static void modifyColumnExpiryDays(int expireDays)
                                    throws Exception

Throws:

Exception

putKVAndFlush

private static void putKVAndFlush(org.apache.hadoop.hbase.client.BufferedMutator table,
 byte[] row,
 byte[] value,
 long ts,
 org.apache.hadoop.hbase.TableName tableName)
                           throws Exception

Throws:

Exception

testCleanerInternal

private static void testCleanerInternal()
                                 throws Exception

Creates a 3 day old hfile and an 1 day old hfile then sets expiry to 2 days. Verifies that the 3 day old hfile is removed but the 1 day one is still present after the expiry based cleaner is run.

Throws:

Exception

secondsOfDay

private static int secondsOfDay()

makeDummyData

private static byte[] makeDummyData(int size)