Repository: hbase Updated Branches: refs/heads/master 020f520d1 -> 8653823ac
HBASE-18213 Add documentation about the new async client Project: http://git-wip-us.apache.org/repos/asf/hbase/repo Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/8653823a Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/8653823a Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/8653823a Branch: refs/heads/master Commit: 8653823ac4f4e8e856ad40a8eca6cac728ce48e1 Parents: 020f520 Author: zhangduo <[email protected]> Authored: Fri Jun 16 09:57:36 2017 +0800 Committer: zhangduo <[email protected]> Committed: Fri Jun 16 14:59:55 2017 +0800 ---------------------------------------------------------------------- src/main/asciidoc/_chapters/architecture.adoc | 27 ++++++++++++++++++++++ 1 file changed, 27 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hbase/blob/8653823a/src/main/asciidoc/_chapters/architecture.adoc ---------------------------------------------------------------------- diff --git a/src/main/asciidoc/_chapters/architecture.adoc b/src/main/asciidoc/_chapters/architecture.adoc index 7f9ba07..8d11efb 100644 --- a/src/main/asciidoc/_chapters/architecture.adoc +++ b/src/main/asciidoc/_chapters/architecture.adoc @@ -244,6 +244,33 @@ For additional information on write durability, review the link:/acid-semantics. For fine-grained control of batching of ``Put``s or ``Delete``s, see the link:http://hbase.apache.org/apidocs/org/apache/hadoop/hbase/client/Table.html#batch%28java.util.List%29[batch] methods on Table. +[[async.client]] +=== Asynchronous Client === + +It is a new API introduced in HBase 2.0 which aims to provide the ability to access HBase asynchronously. + +You can obtain an `AsyncConnection` from `ConnectionFactory`, and then get a asynchronous table instance from it to access HBase. When done, close the `AsyncConnection` instance(usually when your program exits). + +For the asynchronous table, most methods have the same meaning with the old `Table` interface, expect that the return value is wrapped with a CompletableFuture usually. We do not have any buffer here so there is no close method for asynchronous table, you do not need to close it. And it is thread safe. + +There are several differences for scan: + +* There is still a `getScanner` method which returns a `ResultScanner`. You can use it in the old way and it works like the old `ClientAsyncPrefetchScanner`. +* There is a `scanAll` method which will return all the results at once. It aims to provide a simpler way for small scans which you want to get the whole results at once usually. +* The Observer Pattern. There is a scan method which accepts a `ScanResultConsumer` as a parameter. It will pass the results to the consumer. + +Notice that there are two types of asynchronous table, one is `AsyncTable` and the other is `RawAsyncTable`. + +For `AsyncTable`, you need to provide a thread pool when getting it. The callbacks registered to the returned CompletableFuture will be executed in that thread pool. It is designed for normal users. You are free to do anything in the callbacks. + +For `RawAsyncTable`, all the callbacks are executed inside the framework thread so it is not allowed to do time consuming works in the callbacks otherwise you may block the framework thread and cause very bad performance impact. It is designed for advanced users who want to write high performance code. You can see the `org.apache.hadoop.hbase.client.example.HttpProxyExample` to see how to write fully asynchronous code with `RawAsyncTable`. And coprocessor related methods are only in `RawAsyncTable`. + +.On `AsyncAdmin` +[WARNING] +==== +`AsyncAdmin` is still under development and marked as IA.Private. Use it with caution as we may change the API without any announcement. +==== + [[client.external]] === External Clients
