org.apache.hadoop.hbase.procedure2

Class ProcedureExecutor.WorkerMonitor

java.lang.Object

org.apache.hadoop.hbase.procedure2.util.DelayedUtil.DelayedObject

org.apache.hadoop.hbase.procedure2.InlineChore

org.apache.hadoop.hbase.procedure2.ProcedureExecutor.WorkerMonitor

All Implemented Interfaces:

Comparable<Delayed>, Runnable, Delayed, DelayedUtil.DelayedWithTimeout

Enclosing class:

ProcedureExecutor<TEnvironment>

private final class ProcedureExecutor.WorkerMonitor
extends InlineChore

Field Summary

Fields

Modifier and Type	Field and Description
private float	addWorkerStuckPercentage
private static float	DEFAULT_WORKER_ADD_STUCK_PERCENTAGE
private static int	DEFAULT_WORKER_MONITOR_INTERVAL
private static int	DEFAULT_WORKER_STUCK_THRESHOLD
private int	stuckThreshold
private int	timeoutInterval
static String	WORKER_ADD_STUCK_PERCENTAGE_CONF_KEY
static String	WORKER_MONITOR_INTERVAL_CONF_KEY
static String	WORKER_STUCK_THRESHOLD_CONF_KEY

Constructor Summary

Constructors

Constructor and Description
WorkerMonitor()

Method Summary

Modifier and Type	Method and Description
private int	checkForStuckWorkers()
private void	checkThreadCount(int stuckCount)
int	getTimeoutInterval()
private void	refreshConfig()
void	run()

Methods inherited from class org.apache.hadoop.hbase.procedure2.InlineChore

getTimeout, refreshTimeout

Methods inherited from class org.apache.hadoop.hbase.procedure2.util.DelayedUtil.DelayedObject

compareTo, getDelay, toString

Methods inherited from class java.lang.Object

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

Field Detail

WORKER_MONITOR_INTERVAL_CONF_KEY

public static final String WORKER_MONITOR_INTERVAL_CONF_KEY

See Also:

Constant Field Values

DEFAULT_WORKER_MONITOR_INTERVAL

private static final int DEFAULT_WORKER_MONITOR_INTERVAL

See Also:

Constant Field Values

WORKER_STUCK_THRESHOLD_CONF_KEY

public static final String WORKER_STUCK_THRESHOLD_CONF_KEY

See Also:

Constant Field Values

DEFAULT_WORKER_STUCK_THRESHOLD

private static final int DEFAULT_WORKER_STUCK_THRESHOLD

See Also:

Constant Field Values

WORKER_ADD_STUCK_PERCENTAGE_CONF_KEY

public static final String WORKER_ADD_STUCK_PERCENTAGE_CONF_KEY

See Also:

Constant Field Values

DEFAULT_WORKER_ADD_STUCK_PERCENTAGE

private static final float DEFAULT_WORKER_ADD_STUCK_PERCENTAGE

See Also:

Constant Field Values

addWorkerStuckPercentage

private float addWorkerStuckPercentage

timeoutInterval

private int timeoutInterval

stuckThreshold

private int stuckThreshold

Constructor Detail

WorkerMonitor

public WorkerMonitor()

Method Detail

run

public void run()

checkForStuckWorkers

private int checkForStuckWorkers()

checkThreadCount

private void checkThreadCount(int stuckCount)

refreshConfig

private void refreshConfig()

getTimeoutInterval

public int getTimeoutInterval()

Specified by:

getTimeoutInterval in class InlineChore