From 20d272bce56ba8e586feceb710da159f288aa1e8 Mon Sep 17 00:00:00 2001 From: Michael Stack Date: Fri, 25 Aug 2017 13:12:20 -0700 Subject: [PATCH] HBASE-18687 Add @since 2.0.0 to new classes --- .../java/org/apache/hadoop/hbase/AsyncMetaTableAccessor.java | 1 + .../main/java/org/apache/hadoop/hbase/client/AsyncAdmin.java | 1 + .../java/org/apache/hadoop/hbase/client/AsyncAdminBuilder.java | 1 + .../hadoop/hbase/client/AsyncAdminRequestRetryingCaller.java | 3 +++ .../java/org/apache/hadoop/hbase/client/AsyncConnection.java | 1 + .../java/org/apache/hadoop/hbase/client/AsyncHBaseAdmin.java | 1 + .../hbase/client/AsyncMasterRequestRpcRetryingCaller.java | 1 + .../org/apache/hadoop/hbase/client/AsyncRequestFuture.java | 3 ++- .../hadoop/hbase/client/AsyncRpcRetryingCallerFactory.java | 1 + .../main/java/org/apache/hadoop/hbase/client/AsyncTable.java | 1 + .../java/org/apache/hadoop/hbase/client/AsyncTableBase.java | 1 + .../java/org/apache/hadoop/hbase/client/AsyncTableBuilder.java | 1 + .../apache/hadoop/hbase/client/AsyncTableRegionLocator.java | 1 + .../org/apache/hadoop/hbase/client/BatchScanResultCache.java | 1 + .../org/apache/hadoop/hbase/client/ColumnFamilyDescriptor.java | 1 + .../hadoop/hbase/client/ColumnFamilyDescriptorBuilder.java | 3 +++ .../org/apache/hadoop/hbase/client/RawAsyncHBaseAdmin.java | 1 + .../java/org/apache/hadoop/hbase/client/RawAsyncTable.java | 1 + .../org/apache/hadoop/hbase/client/RawScanResultConsumer.java | 1 + .../org/apache/hadoop/hbase/client/TableDescriptorBuilder.java | 3 +++ .../main/java/org/apache/hadoop/hbase/ipc/NettyRpcClient.java | 1 + .../apache/hadoop/hbase/ipc/NettyRpcClientConfigHelper.java | 1 + .../java/org/apache/hadoop/hbase/ipc/NettyRpcConnection.java | 1 + .../org/apache/hadoop/hbase/ipc/NettyRpcDuplexHandler.java | 1 + .../hbase/security/NettyHBaseRpcConnectionHeaderHandler.java | 1 + .../apache/hadoop/hbase/security/NettyHBaseSaslRpcClient.java | 1 + .../hadoop/hbase/security/NettyHBaseSaslRpcClientHandler.java | 1 + .../main/java/org/apache/hadoop/hbase/ipc/NettyRpcServer.java | 1 + .../apache/hadoop/hbase/ipc/NettyRpcServerPreambleHandler.java | 1 + .../apache/hadoop/hbase/ipc/NettyRpcServerRequestDecoder.java | 1 + .../apache/hadoop/hbase/ipc/NettyRpcServerResponseEncoder.java | 1 + .../main/java/org/apache/hadoop/hbase/ipc/NettyServerCall.java | 1 + .../org/apache/hadoop/hbase/ipc/NettyServerRpcConnection.java | 1 + .../apache/hadoop/hbase/wal/NettyAsyncFSWALConfigHelper.java | 1 + 34 files changed, 41 insertions(+), 1 deletion(-) diff --git a/hbase-client/src/main/java/org/apache/hadoop/hbase/AsyncMetaTableAccessor.java b/hbase-client/src/main/java/org/apache/hadoop/hbase/AsyncMetaTableAccessor.java index 1018d7a85ad..232212a2f99 100644 --- a/hbase-client/src/main/java/org/apache/hadoop/hbase/AsyncMetaTableAccessor.java +++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/AsyncMetaTableAccessor.java @@ -56,6 +56,7 @@ import org.apache.hadoop.hbase.util.Pair; /** * The asynchronous meta table accessor. Used to read/write region and assignment information store * in hbase:meta. + * @since 2.0.0 */ @InterfaceAudience.Private public class AsyncMetaTableAccessor { diff --git a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/AsyncAdmin.java b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/AsyncAdmin.java index 4b3381247c8..bdd047d6328 100644 --- a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/AsyncAdmin.java +++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/AsyncAdmin.java @@ -52,6 +52,7 @@ import com.google.protobuf.RpcChannel; *

* This feature is still under development, so marked as IA.Private. Will change to public when * done. Use it with caution. + * @since 2.0.0 */ @InterfaceAudience.Public public interface AsyncAdmin { diff --git a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/AsyncAdminBuilder.java b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/AsyncAdminBuilder.java index fb0aefdc498..7347ebf7b30 100644 --- a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/AsyncAdminBuilder.java +++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/AsyncAdminBuilder.java @@ -27,6 +27,7 @@ import org.apache.hadoop.hbase.classification.InterfaceAudience; * For creating {@link AsyncAdmin}. The implementation should have default configurations set before * returning the builder to user. So users are free to only set the configs they care about to * create a new AsyncAdmin instance. + * @since 2.0.0 */ @InterfaceAudience.Public public interface AsyncAdminBuilder { diff --git a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/AsyncAdminRequestRetryingCaller.java b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/AsyncAdminRequestRetryingCaller.java index 2871c4d1d64..bf6d62d5584 100644 --- a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/AsyncAdminRequestRetryingCaller.java +++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/AsyncAdminRequestRetryingCaller.java @@ -26,6 +26,9 @@ import org.apache.hadoop.hbase.classification.InterfaceAudience; import org.apache.hadoop.hbase.ipc.HBaseRpcController; import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.AdminService; +/** + * @since 2.0.0 + */ @InterfaceAudience.Private public class AsyncAdminRequestRetryingCaller extends AsyncRpcRetryingCaller { diff --git a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/AsyncConnection.java b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/AsyncConnection.java index 8d26368099b..2b7e7024e94 100644 --- a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/AsyncConnection.java +++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/AsyncConnection.java @@ -26,6 +26,7 @@ import org.apache.hadoop.hbase.classification.InterfaceAudience; /** * The asynchronous version of Connection. + * @since 2.0.0 */ @InterfaceAudience.Public public interface AsyncConnection extends Closeable { diff --git a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/AsyncHBaseAdmin.java b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/AsyncHBaseAdmin.java index 097f22a1d22..df077fcdea3 100644 --- a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/AsyncHBaseAdmin.java +++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/AsyncHBaseAdmin.java @@ -58,6 +58,7 @@ import com.google.protobuf.RpcChannel; /** * The implementation of AsyncAdmin. + * @since 2.0.0 */ @InterfaceAudience.Private public class AsyncHBaseAdmin implements AsyncAdmin { diff --git a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/AsyncMasterRequestRpcRetryingCaller.java b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/AsyncMasterRequestRpcRetryingCaller.java index 7a598d7850e..2715eabfa3c 100644 --- a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/AsyncMasterRequestRpcRetryingCaller.java +++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/AsyncMasterRequestRpcRetryingCaller.java @@ -27,6 +27,7 @@ import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.MasterServ /** * Retry caller for a request call to master. + * @since 2.0.0 */ @InterfaceAudience.Private public class AsyncMasterRequestRpcRetryingCaller extends AsyncRpcRetryingCaller { diff --git a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/AsyncRequestFuture.java b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/AsyncRequestFuture.java index 539e2345697..f439ca016e2 100644 --- a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/AsyncRequestFuture.java +++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/AsyncRequestFuture.java @@ -28,7 +28,8 @@ import java.util.List; * 1) If AsyncProcess is set to track errors globally, and not per call (for HTable puts), * then errors and failed operations in this object will reflect global errors. * 2) If submit call is made with needResults false, results will not be saved. - * */ + * @since 2.0.0 + */ @InterfaceAudience.Private public interface AsyncRequestFuture { public boolean hasError(); diff --git a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/AsyncRpcRetryingCallerFactory.java b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/AsyncRpcRetryingCallerFactory.java index 1aa3fbd2b3e..6cb286a99f0 100644 --- a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/AsyncRpcRetryingCallerFactory.java +++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/AsyncRpcRetryingCallerFactory.java @@ -38,6 +38,7 @@ import org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ScanRespon /** * Factory to create an AsyncRpcRetryCaller. + * @since 2.0.0 */ @InterfaceAudience.Private class AsyncRpcRetryingCallerFactory { diff --git a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/AsyncTable.java b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/AsyncTable.java index a2e193cd67a..9cea8d4265a 100644 --- a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/AsyncTable.java +++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/AsyncTable.java @@ -27,6 +27,7 @@ import org.apache.hadoop.hbase.classification.InterfaceAudience; * The implementation should make sure that user can do everything they want to the returned * {@code CompletableFuture} without breaking anything. Usually the implementation will require user * to provide a {@code ExecutorService}. + * @since 2.0.0 */ @InterfaceAudience.Public public interface AsyncTable extends AsyncTableBase { diff --git a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/AsyncTableBase.java b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/AsyncTableBase.java index 006e3e29da4..d5250863f03 100644 --- a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/AsyncTableBase.java +++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/AsyncTableBase.java @@ -41,6 +41,7 @@ import org.apache.hadoop.hbase.util.Bytes; *

* Usually the implementation will not throw any exception directly. You need to get the exception * from the returned {@link CompletableFuture}. + * @since 2.0.0 */ @InterfaceAudience.Public public interface AsyncTableBase { diff --git a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/AsyncTableBuilder.java b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/AsyncTableBuilder.java index 1cc5f10229a..8d137b4c417 100644 --- a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/AsyncTableBuilder.java +++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/AsyncTableBuilder.java @@ -29,6 +29,7 @@ import org.apache.hadoop.hbase.classification.InterfaceAudience; * The implementation should have default configurations set before returning the builder to user. * So users are free to only set the configs they care about to create a new * AsyncTable/RawAsyncTable instance. + * @since 2.0.0 */ @InterfaceAudience.Public public interface AsyncTableBuilder { diff --git a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/AsyncTableRegionLocator.java b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/AsyncTableRegionLocator.java index 13434a683ad..c3bc4e21782 100644 --- a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/AsyncTableRegionLocator.java +++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/AsyncTableRegionLocator.java @@ -28,6 +28,7 @@ import org.apache.hadoop.hbase.classification.InterfaceAudience; *

* Usually the implementations will not throw any exception directly, you need to get the exception * from the returned {@link CompletableFuture}. + * @since 2.0.0 */ @InterfaceAudience.Public public interface AsyncTableRegionLocator { diff --git a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/BatchScanResultCache.java b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/BatchScanResultCache.java index 293f4117dc0..7c88b7fad69 100644 --- a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/BatchScanResultCache.java +++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/BatchScanResultCache.java @@ -36,6 +36,7 @@ import org.apache.hadoop.hbase.util.Bytes; *

* If user setBatch(5) and rpc returns 3+5+5+5+3 cells, we should return 5+5+5+5+1 to user. setBatch * doesn't mean setAllowPartialResult(true). + * @since 2.0.0 */ @InterfaceAudience.Private public class BatchScanResultCache implements ScanResultCache { diff --git a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/ColumnFamilyDescriptor.java b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/ColumnFamilyDescriptor.java index 76b53330e66..3234632959d 100644 --- a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/ColumnFamilyDescriptor.java +++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/ColumnFamilyDescriptor.java @@ -34,6 +34,7 @@ import org.apache.hadoop.hbase.util.Bytes; * It is used as input when creating a table or adding a column. * * To construct a new instance, use the {@link ColumnFamilyDescriptorBuilder} methods + * @since 2.0.0 */ @InterfaceAudience.Public public interface ColumnFamilyDescriptor { diff --git a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/ColumnFamilyDescriptorBuilder.java b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/ColumnFamilyDescriptorBuilder.java index 67d2c5676dc..d25f9d1dc31 100644 --- a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/ColumnFamilyDescriptorBuilder.java +++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/ColumnFamilyDescriptorBuilder.java @@ -41,6 +41,9 @@ import org.apache.hadoop.hbase.util.Bytes; import org.apache.hadoop.hbase.util.PrettyPrinter; import org.apache.hadoop.hbase.util.PrettyPrinter.Unit; +/** + * @since 2.0.0 + */ @InterfaceAudience.Public public class ColumnFamilyDescriptorBuilder { // For future backward compatibility diff --git a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/RawAsyncHBaseAdmin.java b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/RawAsyncHBaseAdmin.java index 19bc2f42008..c5eb1688208 100644 --- a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/RawAsyncHBaseAdmin.java +++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/RawAsyncHBaseAdmin.java @@ -255,6 +255,7 @@ import org.apache.hadoop.hbase.util.Pair; /** * The implementation of AsyncAdmin. + * @since 2.0.0 */ @InterfaceAudience.Private public class RawAsyncHBaseAdmin implements AsyncAdmin { diff --git a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/RawAsyncTable.java b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/RawAsyncTable.java index 4a916d3fca3..582e2c99e4d 100644 --- a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/RawAsyncTable.java +++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/RawAsyncTable.java @@ -44,6 +44,7 @@ import org.apache.hadoop.hbase.classification.InterfaceAudience; * method. The {@link RawScanResultConsumer} exposes the implementation details of a scan(heartbeat) * so it is not suitable for a normal user. If it is still the only difference after we implement * most features of AsyncTable, we can think about merge these two interfaces. + * @since 2.0.0 */ @InterfaceAudience.Public public interface RawAsyncTable extends AsyncTableBase { diff --git a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/RawScanResultConsumer.java b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/RawScanResultConsumer.java index 4fedb0f2c18..b10e834325b 100644 --- a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/RawScanResultConsumer.java +++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/RawScanResultConsumer.java @@ -31,6 +31,7 @@ import org.apache.hadoop.hbase.client.metrics.ScanMetrics; * HBase in background while you process the returned data, you need to move the processing work to * another thread to make the {@code onNext} call return immediately. And please do NOT do any time * consuming tasks in all methods below unless you know what you are doing. + * @since 2.0.0 */ @InterfaceAudience.Public public interface RawScanResultConsumer { diff --git a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/TableDescriptorBuilder.java b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/TableDescriptorBuilder.java index a710077d52c..0dc4175cfd3 100644 --- a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/TableDescriptorBuilder.java +++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/TableDescriptorBuilder.java @@ -47,6 +47,9 @@ import org.apache.hadoop.hbase.shaded.protobuf.ProtobufUtil; import org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos; import org.apache.hadoop.hbase.util.Bytes; +/** + * @since 2.0.0 + */ @InterfaceAudience.Public public class TableDescriptorBuilder { public static final Log LOG = LogFactory.getLog(TableDescriptorBuilder.class); diff --git a/hbase-client/src/main/java/org/apache/hadoop/hbase/ipc/NettyRpcClient.java b/hbase-client/src/main/java/org/apache/hadoop/hbase/ipc/NettyRpcClient.java index 2fea5624ae2..1a7748b3128 100644 --- a/hbase-client/src/main/java/org/apache/hadoop/hbase/ipc/NettyRpcClient.java +++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/ipc/NettyRpcClient.java @@ -35,6 +35,7 @@ import org.apache.hadoop.hbase.util.Pair; /** * Netty client for the requests and responses. + * @since 2.0.0 */ @InterfaceAudience.LimitedPrivate(HBaseInterfaceAudience.CONFIG) public class NettyRpcClient extends AbstractRpcClient { diff --git a/hbase-client/src/main/java/org/apache/hadoop/hbase/ipc/NettyRpcClientConfigHelper.java b/hbase-client/src/main/java/org/apache/hadoop/hbase/ipc/NettyRpcClientConfigHelper.java index 0e12f27a56c..726a9ef1d31 100644 --- a/hbase-client/src/main/java/org/apache/hadoop/hbase/ipc/NettyRpcClientConfigHelper.java +++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/ipc/NettyRpcClientConfigHelper.java @@ -36,6 +36,7 @@ import org.apache.hadoop.hbase.util.Pair; * As hadoop Configuration can not pass an Object directly, we need to find a way to pass the * EventLoopGroup to {@code AsyncRpcClient} if we want to use a single {@code EventLoopGroup} for * the whole process. + * @since 2.0.0 */ @InterfaceAudience.Public public class NettyRpcClientConfigHelper { diff --git a/hbase-client/src/main/java/org/apache/hadoop/hbase/ipc/NettyRpcConnection.java b/hbase-client/src/main/java/org/apache/hadoop/hbase/ipc/NettyRpcConnection.java index 54e2b2cb563..fbae676cd09 100644 --- a/hbase-client/src/main/java/org/apache/hadoop/hbase/ipc/NettyRpcConnection.java +++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/ipc/NettyRpcConnection.java @@ -65,6 +65,7 @@ import org.apache.hadoop.security.UserGroupInformation; *

* Most operations are executed in handlers. Netty handler is always executed in the same * thread(EventLoop) so no lock is needed. + * @since 2.0.0 */ @InterfaceAudience.Private class NettyRpcConnection extends RpcConnection { diff --git a/hbase-client/src/main/java/org/apache/hadoop/hbase/ipc/NettyRpcDuplexHandler.java b/hbase-client/src/main/java/org/apache/hadoop/hbase/ipc/NettyRpcDuplexHandler.java index f904b4fda68..06ef4700fe5 100644 --- a/hbase-client/src/main/java/org/apache/hadoop/hbase/ipc/NettyRpcDuplexHandler.java +++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/ipc/NettyRpcDuplexHandler.java @@ -48,6 +48,7 @@ import org.apache.hadoop.ipc.RemoteException; /** * The netty rpc handler. + * @since 2.0.0 */ @InterfaceAudience.Private class NettyRpcDuplexHandler extends ChannelDuplexHandler { diff --git a/hbase-client/src/main/java/org/apache/hadoop/hbase/security/NettyHBaseRpcConnectionHeaderHandler.java b/hbase-client/src/main/java/org/apache/hadoop/hbase/security/NettyHBaseRpcConnectionHeaderHandler.java index c515e83101e..ac5bb9bee95 100644 --- a/hbase-client/src/main/java/org/apache/hadoop/hbase/security/NettyHBaseRpcConnectionHeaderHandler.java +++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/security/NettyHBaseRpcConnectionHeaderHandler.java @@ -31,6 +31,7 @@ import org.apache.hadoop.hbase.shaded.protobuf.generated.RPCProtos; /** * Implement logic to deal with the rpc connection header. + * @since 2.0.0 */ @InterfaceAudience.Private public class NettyHBaseRpcConnectionHeaderHandler extends SimpleChannelInboundHandler { diff --git a/hbase-client/src/main/java/org/apache/hadoop/hbase/security/NettyHBaseSaslRpcClient.java b/hbase-client/src/main/java/org/apache/hadoop/hbase/security/NettyHBaseSaslRpcClient.java index 937fccd4a39..d7d32df55a8 100644 --- a/hbase-client/src/main/java/org/apache/hadoop/hbase/security/NettyHBaseSaslRpcClient.java +++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/security/NettyHBaseSaslRpcClient.java @@ -32,6 +32,7 @@ import org.apache.hadoop.security.token.TokenIdentifier; /** * Implement SASL logic for netty rpc client. + * @since 2.0.0 */ @InterfaceAudience.Private public class NettyHBaseSaslRpcClient extends AbstractHBaseSaslRpcClient { diff --git a/hbase-client/src/main/java/org/apache/hadoop/hbase/security/NettyHBaseSaslRpcClientHandler.java b/hbase-client/src/main/java/org/apache/hadoop/hbase/security/NettyHBaseSaslRpcClientHandler.java index 2f64ae214cb..84445cdc827 100644 --- a/hbase-client/src/main/java/org/apache/hadoop/hbase/security/NettyHBaseSaslRpcClientHandler.java +++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/security/NettyHBaseSaslRpcClientHandler.java @@ -36,6 +36,7 @@ import org.apache.hadoop.security.token.TokenIdentifier; /** * Implement SASL logic for netty rpc client. + * @since 2.0.0 */ @InterfaceAudience.Private public class NettyHBaseSaslRpcClientHandler extends SimpleChannelInboundHandler { diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/NettyRpcServer.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/NettyRpcServer.java index ffd6d6e6acd..8b1c4da604f 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/NettyRpcServer.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/NettyRpcServer.java @@ -57,6 +57,7 @@ import org.apache.hadoop.security.authorize.ServiceAuthorizationManager; /** * An RPC server with Netty4 implementation. + * @since 2.0.0 */ @InterfaceAudience.Private public class NettyRpcServer extends RpcServer { diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/NettyRpcServerPreambleHandler.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/NettyRpcServerPreambleHandler.java index 07cf6c6e1b8..36f4ae7cb9d 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/NettyRpcServerPreambleHandler.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/NettyRpcServerPreambleHandler.java @@ -28,6 +28,7 @@ import org.apache.hadoop.hbase.classification.InterfaceAudience; /** * Handle connection preamble. + * @since 2.0.0` */ @InterfaceAudience.Private class NettyRpcServerPreambleHandler extends SimpleChannelInboundHandler { diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/NettyRpcServerRequestDecoder.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/NettyRpcServerRequestDecoder.java index fde8e46b031..5da2637842c 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/NettyRpcServerRequestDecoder.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/NettyRpcServerRequestDecoder.java @@ -26,6 +26,7 @@ import org.apache.hadoop.hbase.classification.InterfaceAudience; /** * Decoder for rpc request. + * @since 2.0.0 */ @InterfaceAudience.Private class NettyRpcServerRequestDecoder extends ChannelInboundHandlerAdapter { diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/NettyRpcServerResponseEncoder.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/NettyRpcServerResponseEncoder.java index 5c106f88be8..4bd7968bc83 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/NettyRpcServerResponseEncoder.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/NettyRpcServerResponseEncoder.java @@ -26,6 +26,7 @@ import org.apache.hadoop.hbase.classification.InterfaceAudience; /** * Encoder for {@link RpcResponse}. + * @since 2.0.0 */ @InterfaceAudience.Private class NettyRpcServerResponseEncoder extends ChannelOutboundHandlerAdapter { diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/NettyServerCall.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/NettyServerCall.java index bba2536544f..25f04c5f78c 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/NettyServerCall.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/NettyServerCall.java @@ -33,6 +33,7 @@ import org.apache.htrace.TraceInfo; /** * Datastructure that holds all necessary to a method invocation and then afterward, carries the * result. + * @since 2.0.0 */ @InterfaceAudience.Private class NettyServerCall extends ServerCall { diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/NettyServerRpcConnection.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/NettyServerRpcConnection.java index 35ce4c772e5..45a65a54779 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/NettyServerRpcConnection.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/NettyServerRpcConnection.java @@ -38,6 +38,7 @@ import org.apache.htrace.TraceInfo; /** * RpcConnection implementation for netty rpc server. + * @since 2.0.0 */ @InterfaceAudience.Private class NettyServerRpcConnection extends ServerRpcConnection { diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/wal/NettyAsyncFSWALConfigHelper.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/wal/NettyAsyncFSWALConfigHelper.java index 5b29dbd2f55..08796bea823 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/wal/NettyAsyncFSWALConfigHelper.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/wal/NettyAsyncFSWALConfigHelper.java @@ -31,6 +31,7 @@ import org.apache.hadoop.hbase.util.Pair; /** * Helper class for passing netty event loop config to {@link AsyncFSWALProvider}. + * @since 2.0.0 */ public class NettyAsyncFSWALConfigHelper {