org.apache.hadoop.hbase.master

Class MetaFixer

java.lang.Object

org.apache.hadoop.hbase.master.MetaFixer

@InterfaceAudience.Private
class MetaFixer
extends Object

Server-side fixing of bad or inconsistent state in hbase:meta. Distinct from MetaTableAccessor because MetaTableAccessor is about low-level manipulations driven by the Master. This class MetaFixer is employed by the Master and it 'knows' about holes and orphans and encapsulates their fixing on behalf of the Master.

Field Summary

Fields

Modifier and Type	Field and Description
private static org.slf4j.Logger	LOG
private MasterServices	masterServices
private static int	MAX_MERGE_COUNT_DEFAULT
private static String	MAX_MERGE_COUNT_KEY
private int	maxMergeCount Maximum for many regions to merge at a time.

Constructor Summary

Constructors

Constructor and Description
MetaFixer(MasterServices masterServices)

Method Summary

Modifier and Type	Method and Description
private RegionInfo	buildRegionInfo(TableName tn, byte[] start, byte[] end)
(package private) static List<SortedSet<RegionInfo>>	calculateMerges(int maxMergeCount, List<Pair<RegionInfo,RegionInfo>> overlaps) Run through overlaps and return a list of merges to run.
(package private) void	fix()
(package private) void	fixHoles(CatalogJanitor.Report report) If hole, it papers it over by adding a region in the filesystem and to hbase:meta.
(package private) void	fixOverlaps(CatalogJanitor.Report report) Fix overlaps noted in CJ consistency report.
private RegionInfo	getHoleCover(Pair<RegionInfo,RegionInfo> hole)
(package private) static RegionInfo	getRegionInfoWithLargestEndKey(RegionInfo a, RegionInfo b)
(package private) static boolean	isOverlap(RegionInfo ri, Pair<RegionInfo,RegionInfo> pair)

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

MAX_MERGE_COUNT_KEY

private static final String MAX_MERGE_COUNT_KEY

See Also:

Constant Field Values

MAX_MERGE_COUNT_DEFAULT

private static final int MAX_MERGE_COUNT_DEFAULT

See Also:

Constant Field Values

masterServices

private final MasterServices masterServices

maxMergeCount

private final int maxMergeCount

Maximum for many regions to merge at a time.

Constructor Detail

MetaFixer

MetaFixer(MasterServices masterServices)

Method Detail

fix

void fix()
  throws IOException

Throws:

IOException

fixHoles

void fixHoles(CatalogJanitor.Report report)
       throws IOException

If hole, it papers it over by adding a region in the filesystem and to hbase:meta. Does not assign.

Throws:

IOException

getHoleCover

private RegionInfo getHoleCover(Pair<RegionInfo,RegionInfo> hole)

Returns:

Calculated RegionInfo that covers the hole hole

buildRegionInfo

private RegionInfo buildRegionInfo(TableName tn,
                                   byte[] start,
                                   byte[] end)

fixOverlaps

void fixOverlaps(CatalogJanitor.Report report)
          throws IOException

Fix overlaps noted in CJ consistency report.

Throws:

IOException

calculateMerges

static List<SortedSet<RegionInfo>> calculateMerges(int maxMergeCount,
                                                   List<Pair<RegionInfo,RegionInfo>> overlaps)

Run through overlaps and return a list of merges to run. Presumes overlaps are ordered (which they are coming out of the CatalogJanitor consistency report).

Parameters:

maxMergeCount - Maximum regions to merge at a time (avoid merging 100k regions in one go!)

getRegionInfoWithLargestEndKey

static RegionInfo getRegionInfoWithLargestEndKey(RegionInfo a,
                                                 RegionInfo b)

Returns:

Either a or b, whichever has the endkey that is furthest along in the Table.

isOverlap

static boolean isOverlap(RegionInfo ri,
                         Pair<RegionInfo,RegionInfo> pair)

Returns:

True if an overlap found between passed in ri and the pair. Does NOT check the pairs themselves overlap.