static class CatalogJanitor.ReportMakingVisitor extends Object implements MetaTableAccessor.CloseableVisitor
close()
'd.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 RegionInfo |
previous
RegionInfo from previous row.
|
private CatalogJanitor.Report |
report
Report is not done until after the close has been called.
|
private MasterServices |
services |
Constructor and Description |
---|
ReportMakingVisitor(MasterServices services) |
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) CatalogJanitor.Report |
getReport()
Do not call until after
close() . |
(package private) boolean |
isTableDisabled(RegionInfo ri) |
private boolean |
isTableTransition(RegionInfo ri) |
private RegionInfo |
metaTableConsistencyCheck(Result metaTableRow)
Check row.
|
boolean |
visit(Result r)
Visit the catalog table row.
|
private final MasterServices services
private volatile boolean closed
private CatalogJanitor.Report report
close()
,
getReport()
private RegionInfo previous
private RegionInfo highestEndKeyRegionInfo
ReportMakingVisitor(MasterServices services)
CatalogJanitor.Report getReport()
close()
.
Will throw a RuntimeException
if you do.public boolean visit(Result r)
MetaTableAccessor.Visitor
visit
in interface MetaTableAccessor.Visitor
r
- A row from catalog tableprivate RegionInfo metaTableConsistencyCheck(Result metaTableRow)
metaTableRow
- Row from hbase:meta table.private void addOverlap(RegionInfo a, RegionInfo b)
private void addHole(RegionInfo a, RegionInfo b)
boolean isTableDisabled(RegionInfo ri)
private void checkServer(RegionLocations locations)
private boolean isTableTransition(RegionInfo ri)
public void close() throws IOException
close
in interface Closeable
close
in interface AutoCloseable
IOException
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.