org.apache.hadoop.hbase.master.cleaner

Class DirScanPool

java.lang.Object

org.apache.hadoop.hbase.master.cleaner.DirScanPool

All Implemented Interfaces:

ConfigurationObserver

@InterfaceAudience.Private
public class DirScanPool
extends Object
implements ConfigurationObserver

The thread pool used for scan directories

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
private static class	DirScanPool.Type

Field Summary

Fields

Modifier and Type	Field and Description
private int	cleanerLatch
private DirScanPool.Type	dirScanPoolType
private static org.slf4j.Logger	LOG
private String	name
private ThreadPoolExecutor	pool
private boolean	reconfigNotification
private int	size

Constructor Summary

Constructors

Modifier	Constructor and Description
private	DirScanPool(org.apache.hadoop.conf.Configuration conf, DirScanPool.Type dirScanPoolType)
private	DirScanPool(DirScanPool.Type dirScanPoolType, String poolSize)

Method Summary

Modifier and Type	Method and Description
(package private) void	execute(Runnable runnable)
static DirScanPool	getHFileCleanerScanPool(org.apache.hadoop.conf.Configuration conf)
static DirScanPool	getHFileCleanerScanPool(String poolSize)
static DirScanPool	getLogCleanerScanPool(org.apache.hadoop.conf.Configuration conf)
int	getSize()
private static ThreadPoolExecutor	initializePool(int size, String name)
(package private) void	latchCountDown()
(package private) void	latchCountUp()
void	onConfigurationChange(org.apache.hadoop.conf.Configuration conf) Checks if pool can be updated.
void	shutdownNow()
(package private) void	tryUpdatePoolSize(long timeout)

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

size

private volatile int size

pool

private final ThreadPoolExecutor pool

cleanerLatch

private int cleanerLatch

reconfigNotification

private boolean reconfigNotification

dirScanPoolType

private DirScanPool.Type dirScanPoolType

name

private final String name

Constructor Detail

DirScanPool

private DirScanPool(org.apache.hadoop.conf.Configuration conf,
                    DirScanPool.Type dirScanPoolType)

DirScanPool

private DirScanPool(DirScanPool.Type dirScanPoolType,
                    String poolSize)

Method Detail

initializePool

private static ThreadPoolExecutor initializePool(int size,
                                                 String name)

onConfigurationChange

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

Checks if pool can be updated. If so, mark for update later.

Specified by:

onConfigurationChange in interface ConfigurationObserver

Parameters:

conf - configuration

latchCountUp

void latchCountUp()

latchCountDown

void latchCountDown()

execute

void execute(Runnable runnable)

shutdownNow

public void shutdownNow()

tryUpdatePoolSize

void tryUpdatePoolSize(long timeout)

getSize

public int getSize()

getHFileCleanerScanPool

public static DirScanPool getHFileCleanerScanPool(org.apache.hadoop.conf.Configuration conf)

getHFileCleanerScanPool

public static DirScanPool getHFileCleanerScanPool(String poolSize)

getLogCleanerScanPool

public static DirScanPool getLogCleanerScanPool(org.apache.hadoop.conf.Configuration conf)