diff --git a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/MasterCallable.java b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/MasterCallable.java index 950b1d3bb0f..f56ebd54f76 100644 --- a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/MasterCallable.java +++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/MasterCallable.java @@ -27,6 +27,7 @@ import org.apache.hadoop.hbase.ipc.HBaseRpcController; import org.apache.hadoop.hbase.ipc.RpcControllerFactory; import org.apache.hadoop.hbase.shaded.protobuf.ProtobufUtil; import org.apache.hadoop.hbase.util.Bytes; +import org.apache.yetus.audience.InterfaceAudience; /** * A RetryingCallable for Master RPC operations. @@ -41,6 +42,7 @@ import org.apache.hadoop.hbase.util.Bytes; * it has to deal with Coprocessor Endpoints. * @param return type */ +@InterfaceAudience.Private abstract class MasterCallable implements RetryingCallable, Closeable { protected final ClusterConnection connection; protected MasterKeepAliveConnection master; diff --git a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/MasterKeepAliveConnection.java b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/MasterKeepAliveConnection.java index 1dc3a479cc4..b1c37776f9e 100644 --- a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/MasterKeepAliveConnection.java +++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/MasterKeepAliveConnection.java @@ -21,6 +21,7 @@ package org.apache.hadoop.hbase.client; import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos; +import org.apache.yetus.audience.InterfaceAudience; /** * A KeepAlive connection is not physically closed immediately after the close, @@ -33,6 +34,7 @@ import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos; * against the master on the MasterProtos.MasterService.BlockingInterface; but not by * final user code. Hence it's package protected. */ +@InterfaceAudience.Private interface MasterKeepAliveConnection extends MasterProtos.MasterService.BlockingInterface { // Do this instead of implement Closeable because closeable returning IOE is PITA. void close(); diff --git a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/ShortCircuitMasterConnection.java b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/ShortCircuitMasterConnection.java index 527f7222bf4..d9277c6348e 100644 --- a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/ShortCircuitMasterConnection.java +++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/ShortCircuitMasterConnection.java @@ -173,7 +173,7 @@ import org.apache.hadoop.hbase.shaded.protobuf.generated.ReplicationProtos.Updat * A short-circuit connection that can bypass the RPC layer (serialization, deserialization, * networking, etc..) when talking to a local master */ -@InterfaceAudience.Public +@InterfaceAudience.Private public class ShortCircuitMasterConnection implements MasterKeepAliveConnection { private final MasterService.BlockingInterface stub;