You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by te...@apache.org on 2016/06/27 13:30:06 UTC
hbase git commit: HBASE-16109 Add Interface audience annotation to a
few classes
Repository: hbase
Updated Branches:
refs/heads/master e05f52799 -> ba9286911
HBASE-16109 Add Interface audience annotation to a few classes
Project: http://git-wip-us.apache.org/repos/asf/hbase/repo
Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/ba928691
Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/ba928691
Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/ba928691
Branch: refs/heads/master
Commit: ba9286911fc08a1e2c3ec1c7e470fc77a5cade88
Parents: e05f527
Author: tedyu <yu...@gmail.com>
Authored: Mon Jun 27 06:29:04 2016 -0700
Committer: tedyu <yu...@gmail.com>
Committed: Mon Jun 27 06:29:04 2016 -0700
----------------------------------------------------------------------
.../hadoop/hbase/regionserver/FlushAllLargeStoresPolicy.java | 3 +++
.../hbase/regionserver/FlushNonSloppyStoresFirstPolicy.java | 4 ++++
.../org/apache/hadoop/hbase/regionserver/MemStoreCompactor.java | 2 ++
3 files changed, 9 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/hbase/blob/ba928691/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/FlushAllLargeStoresPolicy.java
----------------------------------------------------------------------
diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/FlushAllLargeStoresPolicy.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/FlushAllLargeStoresPolicy.java
index 362d0f9..bb57869 100644
--- a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/FlushAllLargeStoresPolicy.java
+++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/FlushAllLargeStoresPolicy.java
@@ -23,11 +23,14 @@ import java.util.Set;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
+import org.apache.hadoop.hbase.HBaseInterfaceAudience;
+import org.apache.hadoop.hbase.classification.InterfaceAudience;
/**
* A {@link FlushPolicy} that only flushes store larger a given threshold. If no store is large
* enough, then all stores will be flushed.
*/
+@InterfaceAudience.LimitedPrivate(HBaseInterfaceAudience.CONFIG)
public class FlushAllLargeStoresPolicy extends FlushLargeStoresPolicy{
private static final Log LOG = LogFactory.getLog(FlushAllLargeStoresPolicy.class);
http://git-wip-us.apache.org/repos/asf/hbase/blob/ba928691/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/FlushNonSloppyStoresFirstPolicy.java
----------------------------------------------------------------------
diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/FlushNonSloppyStoresFirstPolicy.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/FlushNonSloppyStoresFirstPolicy.java
index 2921f23..ea4a193 100644
--- a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/FlushNonSloppyStoresFirstPolicy.java
+++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/FlushNonSloppyStoresFirstPolicy.java
@@ -20,12 +20,16 @@ package org.apache.hadoop.hbase.regionserver;
import java.util.Collection;
import java.util.HashSet;
+import org.apache.hadoop.hbase.HBaseInterfaceAudience;
+import org.apache.hadoop.hbase.classification.InterfaceAudience;
+
/**
* A {@link FlushPolicy} that only flushes store larger than a given threshold. If no store is large
* enough, then all stores will be flushed.
* Gives priority to selecting regular stores first, and only if no other
* option, selects sloppy stores which normaly require more memory.
*/
+@InterfaceAudience.LimitedPrivate(HBaseInterfaceAudience.CONFIG)
public class FlushNonSloppyStoresFirstPolicy extends FlushLargeStoresPolicy {
private Collection<Store> regularStores = new HashSet<>();
http://git-wip-us.apache.org/repos/asf/hbase/blob/ba928691/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/MemStoreCompactor.java
----------------------------------------------------------------------
diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/MemStoreCompactor.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/MemStoreCompactor.java
index 88e067e..5b2876d 100644
--- a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/MemStoreCompactor.java
+++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/MemStoreCompactor.java
@@ -22,6 +22,7 @@ import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.apache.hadoop.hbase.Cell;
import org.apache.hadoop.hbase.HConstants;
+import org.apache.hadoop.hbase.classification.InterfaceAudience;
import org.apache.hadoop.hbase.client.Scan;
import java.io.IOException;
@@ -38,6 +39,7 @@ import java.util.concurrent.atomic.AtomicBoolean;
* Threads safety: It is assumed that the compaction pipeline is immutable,
* therefore no special synchronization is required.
*/
+@InterfaceAudience.Private
class MemStoreCompactor {
private static final Log LOG = LogFactory.getLog(MemStoreCompactor.class);