http://git-wip-us.apache.org/repos/asf/hbase-site/blob/48aaec11/apidocs/src-html/org/apache/hadoop/hbase/mapreduce/Import.html ---------------------------------------------------------------------- diff --git a/apidocs/src-html/org/apache/hadoop/hbase/mapreduce/Import.html b/apidocs/src-html/org/apache/hadoop/hbase/mapreduce/Import.html index ebc8e8a..f48e20e 100644 --- a/apidocs/src-html/org/apache/hadoop/hbase/mapreduce/Import.html +++ b/apidocs/src-html/org/apache/hadoop/hbase/mapreduce/Import.html @@ -56,23 +56,23 @@ <span class="sourceLineNo">048</span>import org.apache.hadoop.hbase.KeyValueUtil;<a name="line.48"></a> <span class="sourceLineNo">049</span>import org.apache.hadoop.hbase.TableName;<a name="line.49"></a> <span class="sourceLineNo">050</span>import org.apache.hadoop.hbase.ZooKeeperConnectionException;<a name="line.50"></a> -<span class="sourceLineNo">051</span>import org.apache.yetus.audience.InterfaceAudience;<a name="line.51"></a> -<span class="sourceLineNo">052</span>import org.apache.hadoop.hbase.client.Admin;<a name="line.52"></a> -<span class="sourceLineNo">053</span>import org.apache.hadoop.hbase.client.Connection;<a name="line.53"></a> -<span class="sourceLineNo">054</span>import org.apache.hadoop.hbase.client.ConnectionFactory;<a name="line.54"></a> -<span class="sourceLineNo">055</span>import org.apache.hadoop.hbase.client.Delete;<a name="line.55"></a> -<span class="sourceLineNo">056</span>import org.apache.hadoop.hbase.client.Durability;<a name="line.56"></a> -<span class="sourceLineNo">057</span>import org.apache.hadoop.hbase.client.Mutation;<a name="line.57"></a> -<span class="sourceLineNo">058</span>import org.apache.hadoop.hbase.client.Put;<a name="line.58"></a> -<span class="sourceLineNo">059</span>import org.apache.hadoop.hbase.client.RegionLocator;<a name="line.59"></a> -<span class="sourceLineNo">060</span>import org.apache.hadoop.hbase.client.Result;<a name="line.60"></a> -<span class="sourceLineNo">061</span>import org.apache.hadoop.hbase.client.Table;<a name="line.61"></a> -<span class="sourceLineNo">062</span>import org.apache.hadoop.hbase.filter.Filter;<a name="line.62"></a> -<span class="sourceLineNo">063</span>import org.apache.hadoop.hbase.io.ImmutableBytesWritable;<a name="line.63"></a> -<span class="sourceLineNo">064</span>import org.apache.hadoop.hbase.util.Bytes;<a name="line.64"></a> -<span class="sourceLineNo">065</span>import org.apache.hadoop.hbase.util.MapReduceCell;<a name="line.65"></a> -<span class="sourceLineNo">066</span>import org.apache.hadoop.hbase.zookeeper.ZKClusterId;<a name="line.66"></a> -<span class="sourceLineNo">067</span>import org.apache.hadoop.hbase.zookeeper.ZooKeeperWatcher;<a name="line.67"></a> +<span class="sourceLineNo">051</span>import org.apache.hadoop.hbase.zookeeper.ZKWatcher;<a name="line.51"></a> +<span class="sourceLineNo">052</span>import org.apache.yetus.audience.InterfaceAudience;<a name="line.52"></a> +<span class="sourceLineNo">053</span>import org.apache.hadoop.hbase.client.Admin;<a name="line.53"></a> +<span class="sourceLineNo">054</span>import org.apache.hadoop.hbase.client.Connection;<a name="line.54"></a> +<span class="sourceLineNo">055</span>import org.apache.hadoop.hbase.client.ConnectionFactory;<a name="line.55"></a> +<span class="sourceLineNo">056</span>import org.apache.hadoop.hbase.client.Delete;<a name="line.56"></a> +<span class="sourceLineNo">057</span>import org.apache.hadoop.hbase.client.Durability;<a name="line.57"></a> +<span class="sourceLineNo">058</span>import org.apache.hadoop.hbase.client.Mutation;<a name="line.58"></a> +<span class="sourceLineNo">059</span>import org.apache.hadoop.hbase.client.Put;<a name="line.59"></a> +<span class="sourceLineNo">060</span>import org.apache.hadoop.hbase.client.RegionLocator;<a name="line.60"></a> +<span class="sourceLineNo">061</span>import org.apache.hadoop.hbase.client.Result;<a name="line.61"></a> +<span class="sourceLineNo">062</span>import org.apache.hadoop.hbase.client.Table;<a name="line.62"></a> +<span class="sourceLineNo">063</span>import org.apache.hadoop.hbase.filter.Filter;<a name="line.63"></a> +<span class="sourceLineNo">064</span>import org.apache.hadoop.hbase.io.ImmutableBytesWritable;<a name="line.64"></a> +<span class="sourceLineNo">065</span>import org.apache.hadoop.hbase.util.Bytes;<a name="line.65"></a> +<span class="sourceLineNo">066</span>import org.apache.hadoop.hbase.util.MapReduceCell;<a name="line.66"></a> +<span class="sourceLineNo">067</span>import org.apache.hadoop.hbase.zookeeper.ZKClusterId;<a name="line.67"></a> <span class="sourceLineNo">068</span>import org.apache.hadoop.io.RawComparator;<a name="line.68"></a> <span class="sourceLineNo">069</span>import org.apache.hadoop.io.WritableComparable;<a name="line.69"></a> <span class="sourceLineNo">070</span>import org.apache.hadoop.io.WritableComparator;<a name="line.70"></a> @@ -414,10 +414,10 @@ <span class="sourceLineNo">406</span> LOG.info("setting WAL durability to default.");<a name="line.406"></a> <span class="sourceLineNo">407</span> }<a name="line.407"></a> <span class="sourceLineNo">408</span> // TODO: This is kind of ugly doing setup of ZKW just to read the clusterid.<a name="line.408"></a> -<span class="sourceLineNo">409</span> ZooKeeperWatcher zkw = null;<a name="line.409"></a> +<span class="sourceLineNo">409</span> ZKWatcher zkw = null;<a name="line.409"></a> <span class="sourceLineNo">410</span> Exception ex = null;<a name="line.410"></a> <span class="sourceLineNo">411</span> try {<a name="line.411"></a> -<span class="sourceLineNo">412</span> zkw = new ZooKeeperWatcher(conf, context.getTaskAttemptID().toString(), null);<a name="line.412"></a> +<span class="sourceLineNo">412</span> zkw = new ZKWatcher(conf, context.getTaskAttemptID().toString(), null);<a name="line.412"></a> <span class="sourceLineNo">413</span> clusterIds = Collections.singletonList(ZKClusterId.getUUIDForCluster(zkw));<a name="line.413"></a> <span class="sourceLineNo">414</span> } catch (ZooKeeperConnectionException e) {<a name="line.414"></a> <span class="sourceLineNo">415</span> ex = e;<a name="line.415"></a>
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/48aaec11/apidocs/src-html/org/apache/hadoop/hbase/util/RegionMover.html ---------------------------------------------------------------------- diff --git a/apidocs/src-html/org/apache/hadoop/hbase/util/RegionMover.html b/apidocs/src-html/org/apache/hadoop/hbase/util/RegionMover.html index 7cdce1e..4fbcab2 100644 --- a/apidocs/src-html/org/apache/hadoop/hbase/util/RegionMover.html +++ b/apidocs/src-html/org/apache/hadoop/hbase/util/RegionMover.html @@ -70,7 +70,7 @@ <span class="sourceLineNo">062</span>import org.apache.hadoop.hbase.client.Table;<a name="line.62"></a> <span class="sourceLineNo">063</span>import org.apache.hadoop.hbase.filter.FirstKeyOnlyFilter;<a name="line.63"></a> <span class="sourceLineNo">064</span>import org.apache.hadoop.hbase.zookeeper.MetaTableLocator;<a name="line.64"></a> -<span class="sourceLineNo">065</span>import org.apache.hadoop.hbase.zookeeper.ZooKeeperWatcher;<a name="line.65"></a> +<span class="sourceLineNo">065</span>import org.apache.hadoop.hbase.zookeeper.ZKWatcher;<a name="line.65"></a> <span class="sourceLineNo">066</span>import org.apache.yetus.audience.InterfaceAudience;<a name="line.66"></a> <span class="sourceLineNo">067</span><a name="line.67"></a> <span class="sourceLineNo">068</span>/**<a name="line.68"></a> @@ -908,7 +908,7 @@ <span class="sourceLineNo">900</span> return null;<a name="line.900"></a> <span class="sourceLineNo">901</span> }<a name="line.901"></a> <span class="sourceLineNo">902</span> if (region.isMetaRegion()) {<a name="line.902"></a> -<span class="sourceLineNo">903</span> ZooKeeperWatcher zkw = new ZooKeeperWatcher(admin.getConfiguration(), "region_mover", null);<a name="line.903"></a> +<span class="sourceLineNo">903</span> ZKWatcher zkw = new ZKWatcher(admin.getConfiguration(), "region_mover", null);<a name="line.903"></a> <span class="sourceLineNo">904</span> MetaTableLocator locator = new MetaTableLocator();<a name="line.904"></a> <span class="sourceLineNo">905</span> int maxWaitInSeconds =<a name="line.905"></a> <span class="sourceLineNo">906</span> admin.getConfiguration().getInt(MOVE_WAIT_MAX_KEY, DEFAULT_MOVE_WAIT_MAX);<a name="line.906"></a> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/48aaec11/book.html ---------------------------------------------------------------------- diff --git a/book.html b/book.html index cc75bee..71d419c 100644 --- a/book.html +++ b/book.html @@ -13534,13 +13534,13 @@ Please use <a href="https://hbase.apache.org/apidocs/org/apache/hadoop/hbase/cli </ul> </div> <div class="paragraph"> -<p>Notice that there are two types of asynchronous table, one is <code>AsyncTable</code> and the other is <code>RawAsyncTable</code>.</p> +<p>Notice that <code>AsyncTable</code> interface is templatized. The template parameter specifies the type of <code>ScanResultConsumerBase</code> used by scans, which means the observer style scan APIs are different. The two types of scan consumers are - <code>ScanResultConsumer</code> and <code>AdvancedScanResultConsumer</code>.</p> </div> <div class="paragraph"> -<p>For <code>AsyncTable</code>, 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.</p> +<p><code>ScanResultConsumer</code> needs a separate thread pool which is used to execute the callbacks registered to the returned CompletableFuture. Because the use of separate thread pool frees up RPC threads, callbacks are free to do anything. Use this if the callbacks are not quick, or when in doubt.</p> </div> <div class="paragraph"> -<p>For <code>RawAsyncTable</code>, 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 <code>org.apache.hadoop.hbase.client.example.HttpProxyExample</code> to see how to write fully asynchronous code with <code>RawAsyncTable</code>. And coprocessor related methods are only in <code>RawAsyncTable</code>.</p> +<p><code>AdvancedScanResultConsumer</code> executes callbacks inside the framework thread. It is not allowed to do time consuming work in the callbacks else it will likely block the framework threads and cause very bad performance impact. As its name, it is designed for advanced users who want to write high performance code. See <code>org.apache.hadoop.hbase.client.example.HttpProxyExample</code> for how to write fully asynchronous code with it.</p> </div> </div> <div class="sect2"> @@ -35449,7 +35449,7 @@ The server will return cellblocks compressed using this same compressor as long <div id="footer"> <div id="footer-text"> Version 3.0.0-SNAPSHOT<br> -Last updated 2017-11-17 14:35:07 UTC +Last updated 2017-11-18 14:29:39 UTC </div> </div> </body> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/48aaec11/bulk-loads.html ---------------------------------------------------------------------- diff --git a/bulk-loads.html b/bulk-loads.html index 0dd9c12..7b9cbe4 100644 --- a/bulk-loads.html +++ b/bulk-loads.html @@ -7,7 +7,7 @@ <head> <meta charset="UTF-8" /> <meta name="viewport" content="width=device-width, initial-scale=1.0" /> - <meta name="Date-Revision-yyyymmdd" content="20171117" /> + <meta name="Date-Revision-yyyymmdd" content="20171118" /> <meta http-equiv="Content-Language" content="en" /> <title>Apache HBase – Bulk Loads in Apache HBase (TM) @@ -311,7 +311,7 @@ under the License. --> <a href="https://www.apache.org/";>The Apache Software Foundation</a>. All rights reserved. - <li id="publishDate" class="pull-right">Last Published: 2017-11-17</li> + <li id="publishDate" class="pull-right">Last Published: 2017-11-18</li> </p> </div>
