org.apache.hadoop.hbase.io.asyncfs.monitor

Class ExcludeDatanodeManager

java.lang.Object

org.apache.hadoop.hbase.io.asyncfs.monitor.ExcludeDatanodeManager

All Implemented Interfaces:

ConfigurationObserver

@InterfaceAudience.Private
public class ExcludeDatanodeManager
extends Object
implements ConfigurationObserver

The class to manage the excluded datanodes of the WALs on the regionserver.

Field Summary

Fields

Modifier and Type	Field and Description
private org.apache.hadoop.conf.Configuration	conf
static int	DEFAULT_WAL_EXCLUDE_DATANODE_TTL
static int	DEFAULT_WAL_MAX_EXCLUDE_SLOW_DATANODE_COUNT
private org.apache.hbase.thirdparty.com.google.common.cache.Cache<org.apache.hadoop.hdfs.protocol.DatanodeInfo,Long>	excludeDNsCache
private static org.slf4j.Logger	LOG
private int	maxExcludeDNCount
private Map<String,StreamSlowMonitor>	streamSlowMonitors
static String	WAL_EXCLUDE_DATANODE_TTL_KEY Configure for the TTL time of the datanodes excluded
static String	WAL_MAX_EXCLUDE_SLOW_DATANODE_COUNT_KEY Configure for the max count the excluded datanodes.

Constructor Summary

Constructors

Constructor and Description
ExcludeDatanodeManager(org.apache.hadoop.conf.Configuration conf)

Method Summary

Modifier and Type	Method and Description
Map<org.apache.hadoop.hdfs.protocol.DatanodeInfo,Long>	getExcludeDNs()
StreamSlowMonitor	getStreamSlowMonitor(String name)
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.
boolean	tryAddExcludeDN(org.apache.hadoop.hdfs.protocol.DatanodeInfo datanodeInfo, String cause) Try to add a datanode to the regionserver excluding cache

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

WAL_MAX_EXCLUDE_SLOW_DATANODE_COUNT_KEY

public static final String WAL_MAX_EXCLUDE_SLOW_DATANODE_COUNT_KEY

Configure for the max count the excluded datanodes.

See Also:

Constant Field Values

DEFAULT_WAL_MAX_EXCLUDE_SLOW_DATANODE_COUNT

public static final int DEFAULT_WAL_MAX_EXCLUDE_SLOW_DATANODE_COUNT

See Also:

Constant Field Values

WAL_EXCLUDE_DATANODE_TTL_KEY

public static final String WAL_EXCLUDE_DATANODE_TTL_KEY

Configure for the TTL time of the datanodes excluded

See Also:

Constant Field Values

DEFAULT_WAL_EXCLUDE_DATANODE_TTL

public static final int DEFAULT_WAL_EXCLUDE_DATANODE_TTL

See Also:

Constant Field Values

excludeDNsCache

private volatile org.apache.hbase.thirdparty.com.google.common.cache.Cache<org.apache.hadoop.hdfs.protocol.DatanodeInfo,Long> excludeDNsCache

maxExcludeDNCount

private final int maxExcludeDNCount

conf

private final org.apache.hadoop.conf.Configuration conf

streamSlowMonitors

private final Map<String,StreamSlowMonitor> streamSlowMonitors

Constructor Detail

ExcludeDatanodeManager

public ExcludeDatanodeManager(org.apache.hadoop.conf.Configuration conf)

Method Detail

tryAddExcludeDN

public boolean tryAddExcludeDN(org.apache.hadoop.hdfs.protocol.DatanodeInfo datanodeInfo,
                               String cause)

Try to add a datanode to the regionserver excluding cache

Parameters:

datanodeInfo - the datanode to be added to the excluded cache

cause - the cause that the datanode is hope to be excluded

Returns:

True if the datanode is added to the regionserver excluding cache, false otherwise

getStreamSlowMonitor

public StreamSlowMonitor getStreamSlowMonitor(String name)

getExcludeDNs

public Map<org.apache.hadoop.hdfs.protocol.DatanodeInfo,Long> getExcludeDNs()

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