Package org.apache.hadoop.hbase.mob

Class TestRSMobFileCleanerChore

java.lang.Object

org.apache.hadoop.hbase.mob.TestRSMobFileCleanerChore

public class TestRSMobFileCleanerChore
extends Object

Mob file cleaner chore test. 1. Creates MOB table 2. Load MOB data and flushes it N times 3. Runs major MOB compaction 4. Verifies that number of MOB files in a mob directory is N+1 5. Waits for a period of time larger than minimum age to archive 6. Runs Mob cleaner chore 7 Verifies that every old MOB file referenced from current RS was archived

Field Summary

Fields

Modifier and Type	Field	Description
private org.apache.hadoop.hbase.client.Admin	admin
private org.apache.hadoop.hbase.mob.RSMobFileCleanerChore	chore
static final HBaseClassTestRule	CLASS_RULE
private org.apache.hadoop.conf.Configuration	conf
private static final byte[]	fam
private org.apache.hadoop.hbase.client.ColumnFamilyDescriptor	familyDescriptor
private static final String	famStr
private HBaseTestingUtil	HTU
private static final org.slf4j.Logger	LOG
private long	minAgeToArchive
private static final long	mobLen
private static final byte[]	mobVal
private static final byte[]	qualifier
private org.apache.hadoop.hbase.client.Table	table
private org.apache.hadoop.hbase.client.TableDescriptor	tableDescriptor

Constructor Summary

Constructors

Constructor	Description
TestRSMobFileCleanerChore()

Method Summary

Modifier and Type	Method	Description
private long	getNumberOfMobFiles(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.hbase.TableName tableName, String family)
private void	initConf()
private void	loadData(org.apache.hadoop.hbase.client.Table t, int start, int num)
private long	scanTable()
void	setUp()
void	tearDown()
void	testCleaningAndStoreFileReaderCreatedByOtherThreads()
void	testMobFileCleanerChore()

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

CLASS_RULE

public static final HBaseClassTestRule CLASS_RULE

HTU

private HBaseTestingUtil HTU

famStr

private static final String famStr

See Also:

• Constant Field Values

fam

private static final byte[] fam

qualifier

private static final byte[] qualifier

mobLen

private static final long mobLen

See Also:

• Constant Field Values

mobVal

private static final byte[] mobVal

conf

private org.apache.hadoop.conf.Configuration conf

tableDescriptor

private org.apache.hadoop.hbase.client.TableDescriptor tableDescriptor

familyDescriptor

private org.apache.hadoop.hbase.client.ColumnFamilyDescriptor familyDescriptor

admin

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

table

private org.apache.hadoop.hbase.client.Table table

chore

private org.apache.hadoop.hbase.mob.RSMobFileCleanerChore chore

minAgeToArchive

private long minAgeToArchive

Constructor Details

TestRSMobFileCleanerChore

public TestRSMobFileCleanerChore()

Method Details

setUp

public void setUp()
           throws Exception

Throws:

Exception

initConf

private void initConf()

loadData

private void loadData(org.apache.hadoop.hbase.client.Table t,
 int start,
 int num)

tearDown

public void tearDown()
              throws Exception

Throws:

Exception

testMobFileCleanerChore

public void testMobFileCleanerChore()
                             throws InterruptedException,
IOException

Throws:

InterruptedException

IOException

testCleaningAndStoreFileReaderCreatedByOtherThreads

public void testCleaningAndStoreFileReaderCreatedByOtherThreads()
                                                         throws IOException,
InterruptedException

Throws:

IOException

InterruptedException

getNumberOfMobFiles

private long getNumberOfMobFiles(org.apache.hadoop.conf.Configuration conf,
 org.apache.hadoop.hbase.TableName tableName,
 String family)
                          throws IOException

Throws:

IOException

scanTable

private long scanTable()