org.apache.hadoop.hbase.master.janitor

Class ReportMakingVisitor

java.lang.Object

org.apache.hadoop.hbase.master.janitor.ReportMakingVisitor

All Implemented Interfaces:

Closeable, AutoCloseable, MetaTableAccessor.CloseableVisitor, MetaTableAccessor.Visitor

@InterfaceAudience.Private
class ReportMakingVisitor
extends Object
implements MetaTableAccessor.CloseableVisitor

Visitor we use in here in CatalogJanitor to go against hbase:meta table. Generates a Report made of a collection of split parents and counts of rows in the hbase:meta table. Also runs hbase:meta consistency checks to generate more report. Report is NOT ready until after this visitor has been close()'d.

Field Summary

Fields

Modifier and Type	Field and Description
private boolean	closed
private RegionInfo	highestEndKeyRegionInfo Keep account of the highest end key seen as we move through hbase:meta.
private static org.slf4j.Logger	LOG
private RegionInfo	previous RegionInfo from previous row.
private CatalogJanitorReport	report Report is not done until after the close has been called.
private MasterServices	services

Constructor Summary

Constructors

Constructor and Description
ReportMakingVisitor(MasterServices services)

Method Summary

Modifier and Type	Method and Description
private void	addHole(RegionInfo a, RegionInfo b)
private void	addOverlap(RegionInfo a, RegionInfo b)
private void	checkServer(RegionLocations locations) Run through referenced servers and save off unknown and the dead.
void	close()
(package private) CatalogJanitorReport	getReport() Do not call until after close().
(package private) boolean	isTableDisabled(RegionInfo ri) Returns True if table is disabled or disabling; defaults false!
private boolean	isTableTransition(RegionInfo ri) Returns True iff first row in hbase:meta or if we've broached a new table in hbase:meta
private RegionInfo	metaTableConsistencyCheck(Result metaTableRow) Check row.
boolean	visit(Result r) Visit the catalog table row.

Methods inherited from class java.lang.Object

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

Field Detail

LOG

private static final org.slf4j.Logger LOG

services

private final MasterServices services

closed

private volatile boolean closed

report

private CatalogJanitorReport report

Report is not done until after the close has been called.

previous

private RegionInfo previous

RegionInfo from previous row.

highestEndKeyRegionInfo

private RegionInfo highestEndKeyRegionInfo

Keep account of the highest end key seen as we move through hbase:meta. Usually, the current RegionInfo has the highest end key but if an overlap, this may no longer hold. An overlap may be a region with startkey 'd' and endkey 'g'. The next region in meta may be 'e' to 'f' and then 'f' to 'g'. Looking at previous and current meta row, we won't know about the 'd' to 'g' overlap unless we keep a running 'highest-endpoint-seen'.

Constructor Detail

ReportMakingVisitor

ReportMakingVisitor(MasterServices services)

Method Detail

getReport

CatalogJanitorReport getReport()

Do not call until after close(). Will throw a RuntimeException if you do.

visit

public boolean visit(Result r)

Description copied from interface: MetaTableAccessor.Visitor

Visit the catalog table row.

Specified by:

visit in interface MetaTableAccessor.Visitor

Parameters:

r - A row from catalog table

Returns:

True if we are to proceed scanning the table, else false if we are to stop now.

metaTableConsistencyCheck

private RegionInfo metaTableConsistencyCheck(Result metaTableRow)

Check row.

Parameters:

metaTableRow - Row from hbase:meta table.

Returns:

Returns default regioninfo found in row parse as a convenience to save on having to do a double-parse of Result.

addOverlap

private void addOverlap(RegionInfo a,
                        RegionInfo b)

addHole

private void addHole(RegionInfo a,
                     RegionInfo b)

isTableDisabled

boolean isTableDisabled(RegionInfo ri)

Returns True if table is disabled or disabling; defaults false!

checkServer

private void checkServer(RegionLocations locations)

Run through referenced servers and save off unknown and the dead.

isTableTransition

private boolean isTableTransition(RegionInfo ri)

Returns True iff first row in hbase:meta or if we've broached a new table in hbase:meta

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Throws:

IOException