Package org.apache.hadoop.hbase.master.hbck

Class HbckChore

java.lang.Object

org.apache.hadoop.hbase.ScheduledChore

org.apache.hadoop.hbase.master.hbck.HbckChore

All Implemented Interfaces:

Runnable

@Private
@Evolving
public class HbckChore
extends ScheduledChore

Used to do the hbck checking job at master side.

Field Summary

Fields

Modifier and Type	Field	Description
private static final int	DEFAULT_HBCK_CHORE_INTERVAL
private boolean	disabled
private static final String	HBCK_CHORE_INTERVAL
private HbckReport	lastReport	Saved report from last time this chore ran.
private static final org.slf4j.Logger	LOG
private final MasterServices	master
private boolean	running	When running, the "snapshot" may be changed when this round's checking finish.

Constructor Summary

Constructors

Constructor	Description
HbckChore(MasterServices master)

Method Summary

Modifier and Type	Method	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)

Methods inherited from class org.apache.hadoop.hbase.ScheduledChore

cancel, cancel, choreForTesting, cleanup, getInitialDelay, getName, getPeriod, getStopper, getTimeUnit, initialChore, isInitialChoreComplete, isScheduled, run, shutdown, shutdown, toString, triggerNow

Methods inherited from class java.lang.Object

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

Field Details

LOG

private static final org.slf4j.Logger LOG

HBCK_CHORE_INTERVAL

private static final String HBCK_CHORE_INTERVAL

See Also:

• Constant Field Values

DEFAULT_HBCK_CHORE_INTERVAL

private static final int DEFAULT_HBCK_CHORE_INTERVAL

See Also:

• Constant Field Values

master

private final MasterServices master

lastReport

private volatile HbckReport lastReport

Saved report from last time this chore ran. Check its date.

running

private volatile boolean running

When running, the "snapshot" may be changed when this round's checking finish.

disabled

private boolean disabled

Constructor Details

HbckChore

public HbckChore(MasterServices master)

Method Details

getLastReport

public HbckReport getLastReport()

Returns Returns last published Report that comes of last successful execution of this chore.

chore

protected void chore()

Description copied from class: ScheduledChore

The task to execute on each scheduled execution of the Chore

Specified by:

chore in class ScheduledChore

runChore

public boolean runChore()

Request execution of this chore's action.

Returns:

true if the chore was executed, false if the chore is disabled or already running.

disableChore

private void disableChore()

isDisabled

public boolean isDisabled()

scanForMergedParentRegions

private HashSet<String> scanForMergedParentRegions()
                                            throws IOException

Scan hbase:meta to get set of merged parent regions, this is a very heavy scan.

Returns:

Return generated HashSet

Throws:

IOException

loadRegionsFromInMemoryState

private void loadRegionsFromInMemoryState(HbckReport report)

loadRegionsFromRSReport

private void loadRegionsFromRSReport(HbckReport report)

loadRegionsFromFS

private void loadRegionsFromFS(HashSet<String> mergedParentRegions,
 HbckReport report)
                        throws IOException

Throws:

IOException

updateAssignmentManagerMetrics

private void updateAssignmentManagerMetrics(HbckReport report)

isRunning

public boolean isRunning()

When running, the HBCK report may be changed later.