From ba9286911fc08a1e2c3ec1c7e470fc77a5cade88 Mon Sep 17 00:00:00 2001
From: tedyu <yuzhihong@gmail.com>
Date: Mon, 27 Jun 2016 06:29:04 -0700
Subject: [PATCH] HBASE-16109 Add Interface audience annotation to a few
 classes

---
 .../hadoop/hbase/regionserver/FlushAllLargeStoresPolicy.java  | 3 +++
 .../hbase/regionserver/FlushNonSloppyStoresFirstPolicy.java   | 4 ++++
 .../apache/hadoop/hbase/regionserver/MemStoreCompactor.java   | 2 ++
 3 files changed, 9 insertions(+)

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<Store> 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);