You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by bu...@apache.org on 2020/02/15 00:56:44 UTC
[hbase] 16/16: whitespace checkstyle
This is an automated email from the ASF dual-hosted git repository.
busbey pushed a commit to branch HBASE-22749
in repository https://gitbox.apache.org/repos/asf/hbase.git
commit 8a030cddf76f3b84e6687aa4632ae81b8c1511bd
Author: Vladimir Rodionov <vl...@gmail.com>
AuthorDate: Fri Feb 14 16:09:15 2020 -0800
whitespace checkstyle
---
.../apache/hadoop/hbase/mob/DefaultMobStoreCompactor.java | 14 +++++++-------
.../main/java/org/apache/hadoop/hbase/mob/MobFileName.java | 3 +--
2 files changed, 8 insertions(+), 9 deletions(-)
diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/mob/DefaultMobStoreCompactor.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/mob/DefaultMobStoreCompactor.java
index 53d9479..391522f 100644
--- a/hbase-server/src/main/java/org/apache/hadoop/hbase/mob/DefaultMobStoreCompactor.java
+++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/mob/DefaultMobStoreCompactor.java
@@ -98,15 +98,15 @@ public class DefaultMobStoreCompactor extends DefaultCompactor {
}
};
-
+
/*
* Disable IO mode. IO mode can be forcefully disabled if compactor finds
- * old MOB file (pre-distributed compaction). This means that migration has not
+ * old MOB file (pre-distributed compaction). This means that migration has not
* been completed yet. During data migration (upgrade) process only general compaction
* is allowed.
- *
+ *
*/
-
+
static ThreadLocal<Boolean> disableIO = new ThreadLocal<Boolean>() {
@Override
@@ -114,7 +114,7 @@ public class DefaultMobStoreCompactor extends DefaultCompactor {
return Boolean.FALSE;
}
};
-
+
/*
* Map : MOB file name - file length Can be expensive for large amount of MOB files.
*/
@@ -277,8 +277,8 @@ public class DefaultMobStoreCompactor extends DefaultCompactor {
long maxMobFileSize = conf.getLong(MobConstants.MOB_COMPACTION_MAX_FILE_SIZE_KEY,
MobConstants.DEFAULT_MOB_COMPACTION_MAX_FILE_SIZE);
boolean ioOptimizedMode = this.ioOptimizedMode && !disableIO.get();
- LOG.info("Compact MOB={} optimized configured={} optimized enabled={} maximum MOB file size={} "+
- "major={} store={}", compactMOBs,
+ LOG.info("Compact MOB={} optimized configured={} optimized enabled={} maximum MOB file size={}"
+ + " major={} store={}", compactMOBs,
this.ioOptimizedMode, ioOptimizedMode, maxMobFileSize, major, getStoreInfo());
// Since scanner.next() can return 'false' but still be delivering data,
// we have to use a do/while loop.
diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/mob/MobFileName.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/mob/MobFileName.java
index 00668d5..73bb07a 100644
--- a/hbase-server/src/main/java/org/apache/hadoop/hbase/mob/MobFileName.java
+++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/mob/MobFileName.java
@@ -133,11 +133,10 @@ public final class MobFileName{
return new MobFileName(startKey, date, uuid, regionName);
}
-
public static boolean isOldMobFileName(String name) {
return name.indexOf(REGION_SEP) < 0;
}
-
+
/**
* get startKey from MobFileName.
* @param fileName file name.