org.apache.hadoop.hbase.mob

Class MobFileCompactionChore

java.lang.Object

org.apache.hadoop.hbase.ScheduledChore

org.apache.hadoop.hbase.mob.MobFileCompactionChore

All Implemented Interfaces:

Runnable

@InterfaceAudience.Private
public class MobFileCompactionChore
extends ScheduledChore

Periodic MOB compaction chore. It runs MOB compaction on region servers in parallel, thus utilizing distributed cluster resources. To avoid possible major compaction storms, one can specify maximum number regions to be compacted in parallel by setting configuration parameter:
'hbase.mob.major.compaction.region.batch.size', which by default is 0 (unlimited).

Field Summary

Fields

Modifier and Type	Field and Description
private static org.slf4j.Logger	LOG
private HMaster	master
private int	regionBatchSize

Constructor Summary

Constructors

Constructor and Description
MobFileCompactionChore(org.apache.hadoop.conf.Configuration conf, int batchSize)
MobFileCompactionChore(HMaster master)

Method Summary

Modifier and Type	Method and Description
protected void	chore() The task to execute on each scheduled execution of the Chore
void	performMajorCompactionInBatches(Admin admin, TableDescriptor htd, ColumnFamilyDescriptor hcd)
private void	startCompaction(Admin admin, TableName table, RegionInfo region, byte[] cf)

Methods inherited from class org.apache.hadoop.hbase.ScheduledChore

cancel, cancel, choreForTesting, cleanup, getInitialDelay, getName, getPeriod, getStopper, getTimeUnit, initialChore, isInitialChoreComplete, isScheduled, run, shutdown, shutdown, toString, triggerNow

Methods inherited from class java.lang.Object

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

Field Detail

LOG

private static final org.slf4j.Logger LOG

master

private HMaster master

regionBatchSize

private int regionBatchSize

Constructor Detail

MobFileCompactionChore

public MobFileCompactionChore(HMaster master)

MobFileCompactionChore

public MobFileCompactionChore(org.apache.hadoop.conf.Configuration conf,
                              int batchSize)

Method Detail

chore

protected void chore()

Description copied from class: ScheduledChore

The task to execute on each scheduled execution of the Chore

Specified by:

chore in class ScheduledChore

performMajorCompactionInBatches

public void performMajorCompactionInBatches(Admin admin,
                                            TableDescriptor htd,
                                            ColumnFamilyDescriptor hcd)
                                     throws IOException,
                                            InterruptedException

Throws:

IOException

InterruptedException

startCompaction

private void startCompaction(Admin admin,
                             TableName table,
                             RegionInfo region,
                             byte[] cf)
                      throws IOException,
                             InterruptedException

Throws:

IOException

InterruptedException