Apache
/
hbase
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

HBASE-12758 treat mob region as any other region when generating rs manifest

This commit is contained in:
Jonathan M Hsieh 2014-12-24 08:18:48 -08:00
parent 533aa52d83
commit 9f1f8c3bc6
1 changed files with 15 additions and 16 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

31
hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegion.java
View File

@ -2994,28 +2994,27 @@ public class HRegion implements HeapSize { // , Writable{
Path rootDir = FSUtils.getRootDir(conf); Path rootDir = FSUtils.getRootDir(conf);
Path snapshotDir = SnapshotDescriptionUtils.getWorkingSnapshotDir(desc, rootDir); Path snapshotDir = SnapshotDescriptionUtils.getWorkingSnapshotDir(desc, rootDir);
if (Bytes.equals(getStartKey(), HConstants.EMPTY_START_ROW)) { SnapshotManifest manifest = SnapshotManifest.create(conf, getFilesystem(),
Map<byte[], Store> stores = getStores();
boolean hasMobStore = false;
for (Entry<byte[], Store> store : stores.entrySet()) {
hasMobStore = store.getValue().getFamily().isMobEnabled();
if (hasMobStore) {
break;
}
}
if (hasMobStore) {
// if this is the first region, snapshot the mob files.
SnapshotManifest snapshotManifest = SnapshotManifest.create(conf, getFilesystem(),
snapshotDir, desc, exnSnare); snapshotDir, desc, exnSnare);
manifest.addRegion(this);
// The regionserver holding the first region of the table is responsible for taking the
// manifest of the mob dir.
if (!Bytes.equals(getStartKey(), HConstants.EMPTY_START_ROW))
return;
// if any cf's have is mob enabled, add the "mob region" to the manifest.
Map<byte[], Store> stores = getStores();
for (Entry<byte[], Store> store : stores.entrySet()) {
boolean hasMobStore = store.getValue().getFamily().isMobEnabled();
if (hasMobStore) {
// use the .mob as the start key and 0 as the regionid // use the .mob as the start key and 0 as the regionid
HRegionInfo mobRegionInfo = MobUtils.getMobRegionInfo(this.getTableDesc().getTableName()); HRegionInfo mobRegionInfo = MobUtils.getMobRegionInfo(this.getTableDesc().getTableName());
mobRegionInfo.setOffline(true); mobRegionInfo.setOffline(true);
snapshotManifest.addMobRegion(mobRegionInfo, this.getTableDesc().getColumnFamilies()); manifest.addMobRegion(mobRegionInfo, this.getTableDesc().getColumnFamilies());
return;
} }
} }
SnapshotManifest manifest = SnapshotManifest.create(conf, getFilesystem(),
snapshotDir, desc, exnSnare);
manifest.addRegion(this);
} }
/** /**