Package org.apache.hadoop.hbase.mob

Class MobFileCleanerChore

java.lang.Object

org.apache.hadoop.hbase.ScheduledChore

org.apache.hadoop.hbase.mob.MobFileCleanerChore

All Implemented Interfaces:

Runnable, ConfigurationObserver

@Private
public class MobFileCleanerChore
extends ScheduledChore
implements ConfigurationObserver

The class MobFileCleanerChore for running cleaner regularly to remove the expired and obsolete (files which have no active references to) mob files.

Field Summary

Fields

Modifier and Type	Field	Description
private final ExpiredMobFileCleaner	cleaner
private final int	cleanerFutureTimeout
private final ThreadPoolExecutor	executor
private static final org.slf4j.Logger	LOG
private final HMaster	master
private int	threadCount

Constructor Summary

Constructors

Constructor	Description
MobFileCleanerChore(HMaster master)

Method Summary

Modifier and Type	Method	Description
private void	cancelAllFutures(List<Future<?>> futureList)
private void	checkObsoleteConfigurations()
protected void	chore()	The task to execute on each scheduled execution of the Chore
ThreadPoolExecutor	getExecutor()
private void	handleOneTable(TableDescriptor htd)
void	onConfigurationChange(org.apache.hadoop.conf.Configuration conf)	This method would be called by the ConfigurationManager object when the Configuration object is reloaded from disk.
private void	resizeThreadPool(int newCoreSize, int newMaxSize)

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 Details

LOG

private static final org.slf4j.Logger LOG

master

private final HMaster master

cleaner

private final ExpiredMobFileCleaner cleaner

executor

private final ThreadPoolExecutor executor

cleanerFutureTimeout

private final int cleanerFutureTimeout

threadCount

private int threadCount

Constructor Details

MobFileCleanerChore

public MobFileCleanerChore(HMaster master)

Method Details

checkObsoleteConfigurations

private void checkObsoleteConfigurations()

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

cancelAllFutures

private void cancelAllFutures(List<Future<?>> futureList)

handleOneTable

private void handleOneTable(TableDescriptor htd)

onConfigurationChange

public void onConfigurationChange(org.apache.hadoop.conf.Configuration conf)

Description copied from interface: ConfigurationObserver

This method would be called by the ConfigurationManager object when the Configuration object is reloaded from disk.

Specified by:

onConfigurationChange in interface ConfigurationObserver

resizeThreadPool

private void resizeThreadPool(int newCoreSize,
 int newMaxSize)

getExecutor

public ThreadPoolExecutor getExecutor()