@InterfaceAudience.Private public class RegionsRecoveryChore extends ScheduledChore
Modifier and Type | Field and Description |
---|---|
private static String |
ERROR_REOPEN_REIONS_MSG |
private HMaster |
hMaster |
private static org.slf4j.Logger |
LOG |
private static PerClientRandomNonceGenerator |
NONCE_GENERATOR |
private static String |
REGIONS_RECOVERY_CHORE_NAME |
private int |
storeFileRefCountThreshold |
Constructor and Description |
---|
RegionsRecoveryChore(Stoppable stopper,
org.apache.hadoop.conf.Configuration configuration,
HMaster hMaster)
Construct RegionsRecoveryChore with provided params
|
Modifier and Type | Method and Description |
---|---|
protected void |
chore()
The task to execute on each scheduled execution of the Chore
|
private Map<TableName,List<byte[]>> |
getTableToRegionsByRefCount(Map<ServerName,ServerMetrics> serverMetricsMap) |
private void |
prepareTableToReopenRegionsMap(Map<TableName,List<byte[]>> tableToReopenRegionsMap,
byte[] regionName,
int regionStoreRefCount) |
cancel, cancel, choreForTesting, cleanup, getInitialDelay, getName, getPeriod, getStopper, getTimeUnit, initialChore, isInitialChoreComplete, isScheduled, run, shutdown, shutdown, toString, triggerNow
private static final org.slf4j.Logger LOG
private static final String REGIONS_RECOVERY_CHORE_NAME
private static final String ERROR_REOPEN_REIONS_MSG
private final int storeFileRefCountThreshold
private static final PerClientRandomNonceGenerator NONCE_GENERATOR
RegionsRecoveryChore(Stoppable stopper, org.apache.hadoop.conf.Configuration configuration, HMaster hMaster)
stopper
- When Stoppable.isStopped()
is true, this chore will cancel and
cleanupconfiguration
- The configuration params to be usedhMaster
- HMaster instance to initiate RegionTableRegionsprotected void chore()
ScheduledChore
chore
in class ScheduledChore
private Map<TableName,List<byte[]>> getTableToRegionsByRefCount(Map<ServerName,ServerMetrics> serverMetricsMap)
private void prepareTableToReopenRegionsMap(Map<TableName,List<byte[]>> tableToReopenRegionsMap, byte[] regionName, int regionStoreRefCount)
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.