Repository: hbase Updated Branches: refs/heads/master 368591dfc -> 20d272bce
HBASE-18687 Add @since 2.0.0 to new classes Project: http://git-wip-us.apache.org/repos/asf/hbase/repo Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/20d272bc Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/20d272bc Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/20d272bc Branch: refs/heads/master Commit: 20d272bce56ba8e586feceb710da159f288aa1e8 Parents: 3bc64da Author: Michael Stack <st...@apache.org> Authored: Fri Aug 25 13:12:20 2017 -0700 Committer: Michael Stack <st...@apache.org> Committed: Fri Aug 25 13:12:30 2017 -0700 ---------------------------------------------------------------------- .../main/java/org/apache/hadoop/hbase/AsyncMetaTableAccessor.java | 1 + .../src/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 +++ .../main/java/org/apache/hadoop/hbase/client/AsyncConnection.java | 1 + .../main/java/org/apache/hadoop/hbase/client/AsyncHBaseAdmin.java | 1 + .../hadoop/hbase/client/AsyncMasterRequestRpcRetryingCaller.java | 1 + .../java/org/apache/hadoop/hbase/client/AsyncRequestFuture.java | 3 ++- .../apache/hadoop/hbase/client/AsyncRpcRetryingCallerFactory.java | 1 + .../src/main/java/org/apache/hadoop/hbase/client/AsyncTable.java | 1 + .../main/java/org/apache/hadoop/hbase/client/AsyncTableBase.java | 1 + .../java/org/apache/hadoop/hbase/client/AsyncTableBuilder.java | 1 + .../org/apache/hadoop/hbase/client/AsyncTableRegionLocator.java | 1 + .../java/org/apache/hadoop/hbase/client/BatchScanResultCache.java | 1 + .../org/apache/hadoop/hbase/client/ColumnFamilyDescriptor.java | 1 + .../apache/hadoop/hbase/client/ColumnFamilyDescriptorBuilder.java | 3 +++ .../java/org/apache/hadoop/hbase/client/RawAsyncHBaseAdmin.java | 1 + .../main/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 +++ .../src/main/java/org/apache/hadoop/hbase/ipc/NettyRpcClient.java | 1 + .../org/apache/hadoop/hbase/ipc/NettyRpcClientConfigHelper.java | 1 + .../main/java/org/apache/hadoop/hbase/ipc/NettyRpcConnection.java | 1 + .../java/org/apache/hadoop/hbase/ipc/NettyRpcDuplexHandler.java | 1 + .../hbase/security/NettyHBaseRpcConnectionHeaderHandler.java | 1 + .../org/apache/hadoop/hbase/security/NettyHBaseSaslRpcClient.java | 1 + .../hadoop/hbase/security/NettyHBaseSaslRpcClientHandler.java | 1 + .../src/main/java/org/apache/hadoop/hbase/ipc/NettyRpcServer.java | 1 + .../apache/hadoop/hbase/ipc/NettyRpcServerPreambleHandler.java | 1 + .../org/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 + .../org/apache/hadoop/hbase/wal/NettyAsyncFSWALConfigHelper.java | 1 + 34 files changed, 41 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hbase/blob/20d272bc/hbase-client/src/main/java/org/apache/hadoop/hbase/AsyncMetaTableAccessor.java ---------------------------------------------------------------------- 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 1018d7a..232212a 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 <code>hbase:meta</code>. + * @since 2.0.0 */ @InterfaceAudience.Private public class AsyncMetaTableAccessor { http://git-wip-us.apache.org/repos/asf/hbase/blob/20d272bc/hbase-client/src/main/java/org/apache/hadoop/hbase/client/AsyncAdmin.java ---------------------------------------------------------------------- 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 4b33812..bdd047d 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; * <p> * 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 { http://git-wip-us.apache.org/repos/asf/hbase/blob/20d272bc/hbase-client/src/main/java/org/apache/hadoop/hbase/client/AsyncAdminBuilder.java ---------------------------------------------------------------------- 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 fb0aefd..7347ebf 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 { http://git-wip-us.apache.org/repos/asf/hbase/blob/20d272bc/hbase-client/src/main/java/org/apache/hadoop/hbase/client/AsyncAdminRequestRetryingCaller.java ---------------------------------------------------------------------- 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 2871c4d..bf6d62d 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<T> extends AsyncRpcRetryingCaller<T> { http://git-wip-us.apache.org/repos/asf/hbase/blob/20d272bc/hbase-client/src/main/java/org/apache/hadoop/hbase/client/AsyncConnection.java ---------------------------------------------------------------------- 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 8d26368..2b7e702 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 { http://git-wip-us.apache.org/repos/asf/hbase/blob/20d272bc/hbase-client/src/main/java/org/apache/hadoop/hbase/client/AsyncHBaseAdmin.java ---------------------------------------------------------------------- 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 097f22a..df077fc 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 { http://git-wip-us.apache.org/repos/asf/hbase/blob/20d272bc/hbase-client/src/main/java/org/apache/hadoop/hbase/client/AsyncMasterRequestRpcRetryingCaller.java ---------------------------------------------------------------------- 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 7a598d7..2715eab 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<T> extends AsyncRpcRetryingCaller<T> { http://git-wip-us.apache.org/repos/asf/hbase/blob/20d272bc/hbase-client/src/main/java/org/apache/hadoop/hbase/client/AsyncRequestFuture.java ---------------------------------------------------------------------- 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 539e234..f439ca0 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(); http://git-wip-us.apache.org/repos/asf/hbase/blob/20d272bc/hbase-client/src/main/java/org/apache/hadoop/hbase/client/AsyncRpcRetryingCallerFactory.java ---------------------------------------------------------------------- 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 1aa3fbd..6cb286a 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 { http://git-wip-us.apache.org/repos/asf/hbase/blob/20d272bc/hbase-client/src/main/java/org/apache/hadoop/hbase/client/AsyncTable.java ---------------------------------------------------------------------- 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 a2e193c..9cea8d4 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 { http://git-wip-us.apache.org/repos/asf/hbase/blob/20d272bc/hbase-client/src/main/java/org/apache/hadoop/hbase/client/AsyncTableBase.java ---------------------------------------------------------------------- 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 006e3e2..d525086 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; * <p> * 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 { http://git-wip-us.apache.org/repos/asf/hbase/blob/20d272bc/hbase-client/src/main/java/org/apache/hadoop/hbase/client/AsyncTableBuilder.java ---------------------------------------------------------------------- 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 1cc5f10..8d137b4 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<T extends AsyncTableBase> { http://git-wip-us.apache.org/repos/asf/hbase/blob/20d272bc/hbase-client/src/main/java/org/apache/hadoop/hbase/client/AsyncTableRegionLocator.java ---------------------------------------------------------------------- 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 13434a6..c3bc4e2 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; * <p> * 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 { http://git-wip-us.apache.org/repos/asf/hbase/blob/20d272bc/hbase-client/src/main/java/org/apache/hadoop/hbase/client/BatchScanResultCache.java ---------------------------------------------------------------------- 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 293f411..7c88b7f 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; * <p> * 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 { http://git-wip-us.apache.org/repos/asf/hbase/blob/20d272bc/hbase-client/src/main/java/org/apache/hadoop/hbase/client/ColumnFamilyDescriptor.java ---------------------------------------------------------------------- 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 76b5333..3234632 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 { http://git-wip-us.apache.org/repos/asf/hbase/blob/20d272bc/hbase-client/src/main/java/org/apache/hadoop/hbase/client/ColumnFamilyDescriptorBuilder.java ---------------------------------------------------------------------- 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 67d2c56..d25f9d1 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 http://git-wip-us.apache.org/repos/asf/hbase/blob/20d272bc/hbase-client/src/main/java/org/apache/hadoop/hbase/client/RawAsyncHBaseAdmin.java ---------------------------------------------------------------------- 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 19bc2f4..c5eb168 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 { http://git-wip-us.apache.org/repos/asf/hbase/blob/20d272bc/hbase-client/src/main/java/org/apache/hadoop/hbase/client/RawAsyncTable.java ---------------------------------------------------------------------- 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 4a916d3..582e2c9 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 { http://git-wip-us.apache.org/repos/asf/hbase/blob/20d272bc/hbase-client/src/main/java/org/apache/hadoop/hbase/client/RawScanResultConsumer.java ---------------------------------------------------------------------- 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 4fedb0f..b10e834 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 { http://git-wip-us.apache.org/repos/asf/hbase/blob/20d272bc/hbase-client/src/main/java/org/apache/hadoop/hbase/client/TableDescriptorBuilder.java ---------------------------------------------------------------------- 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 a710077..0dc4175 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); http://git-wip-us.apache.org/repos/asf/hbase/blob/20d272bc/hbase-client/src/main/java/org/apache/hadoop/hbase/ipc/NettyRpcClient.java ---------------------------------------------------------------------- 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 2fea562..1a7748b 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<NettyRpcConnection> { http://git-wip-us.apache.org/repos/asf/hbase/blob/20d272bc/hbase-client/src/main/java/org/apache/hadoop/hbase/ipc/NettyRpcClientConfigHelper.java ---------------------------------------------------------------------- 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 0e12f27..726a9ef 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 { http://git-wip-us.apache.org/repos/asf/hbase/blob/20d272bc/hbase-client/src/main/java/org/apache/hadoop/hbase/ipc/NettyRpcConnection.java ---------------------------------------------------------------------- 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 54e2b2c..fbae676 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; * <p> * 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 { http://git-wip-us.apache.org/repos/asf/hbase/blob/20d272bc/hbase-client/src/main/java/org/apache/hadoop/hbase/ipc/NettyRpcDuplexHandler.java ---------------------------------------------------------------------- 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 f904b4f..06ef470 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 { http://git-wip-us.apache.org/repos/asf/hbase/blob/20d272bc/hbase-client/src/main/java/org/apache/hadoop/hbase/security/NettyHBaseRpcConnectionHeaderHandler.java ---------------------------------------------------------------------- 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 c515e83..ac5bb9b 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<ByteBuf> { http://git-wip-us.apache.org/repos/asf/hbase/blob/20d272bc/hbase-client/src/main/java/org/apache/hadoop/hbase/security/NettyHBaseSaslRpcClient.java ---------------------------------------------------------------------- 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 937fccd..d7d32df 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 { http://git-wip-us.apache.org/repos/asf/hbase/blob/20d272bc/hbase-client/src/main/java/org/apache/hadoop/hbase/security/NettyHBaseSaslRpcClientHandler.java ---------------------------------------------------------------------- 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 2f64ae2..84445cd 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<ByteBuf> { http://git-wip-us.apache.org/repos/asf/hbase/blob/20d272bc/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/NettyRpcServer.java ---------------------------------------------------------------------- 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 ffd6d6e..8b1c4da 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 { http://git-wip-us.apache.org/repos/asf/hbase/blob/20d272bc/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/NettyRpcServerPreambleHandler.java ---------------------------------------------------------------------- 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 07cf6c6..36f4ae7 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<ByteBuf> { http://git-wip-us.apache.org/repos/asf/hbase/blob/20d272bc/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/NettyRpcServerRequestDecoder.java ---------------------------------------------------------------------- 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 fde8e46..5da2637 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 { http://git-wip-us.apache.org/repos/asf/hbase/blob/20d272bc/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/NettyRpcServerResponseEncoder.java ---------------------------------------------------------------------- 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 5c106f8..4bd7968 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 { http://git-wip-us.apache.org/repos/asf/hbase/blob/20d272bc/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/NettyServerCall.java ---------------------------------------------------------------------- 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 bba2536..25f04c5 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<NettyServerRpcConnection> { http://git-wip-us.apache.org/repos/asf/hbase/blob/20d272bc/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/NettyServerRpcConnection.java ---------------------------------------------------------------------- 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 35ce4c7..45a65a5 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 { http://git-wip-us.apache.org/repos/asf/hbase/blob/20d272bc/hbase-server/src/main/java/org/apache/hadoop/hbase/wal/NettyAsyncFSWALConfigHelper.java ---------------------------------------------------------------------- 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 5b29dbd..08796be 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 {