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 362d0f96fa5..bb57869bb38 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); 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 2921f236111..ea4a193a92b 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 regularStores = new HashSet<>(); 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 88e067e472d..5b2876d1dff 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);