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

HBASE-16109 Add Interface audience annotation to a few classes

This commit is contained in:
tedyu 2016-06-27 06:29:04 -07:00
parent e05f527991
commit ba9286911f
3 changed files with 9 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/FlushAllLargeStoresPolicy.java
View File

@ -23,11 +23,14 @@ import java.util.Set;
import org.apache.commons.logging.Log; import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory; 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 * A {@link FlushPolicy} that only flushes store larger a given threshold. If no store is large
* enough, then all stores will be flushed. * enough, then all stores will be flushed.
*/ */
@InterfaceAudience.LimitedPrivate(HBaseInterfaceAudience.CONFIG)
public class FlushAllLargeStoresPolicy extends FlushLargeStoresPolicy{ public class FlushAllLargeStoresPolicy extends FlushLargeStoresPolicy{
private static final Log LOG = LogFactory.getLog(FlushAllLargeStoresPolicy.class); private static final Log LOG = LogFactory.getLog(FlushAllLargeStoresPolicy.class);

4
hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/FlushNonSloppyStoresFirstPolicy.java
View File

@ -20,12 +20,16 @@ package org.apache.hadoop.hbase.regionserver;
import java.util.Collection; import java.util.Collection;
import java.util.HashSet; 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 * A {@link FlushPolicy} that only flushes store larger than a given threshold. If no store is large
* enough, then all stores will be flushed. * enough, then all stores will be flushed.
* Gives priority to selecting regular stores first, and only if no other * Gives priority to selecting regular stores first, and only if no other
* option, selects sloppy stores which normaly require more memory. * option, selects sloppy stores which normaly require more memory.
*/ */
@InterfaceAudience.LimitedPrivate(HBaseInterfaceAudience.CONFIG)
public class FlushNonSloppyStoresFirstPolicy extends FlushLargeStoresPolicy { public class FlushNonSloppyStoresFirstPolicy extends FlushLargeStoresPolicy {
private Collection<Store> regularStores = new HashSet<>(); private Collection<Store> regularStores = new HashSet<>();

2
hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/MemStoreCompactor.java
View File

@ -22,6 +22,7 @@ import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory; import org.apache.commons.logging.LogFactory;
import org.apache.hadoop.hbase.Cell; import org.apache.hadoop.hbase.Cell;
import org.apache.hadoop.hbase.HConstants; import org.apache.hadoop.hbase.HConstants;
import org.apache.hadoop.hbase.classification.InterfaceAudience;
import org.apache.hadoop.hbase.client.Scan; import org.apache.hadoop.hbase.client.Scan;
import java.io.IOException; 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, * Threads safety: It is assumed that the compaction pipeline is immutable,
* therefore no special synchronization is required. * therefore no special synchronization is required.
*/ */
@InterfaceAudience.Private
class MemStoreCompactor { class MemStoreCompactor {
private static final Log LOG = LogFactory.getLog(MemStoreCompactor.class); private static final Log LOG = LogFactory.getLog(MemStoreCompactor.class);