@InterfaceAudience.Private @InterfaceStability.Evolving public class HbckChore extends ScheduledChore
Modifier and Type | Field and Description |
---|---|
private static int |
DEFAULT_HBCK_CHORE_INTERVAL |
private boolean |
disabled |
private static String |
HBCK_CHORE_INTERVAL |
private HbckReport |
lastReport
Saved report from last time this chore ran.
|
private static org.slf4j.Logger |
LOG |
private MasterServices |
master |
private boolean |
running
When running, the "snapshot" may be changed when this round's checking finish.
|
Constructor and Description |
---|
HbckChore(MasterServices master) |
Modifier and Type | Method and Description |
---|---|
protected void |
chore()
The task to execute on each scheduled execution of the Chore
|
private void |
disableChore() |
HbckReport |
getLastReport()
Returns Returns last published Report that comes of last successful execution of this chore.
|
boolean |
isDisabled() |
boolean |
isRunning()
When running, the HBCK report may be changed later.
|
private void |
loadRegionsFromFS(HashSet<String> mergedParentRegions,
HbckReport report) |
private void |
loadRegionsFromInMemoryState(HbckReport report) |
private void |
loadRegionsFromRSReport(HbckReport report) |
boolean |
runChore()
Request execution of this chore's action.
|
private HashSet<String> |
scanForMergedParentRegions()
Scan hbase:meta to get set of merged parent regions, this is a very heavy scan.
|
private void |
updateAssignmentManagerMetrics(HbckReport report) |
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 HBCK_CHORE_INTERVAL
private static final int DEFAULT_HBCK_CHORE_INTERVAL
private final MasterServices master
private volatile HbckReport lastReport
private volatile boolean running
private boolean disabled
public HbckChore(MasterServices master)
public HbckReport getLastReport()
protected void chore()
ScheduledChore
chore
in class ScheduledChore
public boolean runChore()
true
if the chore was executed, false
if the chore is disabled or
already running.private void disableChore()
public boolean isDisabled()
private HashSet<String> scanForMergedParentRegions() throws IOException
HashSet
IOException
private void loadRegionsFromInMemoryState(HbckReport report)
private void loadRegionsFromRSReport(HbckReport report)
private void loadRegionsFromFS(HashSet<String> mergedParentRegions, HbckReport report) throws IOException
IOException
private void updateAssignmentManagerMetrics(HbckReport report)
public boolean isRunning()
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.