Package org.apache.hadoop.hbase.regionserver

Class BootstrapNodeManager

java.lang.Object

org.apache.hadoop.hbase.regionserver.BootstrapNodeManager

@Private
public class BootstrapNodeManager
extends Object

Manage the bootstrap node list at region server side.

It will request master first to get the initial set of bootstrap nodes(a sub set of live region servers), and then it will exchange the bootstrap nodes with other bootstrap nodes. In most cases, if the cluster is stable, we do not need to request master again until we reach the request master interval. And if the current number of bootstrap nodes is not enough, we will request master soon.

The algorithm is very simple, as we will always fallback to request master. THe trick here is that, if we can not get enough bootstrap nodes from master, then the cluster will be small, so it will not put too much pressure on master if we always request master. And for large clusters, we will soon get enough bootstrap nodes and stop requesting master.

Field Summary

Fields

Modifier and Type	Field	Description
private final AsyncClusterConnection	conn
static final long	DEFAULT_REQUEST_MASTER_INTERVAL_SECS
static final long	DEFAULT_REQUEST_MASTER_MIN_INTERVAL_SECS
static final long	DEFAULT_REQUEST_REGIONSERVER_INTERVAL_SECS
private final ScheduledExecutorService	executor
private static final float	JITTER
private long	lastRequestMasterTime
private static final org.slf4j.Logger	LOG
private final MasterAddressTracker	masterAddrTracker
private final int	maxNodeCount
private List<ServerName>	nodes
static final String	REQUEST_MASTER_INTERVAL_SECS
static final String	REQUEST_MASTER_MIN_INTERVAL_SECS
static final String	REQUEST_REGIONSERVER_INTERVAL_SECS
private final long	requestMasterIntervalSecs
private final long	requestMasterMinIntervalSecs
private final long	requestRegionServerIntervalSecs
private RetryCounter	retryCounter
private final RetryCounterFactory	retryCounterFactory

Constructor Summary

Constructors

Constructor	Description
BootstrapNodeManager(AsyncClusterConnection conn, MasterAddressTracker masterAddrTracker)

Method Summary

Modifier and Type	Method	Description
List<ServerName>	getBootstrapNodes()
private long	getDelay(long delay)
private void	getFromMaster()
private void	getFromRegionServer()
void	stop()

Methods inherited from class java.lang.Object

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

Field Details

LOG

private static final org.slf4j.Logger LOG

REQUEST_MASTER_INTERVAL_SECS

public static final String REQUEST_MASTER_INTERVAL_SECS

See Also:

• Constant Field Values

DEFAULT_REQUEST_MASTER_INTERVAL_SECS

public static final long DEFAULT_REQUEST_MASTER_INTERVAL_SECS

REQUEST_MASTER_MIN_INTERVAL_SECS

public static final String REQUEST_MASTER_MIN_INTERVAL_SECS

See Also:

• Constant Field Values

DEFAULT_REQUEST_MASTER_MIN_INTERVAL_SECS

public static final long DEFAULT_REQUEST_MASTER_MIN_INTERVAL_SECS

See Also:

• Constant Field Values

REQUEST_REGIONSERVER_INTERVAL_SECS

public static final String REQUEST_REGIONSERVER_INTERVAL_SECS

See Also:

• Constant Field Values

DEFAULT_REQUEST_REGIONSERVER_INTERVAL_SECS

public static final long DEFAULT_REQUEST_REGIONSERVER_INTERVAL_SECS

See Also:

• Constant Field Values

JITTER

private static final float JITTER

See Also:

• Constant Field Values

nodes

private volatile List<ServerName> nodes

conn

private final AsyncClusterConnection conn

masterAddrTracker

private final MasterAddressTracker masterAddrTracker

executor

private final ScheduledExecutorService executor

requestMasterIntervalSecs

private final long requestMasterIntervalSecs

requestMasterMinIntervalSecs

private final long requestMasterMinIntervalSecs

requestRegionServerIntervalSecs

private final long requestRegionServerIntervalSecs

maxNodeCount

private final int maxNodeCount

retryCounterFactory

private final RetryCounterFactory retryCounterFactory

retryCounter

private RetryCounter retryCounter

lastRequestMasterTime

private long lastRequestMasterTime

Constructor Details

BootstrapNodeManager

public BootstrapNodeManager(AsyncClusterConnection conn,
 MasterAddressTracker masterAddrTracker)

Method Details

getDelay

private long getDelay(long delay)

getFromMaster

private void getFromMaster()

getFromRegionServer

private void getFromRegionServer()

stop

public void stop()

getBootstrapNodes

public List<ServerName> getBootstrapNodes()