org.apache.hadoop.hbase.mob

Class TestMobCompactionOptRegionBatchMode

java.lang.Object

org.apache.hadoop.hbase.mob.TestMobCompactionWithDefaults

org.apache.hadoop.hbase.mob.TestMobCompactionOptRegionBatchMode

public class TestMobCompactionOptRegionBatchMode
extends TestMobCompactionWithDefaults

Mob file compaction chore in a generational batch mode test. 1. Enables batch mode for regular MOB compaction, Sets batch size to 7 regions. Enables generational mode. 2. Disables periodic MOB compactions, sets minimum age to archive to 10 sec 3. Creates MOB table with 20 regions 4. Loads MOB data (randomized keys, 1000 rows), flushes data. 5. Repeats 4. two more times 6. Verifies that we have 20 *3 = 60 mob files (equals to number of regions x 3) 7. Runs major MOB compaction. 8. Verifies that number of MOB files in a mob directory is 20 x4 = 80 9. Waits for a period of time larger than minimum age to archive 10. Runs Mob cleaner chore 11 Verifies that number of MOB files in a mob directory is 20. 12 Runs scanner and checks all 3 * 1000 rows.

Field Summary

Fields

Modifier and Type	Field and Description
private static int	batchSize
static HBaseClassTestRule	CLASS_RULE
private org.apache.hadoop.hbase.mob.MobFileCompactionChore	compactionChore
private static org.slf4j.Logger	LOG

Fields inherited from class org.apache.hadoop.hbase.mob.TestMobCompactionWithDefaults

admin, cleanerChore, conf, fam, familyDescriptor, famStr, HTU, minAgeToArchive, mobLen, mobVal, numRegions, qualifier, rows, table, tableDescriptor, test, useFileBasedSFT

Constructor Summary

Constructors

Constructor and Description
TestMobCompactionOptRegionBatchMode(Boolean useFileBasedSFT)

Method Summary

Modifier and Type	Method and Description
protected void	additonalConfigSetup()
protected String	description()
protected void	mobCompactImpl(org.apache.hadoop.hbase.client.TableDescriptor tableDescriptor, org.apache.hadoop.hbase.client.ColumnFamilyDescriptor familyDescriptor) Call the API for compaction specific to the test set.
void	setUp()

Methods inherited from class org.apache.hadoop.hbase.mob.TestMobCompactionWithDefaults

baseTestMobFileCompaction, cleanupAndVerifyCounts, data, disableCompactions, enableCompactions, getNumberOfMobFiles, htuStart, loadAndFlushThreeTimes, mobCompact, scanTable, tearDown, testMobFileCompactionAfterSnapshotClone, testMobFileCompactionAfterSnapshotCloneAndFlush, waitUntilCompactionIsComplete

Methods inherited from class java.lang.Object

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

Field Detail

LOG

private static final org.slf4j.Logger LOG

CLASS_RULE

public static final HBaseClassTestRule CLASS_RULE

batchSize

private static final int batchSize

See Also:

Constant Field Values

compactionChore

private org.apache.hadoop.hbase.mob.MobFileCompactionChore compactionChore

Constructor Detail

TestMobCompactionOptRegionBatchMode

public TestMobCompactionOptRegionBatchMode(Boolean useFileBasedSFT)

Method Detail

setUp

public void setUp()
           throws Exception

Overrides:

setUp in class TestMobCompactionWithDefaults

Throws:

Exception

additonalConfigSetup

protected void additonalConfigSetup()

Overrides:

additonalConfigSetup in class TestMobCompactionWithDefaults

mobCompactImpl

protected void mobCompactImpl(org.apache.hadoop.hbase.client.TableDescriptor tableDescriptor,
                              org.apache.hadoop.hbase.client.ColumnFamilyDescriptor familyDescriptor)
                       throws IOException,
                              InterruptedException

Description copied from class: TestMobCompactionWithDefaults

Call the API for compaction specific to the test set. should not wait for compactions to finish. may assume compactions are enabled when called.

Overrides:

mobCompactImpl in class TestMobCompactionWithDefaults

Throws:

IOException

InterruptedException

description

protected String description()

Overrides:

description in class TestMobCompactionWithDefaults