@InterfaceAudience.Private public class BootstrapNodeManager extends Object
Modifier and Type | Field and Description |
---|---|
private AsyncClusterConnection |
conn |
static long |
DEFAULT_REQUEST_MASTER_INTERVAL_SECS |
static long |
DEFAULT_REQUEST_MASTER_MIN_INTERVAL_SECS |
static long |
DEFAULT_REQUEST_REGIONSERVER_INTERVAL_SECS |
private ScheduledExecutorService |
executor |
private static float |
JITTER |
private long |
lastRequestMasterTime |
private static org.slf4j.Logger |
LOG |
private MasterAddressTracker |
masterAddrTracker |
private int |
maxNodeCount |
private List<ServerName> |
nodes |
static String |
REQUEST_MASTER_INTERVAL_SECS |
static String |
REQUEST_MASTER_MIN_INTERVAL_SECS |
static String |
REQUEST_REGIONSERVER_INTERVAL_SECS |
private long |
requestMasterIntervalSecs |
private long |
requestMasterMinIntervalSecs |
private long |
requestRegionServerIntervalSecs |
private RetryCounter |
retryCounter |
private RetryCounterFactory |
retryCounterFactory |
Constructor and Description |
---|
BootstrapNodeManager(AsyncClusterConnection conn,
MasterAddressTracker masterAddrTracker) |
Modifier and Type | Method and Description |
---|---|
List<ServerName> |
getBootstrapNodes() |
private long |
getDelay(long delay) |
private void |
getFromMaster() |
private void |
getFromRegionServer() |
void |
stop() |
private static final org.slf4j.Logger LOG
public static final String REQUEST_MASTER_INTERVAL_SECS
public static final long DEFAULT_REQUEST_MASTER_INTERVAL_SECS
public static final String REQUEST_MASTER_MIN_INTERVAL_SECS
public static final long DEFAULT_REQUEST_MASTER_MIN_INTERVAL_SECS
public static final String REQUEST_REGIONSERVER_INTERVAL_SECS
public static final long DEFAULT_REQUEST_REGIONSERVER_INTERVAL_SECS
private static final float JITTER
private volatile List<ServerName> nodes
private final AsyncClusterConnection conn
private final MasterAddressTracker masterAddrTracker
private final ScheduledExecutorService executor
private final long requestMasterIntervalSecs
private final long requestMasterMinIntervalSecs
private final long requestRegionServerIntervalSecs
private final int maxNodeCount
private final RetryCounterFactory retryCounterFactory
private RetryCounter retryCounter
private long lastRequestMasterTime
public BootstrapNodeManager(AsyncClusterConnection conn, MasterAddressTracker masterAddrTracker)
private long getDelay(long delay)
private void getFromMaster()
private void getFromRegionServer()
public void stop()
public List<ServerName> getBootstrapNodes()
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.