date:20161111

[1/2] hbase git commit: HBASE-16816 HMaster.move() should throw exception if region to move is not online (Allan Yang)

2016-11-11 Thread apurtell

Repository: hbase
Updated Branches:
  refs/heads/0.98 cf2cb620e -> dba43b628


HBASE-16816 HMaster.move() should throw exception if region to move is not 
online (Allan Yang)


Project: http://git-wip-us.apache.org/repos/asf/hbase/repo
Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/500e0b7a
Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/500e0b7a
Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/500e0b7a

Branch: refs/heads/0.98
Commit: 500e0b7a6794ae32a858a1ef1cd4e79fdcbb55b9
Parents: cf2cb62
Author: tedyu 
Authored: Thu Oct 13 11:11:11 2016 -0700
Committer: Andrew Purtell 
Committed: Fri Nov 11 18:15:01 2016 -0800

--
 .../src/main/java/org/apache/hadoop/hbase/master/HMaster.java   | 5 +
 1 file changed, 5 insertions(+)
--


http://git-wip-us.apache.org/repos/asf/hbase/blob/500e0b7a/hbase-server/src/main/java/org/apache/hadoop/hbase/master/HMaster.java
--
diff --git 
a/hbase-server/src/main/java/org/apache/hadoop/hbase/master/HMaster.java 
b/hbase-server/src/main/java/org/apache/hadoop/hbase/master/HMaster.java
index 93f4e8b..4584a64 100644
--- a/hbase-server/src/main/java/org/apache/hadoop/hbase/master/HMaster.java
+++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/master/HMaster.java
@@ -1805,6 +1805,11 @@ MasterServices, Server {
   getRegionState(Bytes.toString(encodedRegionName));
 if (regionState == null) {
   throw new 
UnknownRegionException(Bytes.toStringBinary(encodedRegionName));
+} else if (!assignmentManager.getRegionStates()
+.isRegionOnline(regionState.getRegion())) {
+  throw new HBaseIOException(
+  "moving region not onlined: " + regionState.getRegion() + ", "
+  + regionState);
 }
 
 HRegionInfo hri = regionState.getRegion();

[2/2] hbase git commit: HBASE-16853 Regions are assigned to Region Servers in /hbase/draining after HBase Master failover (David Pope)

2016-11-11 Thread apurtell

HBASE-16853 Regions are assigned to Region Servers in /hbase/draining after 
HBase Master failover (David Pope)


Project: http://git-wip-us.apache.org/repos/asf/hbase/repo
Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/dba43b62
Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/dba43b62
Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/dba43b62

Branch: refs/heads/0.98
Commit: dba43b62823cbaa663cf0c2f7b7e4dcd668bdbce
Parents: 500e0b7
Author: tedyu 
Authored: Sun Oct 16 18:54:59 2016 -0700
Committer: Andrew Purtell 
Committed: Fri Nov 11 18:21:22 2016 -0800

--
 .../hadoop/hbase/master/ServerManager.java  |   2 +-
 .../hbase/zookeeper/DrainingServerTracker.java  |  18 
 .../hbase/master/TestAssignmentListener.java| 101 ++-
 3 files changed, 119 insertions(+), 2 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/hbase/blob/dba43b62/hbase-server/src/main/java/org/apache/hadoop/hbase/master/ServerManager.java
--
diff --git 
a/hbase-server/src/main/java/org/apache/hadoop/hbase/master/ServerManager.java 
b/hbase-server/src/main/java/org/apache/hadoop/hbase/master/ServerManager.java
index ca34de5..3c0696a 100644
--- 
a/hbase-server/src/main/java/org/apache/hadoop/hbase/master/ServerManager.java
+++ 
b/hbase-server/src/main/java/org/apache/hadoop/hbase/master/ServerManager.java
@@ -475,7 +475,6 @@ public class ServerManager {
 }
   }
 
-
   public DeadServer getDeadServers() {
 return this.deadservers;
   }
@@ -659,6 +658,7 @@ public class ServerManager {
"Ignoring request to add it again.");
   return false;
 }
+LOG.info("Server " + sn + " added to draining server list.");
 return this.drainingServers.add(sn);
   }
 

http://git-wip-us.apache.org/repos/asf/hbase/blob/dba43b62/hbase-server/src/main/java/org/apache/hadoop/hbase/zookeeper/DrainingServerTracker.java
--
diff --git 
a/hbase-server/src/main/java/org/apache/hadoop/hbase/zookeeper/DrainingServerTracker.java
 
b/hbase-server/src/main/java/org/apache/hadoop/hbase/zookeeper/DrainingServerTracker.java
index 5969143..413f226 100644
--- 
a/hbase-server/src/main/java/org/apache/hadoop/hbase/zookeeper/DrainingServerTracker.java
+++ 
b/hbase-server/src/main/java/org/apache/hadoop/hbase/zookeeper/DrainingServerTracker.java
@@ -27,6 +27,7 @@ import org.apache.commons.logging.LogFactory;
 import org.apache.hadoop.hbase.classification.InterfaceAudience;
 import org.apache.hadoop.hbase.Abortable;
 import org.apache.hadoop.hbase.ServerName;
+import org.apache.hadoop.hbase.master.ServerListener;
 import org.apache.hadoop.hbase.master.ServerManager;
 import org.apache.zookeeper.KeeperException;
 
@@ -68,6 +69,23 @@ public class DrainingServerTracker extends ZooKeeperListener 
{
*/
   public void start() throws KeeperException, IOException {
 watcher.registerListener(this);
+// Add a ServerListener to check if a server is draining when it's added.
+serverManager.registerListener(
+new ServerListener() {
+
+  @Override
+  public void serverAdded(ServerName sn) {
+if (drainingServers.contains(sn)){
+  serverManager.addServerToDrainList(sn);
+}
+  }
+
+  @Override
+  public void serverRemoved(ServerName serverName) {
+// no-op
+  }
+}
+);
 List servers =
   ZKUtil.listChildrenAndWatchThem(watcher, watcher.drainingZNode);
 add(servers);

http://git-wip-us.apache.org/repos/asf/hbase/blob/dba43b62/hbase-server/src/test/java/org/apache/hadoop/hbase/master/TestAssignmentListener.java
--
diff --git 
a/hbase-server/src/test/java/org/apache/hadoop/hbase/master/TestAssignmentListener.java
 
b/hbase-server/src/test/java/org/apache/hadoop/hbase/master/TestAssignmentListener.java
index 36a8265..bc2a3a6 100644
--- 
a/hbase-server/src/test/java/org/apache/hadoop/hbase/master/TestAssignmentListener.java
+++ 
b/hbase-server/src/test/java/org/apache/hadoop/hbase/master/TestAssignmentListener.java
@@ -21,16 +21,22 @@ package org.apache.hadoop.hbase.master;
 import static org.junit.Assert.assertEquals;
 
 import java.io.IOException;
+import java.util.ArrayList;
+import java.util.HashMap;
 import java.util.List;
 import java.util.concurrent.atomic.AtomicInteger;
 
 import org.apache.commons.logging.Log;
 import org.apache.commons.logging.LogFactory;
+import org.apache.hadoop.conf.Configuration;
+import org.apache.hadoop.hbase.Abortable;
 import org.apache.hadoop.hbase.HBaseTestingUtility;
+import org.apache.hadoop.hbase.HConstants;
 import org.apache.hadoop.hbase.HRegionInfo;
 import org.apache.hadoop.hbase.testclassificati

[07/52] [partial] hbase-site git commit: Published site at 8a6d6aa23944bbfd5047cf0c09fb4d8045735dab.

2016-11-11 Thread stack

http://git-wip-us.apache.org/repos/asf/hbase-site/blob/74ea7fbd/devapidocs/org/apache/hadoop/hbase/mob/DefaultMobStoreCompactor.html
--
diff --git 
a/devapidocs/org/apache/hadoop/hbase/mob/DefaultMobStoreCompactor.html 
b/devapidocs/org/apache/hadoop/hbase/mob/DefaultMobStoreCompactor.html
index 6f95346..262e9db 100644
--- a/devapidocs/org/apache/hadoop/hbase/mob/DefaultMobStoreCompactor.html
+++ b/devapidocs/org/apache/hadoop/hbase/mob/DefaultMobStoreCompactor.html
@@ -250,7 +250,7 @@ extends Compactor
-compact,
 createFileScanners,
 createScanner,
 createScanner, createTmpWriter,
 getFileDetails,
 getProgress,
 getSmallestReadPoint,
 pos
 tCreateCoprocScanner, preCreateCoprocScanner,
 preCreateCoprocScanner
+compact,
 createFileScanners,
 createScanner,
 createScanner, createTmpWriter,
 getFileDetails,
 getProgress,
 getSmallestReadPoint,
 pos
 tCreateCoprocScanner, preCreateCoprocScanner
 
 
 

http://git-wip-us.apache.org/repos/asf/hbase-site/blob/74ea7fbd/devapidocs/org/apache/hadoop/hbase/package-tree.html
--
diff --git a/devapidocs/org/apache/hadoop/hbase/package-tree.html 
b/devapidocs/org/apache/hadoop/hbase/package-tree.html
index 8a9656c..bf92bbf 100644
--- a/devapidocs/org/apache/hadoop/hbase/package-tree.html
+++ b/devapidocs/org/apache/hadoop/hbase/package-tree.html
@@ -413,14 +413,14 @@
 
 java.lang.http://docs.oracle.com/javase/8/docs/api/java/lang/Enum.html?is-external=true";
 title="class or interface in java.lang">Enum (implements java.lang.http://docs.oracle.com/javase/8/docs/api/java/lang/Comparable.html?is-external=true";
 title="class or interface in java.lang">Comparable, java.io.http://docs.oracle.com/javase/8/docs/api/java/io/Serializable.html?is-external=true";
 title="class or interface in java.io">Serializable)
 
-org.apache.hadoop.hbase.HealthChecker.HealthCheckerExitStatus
 org.apache.hadoop.hbase.HConstants.OperationStatusCode
-org.apache.hadoop.hbase.HConstants.Modify
+org.apache.hadoop.hbase.HealthChecker.HealthCheckerExitStatus
 org.apache.hadoop.hbase.MetaTableAccessor.QueryType
-org.apache.hadoop.hbase.ProcedureState
+org.apache.hadoop.hbase.Coprocessor.State
 org.apache.hadoop.hbase.KeepDeletedCells
+org.apache.hadoop.hbase.ProcedureState
 org.apache.hadoop.hbase.KeyValue.Type
-org.apache.hadoop.hbase.Coprocessor.State
+org.apache.hadoop.hbase.HConstants.Modify
 org.apache.hadoop.hbase.CompatibilitySingletonFactory.SingletonStorage
 
 

http://git-wip-us.apache.org/repos/asf/hbase-site/blob/74ea7fbd/devapidocs/org/apache/hadoop/hbase/procedure2/package-tree.html
--
diff --git a/devapidocs/org/apache/hadoop/hbase/procedure2/package-tree.html 
b/devapidocs/org/apache/hadoop/hbase/procedure2/package-tree.html
index 181ba30..4d206a5 100644
--- a/devapidocs/org/apache/hadoop/hbase/procedure2/package-tree.html
+++ b/devapidocs/org/apache/hadoop/hbase/procedure2/package-tree.html
@@ -179,8 +179,8 @@
 
 java.lang.http://docs.oracle.com/javase/8/docs/api/java/lang/Enum.html?is-external=true";
 title="class or interface in java.lang">Enum (implements java.lang.http://docs.oracle.com/javase/8/docs/api/java/lang/Comparable.html?is-external=true";
 title="class or interface in java.lang">Comparable, java.io.http://docs.oracle.com/javase/8/docs/api/java/io/Serializable.html?is-external=true";
 title="class or interface in java.io">Serializable)
 
-org.apache.hadoop.hbase.procedure2.StateMachineProcedure.Flow
 org.apache.hadoop.hbase.procedure2.RootProcedureState.State
+org.apache.hadoop.hbase.procedure2.StateMachineProcedure.Flow
 
 
 

http://git-wip-us.apache.org/repos/asf/hbase-site/blob/74ea7fbd/devapidocs/org/apache/hadoop/hbase/quotas/package-tree.html
--
diff --git a/devapidocs/org/apache/hadoop/hbase/quotas/package-tree.html 
b/devapidocs/org/apache/hadoop/hbase/quotas/package-tree.html
index 09bceae..9407432 100644
--- a/devapidocs/org/apache/hadoop/hbase/quotas/package-tree.html
+++ b/devapidocs/org/apache/hadoop/hbase/quotas/package-tree.html
@@ -179,11 +179,11 @@
 
 java.lang.http://docs.oracle.com/javase/8/docs/api/java/lang/Enum.html?is-external=true";
 title="class or interface in java.lang">Enum (implements java.lang.http://docs.oracle.com/javase/8/docs/api/java/lang/Comparable.html?is-external=true";
 title="class or interface in java.lang">Comparable, java.io.http://docs.oracle.com/javase/8/docs/api/java/io/Serializable.html?is-external=true";
 title="class or interface in java.io">Serializable)
 
-org.apache.hadoop.hbase.quotas.ThrottleType
+org.apache.hadoop.hbase.quotas.ThrottlingException.Type
 org.apache.hadoop.hbase.quotas.QuotaType
 org.apache.hadoop.hbase.quotas.QuotaScope
+org.apache.hadoop.hbase.quotas.ThrottleType
 org.apache.hadoop.hbase.quotas.OperationQuota.Operation

[30/52] [partial] hbase-site git commit: Published site at 8a6d6aa23944bbfd5047cf0c09fb4d8045735dab.

2016-11-11 Thread stack

http://git-wip-us.apache.org/repos/asf/hbase-site/blob/74ea7fbd/devapidocs/org/apache/hadoop/hbase/client/AsyncRpcRetryingCallerFactory.ScanSingleRegionCallerBuilder.html
--
diff --git 
a/devapidocs/org/apache/hadoop/hbase/client/AsyncRpcRetryingCallerFactory.ScanSingleRegionCallerBuilder.html
 
b/devapidocs/org/apache/hadoop/hbase/client/AsyncRpcRetryingCallerFactory.ScanSingleRegionCallerBuilder.html
new file mode 100644
index 000..b1740aa
--- /dev/null
+++ 
b/devapidocs/org/apache/hadoop/hbase/client/AsyncRpcRetryingCallerFactory.ScanSingleRegionCallerBuilder.html
@@ -0,0 +1,527 @@
+http://www.w3.org/TR/html4/loose.dtd";>
+
+
+
+
+
+AsyncRpcRetryingCallerFactory.ScanSingleRegionCallerBuilder (Apache 
HBase 2.0.0-SNAPSHOT API)
+
+
+
+
+
+var methods = 
{"i0":10,"i1":10,"i2":10,"i3":10,"i4":10,"i5":10,"i6":10,"i7":10,"i8":10,"i9":10};
+var tabs = {65535:["t0","All Methods"],2:["t2","Instance 
Methods"],8:["t4","Concrete Methods"]};
+var altColor = "altColor";
+var rowColor = "rowColor";
+var tableTab = "tableTab";
+var activeTableTab = "activeTableTab";
+
+
+JavaScript is disabled on your browser.
+
+
+
+
+
+Skip navigation links
+
+
+
+
+Overview
+Package
+Class
+Use
+Tree
+Deprecated
+Index
+Help
+
+
+
+
+Prev Class
+Next Class
+
+
+Frames
+No Frames
+
+
+All Classes
+
+
+
+
+
+
+
+Summary: 
+Nested | 
+Field | 
+Constr | 
+Method
+
+
+Detail: 
+Field | 
+Constr | 
+Method
+
+
+
+
+
+
+
+
+org.apache.hadoop.hbase.client
+Class 
AsyncRpcRetryingCallerFactory.ScanSingleRegionCallerBuilder
+
+
+
+http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true";
 title="class or interface in java.lang">java.lang.Object
+
+
+org.apache.hadoop.hbase.client.AsyncRpcRetryingCallerFactory.ScanSingleRegionCallerBuilder
+
+
+
+
+
+
+
+Enclosing class:
+AsyncRpcRetryingCallerFactory
+
+
+
+public class AsyncRpcRetryingCallerFactory.ScanSingleRegionCallerBuilder
+extends http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true";
 title="class or interface in java.lang">Object
+
+
+
+
+
+
+
+
+
+
+
+Field Summary
+
+Fields 
+
+Modifier and Type
+Field and Description
+
+
+private ScanResultConsumer
+consumer 
+
+
+private HRegionLocation
+loc 
+
+
+private ScanResultCache
+resultCache 
+
+
+private long
+rpcTimeoutNs 
+
+
+private Scan
+scan 
+
+
+private long
+scannerId 
+
+
+private long
+scanTimeoutNs 
+
+
+private 
org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ClientService.Interface
+stub 
+
+
+
+
+
+
+
+
+
+Constructor Summary
+
+Constructors 
+
+Constructor and Description
+
+
+ScanSingleRegionCallerBuilder() 
+
+
+
+
+
+
+
+
+
+Method Summary
+
+All Methods Instance Methods Concrete Methods 
+
+Modifier and Type
+Method and Description
+
+
+AsyncScanSingleRegionRpcRetryingCaller
+build() 
+
+
+AsyncRpcRetryingCallerFactory.ScanSingleRegionCallerBuilder
+consumer(ScanResultConsumer consumer) 
+
+
+AsyncRpcRetryingCallerFactory.ScanSingleRegionCallerBuilder
+id(long scannerId) 
+
+
+AsyncRpcRetryingCallerFactory.ScanSingleRegionCallerBuilder
+location(HRegionLocation loc) 
+
+
+AsyncRpcRetryingCallerFactory.ScanSingleRegionCallerBuilder
+resultCache(ScanResultCache resultCache) 
+
+
+AsyncRpcRetryingCallerFactory.ScanSingleRegionCallerBuilder
+rpcTimeout(long rpcTimeout,
+  http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/TimeUnit.html?is-external=true";
 title="class or interface in 
java.util.concurrent">TimeUnit unit) 
+
+
+AsyncRpcRetryingCallerFactory.ScanSingleRegionCallerBuilder
+scanTimeout(long scanTimeout,
+   http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/TimeUnit.html?is-external=true";
 title="class or interface in 
java.util.concurrent">TimeUnit unit) 
+
+
+AsyncRpcRetryingCallerFactory.ScanSingleRegionCallerBuilder
+setScan(Scan scan) 
+
+
+http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/CompletableFuture.html?is-external=true";
 title="class or interface in java.util.concurrent">CompletableFutureBoolean>
+start()
+Short cut for build().start().
+
+
+
+AsyncRpcRetryingCallerFactory.ScanSingleRegionCallerBuilder
+stub(org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ClientService.Interface stub) 
+
+
+
+
+
+
+Methods inherited from class java.lang.http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is

[36/52] [partial] hbase-site git commit: Published site at 8a6d6aa23944bbfd5047cf0c09fb4d8045735dab.

2016-11-11 Thread stack

http://git-wip-us.apache.org/repos/asf/hbase-site/blob/74ea7fbd/devapidocs/org/apache/hadoop/hbase/MetaTableAccessor.CloseableVisitor.html
--
diff --git 
a/devapidocs/org/apache/hadoop/hbase/MetaTableAccessor.CloseableVisitor.html 
b/devapidocs/org/apache/hadoop/hbase/MetaTableAccessor.CloseableVisitor.html
index 1c94730..7592197 100644
--- a/devapidocs/org/apache/hadoop/hbase/MetaTableAccessor.CloseableVisitor.html
+++ b/devapidocs/org/apache/hadoop/hbase/MetaTableAccessor.CloseableVisitor.html
@@ -103,7 +103,7 @@
 
 
 
-public static interface MetaTableAccessor.CloseableVisitor
+public static interface MetaTableAccessor.CloseableVisitor
 extends MetaTableAccessor.Visitor, http://docs.oracle.com/javase/8/docs/api/java/io/Closeable.html?is-external=true";
 title="class or interface in java.io">Closeable
 Implementations 'visit' a catalog table row but with 
close() at the end.
 

http://git-wip-us.apache.org/repos/asf/hbase-site/blob/74ea7fbd/devapidocs/org/apache/hadoop/hbase/MetaTableAccessor.CollectAllVisitor.html
--
diff --git 
a/devapidocs/org/apache/hadoop/hbase/MetaTableAccessor.CollectAllVisitor.html 
b/devapidocs/org/apache/hadoop/hbase/MetaTableAccessor.CollectAllVisitor.html
index 1874238..e106ff5 100644
--- 
a/devapidocs/org/apache/hadoop/hbase/MetaTableAccessor.CollectAllVisitor.html
+++ 
b/devapidocs/org/apache/hadoop/hbase/MetaTableAccessor.CollectAllVisitor.html
@@ -122,7 +122,7 @@ var activeTableTab = "activeTableTab";
 
 
 
-static class MetaTableAccessor.CollectAllVisitor
+static class MetaTableAccessor.CollectAllVisitor
 extends MetaTableAccessor.CollectingVisitor
 Collects all returned.
 
@@ -214,7 +214,7 @@ extends 
 
 CollectAllVisitor
-CollectAllVisitor()
+CollectAllVisitor()
 
 
 
@@ -231,7 +231,7 @@ extends 
 
 add
-void add(Result r)
+void add(Result r)
 
 Specified by:
 add in
 class MetaTableAccessor.CollectingVisitor

http://git-wip-us.apache.org/repos/asf/hbase-site/blob/74ea7fbd/devapidocs/org/apache/hadoop/hbase/MetaTableAccessor.CollectingVisitor.html
--
diff --git 
a/devapidocs/org/apache/hadoop/hbase/MetaTableAccessor.CollectingVisitor.html 
b/devapidocs/org/apache/hadoop/hbase/MetaTableAccessor.CollectingVisitor.html
index 4200670..c727994 100644
--- 
a/devapidocs/org/apache/hadoop/hbase/MetaTableAccessor.CollectingVisitor.html
+++ 
b/devapidocs/org/apache/hadoop/hbase/MetaTableAccessor.CollectingVisitor.html
@@ -121,7 +121,7 @@ var activeTableTab = "activeTableTab";
 
 
 
-abstract static class MetaTableAccessor.CollectingVisitor
+abstract static class MetaTableAccessor.CollectingVisitor
 extends http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true";
 title="class or interface in java.lang">Object
 implements MetaTableAccessor.Visitor
 A MetaTableAccessor.Visitor that 
collects content out of passed Result.
@@ -221,7 +221,7 @@ implements 
 
 results
-final http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true";
 title="class or interface in java.util">List results
+final http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true";
 title="class or interface in java.util">List results
 
 
 
@@ -238,7 +238,7 @@ implements 
 
 CollectingVisitor
-CollectingVisitor()
+CollectingVisitor()
 
 
 
@@ -255,7 +255,7 @@ implements 
 
 visit
-public boolean visit(Result r)
+public boolean visit(Result r)
   throws http://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true";
 title="class or interface in java.io">IOException
 Description copied from 
interface: MetaTableAccessor.Visitor
 Visit the catalog table row.
@@ -278,7 +278,7 @@ implements 
 
 add
-abstract void add(Result r)
+abstract void add(Result r)
 
 
 
@@ -287,7 +287,7 @@ implements 
 
 getResults
-http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true";
 title="class or interface in java.util">List getResults()
+http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true";
 title="class or interface in java.util">List getResults()
 
 Returns:
 Collected results; wait till visits complete to collect all

http://git-wip-us.apache.org/repos/asf/hbase-site/blob/74ea7fbd/devapidocs/org/apache/hadoop/hbase/MetaTableAccessor.DefaultVisitorBase.html
--
diff --git 
a/devapidocs/org/apache/hadoop/hbase/MetaTableAccessor.DefaultVisitorBase.html 
b/devapidocs/org/apache/hadoop/hbase/MetaTableAccessor.DefaultVisitorBase.html
index 26d69db..be586e2 100644
--- 
a/devapidocs/org/apache/hadoop/hbase/MetaTableAccessor.DefaultVisitorBase.html
+++ 
b/devapidocs/org/apache/hadoop/hbase/MetaTableAccessor.DefaultVisitorBase.html
@@ -121,7 +121,7 @@ var activeTableTab = "activeTableTab";
 
 
 
-p

[01/52] [partial] hbase-site git commit: Published site at 8a6d6aa23944bbfd5047cf0c09fb4d8045735dab.

2016-11-11 Thread stack

Repository: hbase-site
Updated Branches:
  refs/heads/asf-site 8418e382f -> ca662680d


http://git-wip-us.apache.org/repos/asf/hbase-site/blob/74ea7fbd/devapidocs/org/apache/hadoop/hbase/regionserver/MetricsRegionServerSourceImpl.html
--
diff --git 
a/devapidocs/org/apache/hadoop/hbase/regionserver/MetricsRegionServerSourceImpl.html
 
b/devapidocs/org/apache/hadoop/hbase/regionserver/MetricsRegionServerSourceImpl.html
index 9f26a88..e8fd55b 100644
--- 
a/devapidocs/org/apache/hadoop/hbase/regionserver/MetricsRegionServerSourceImpl.html
+++ 
b/devapidocs/org/apache/hadoop/hbase/regionserver/MetricsRegionServerSourceImpl.html
@@ -316,7 +316,7 @@ implements MetricsRegionServerSource
-APPEND_KEY,
 AVERAGE_REGION_SIZE,
 AVERAGE_REGION_SIZE_DESC,
 AVG_STORE_FILE_AGE,
 AVG_STORE_FILE_AGE_DESC,
 BLOCK_CACHE_BLOOM_CHUNK_HIT_COUNT,
 BLOCK_CAC
 HE_BLOOM_CHUNK_MISS_COUNT, BLOCK_CACHE_COUNT,
 BLOCK_CACHE_COUNT_DESC,
 BLOCK_CACHE_DATA_HIT_COUNT,
 BLOCK_CACHE_DATA_MISS_COUNT,
 BLOCK_CACHE_DELETE_FAMILY_BLOOM_HIT_COUNT,
 BLOCK_CACHE_DELETE_FAMILY_BLOOM_MISS_COUNT,
 BLOCK_CACHE_ENCODED_DATA_HIT_COUNT,
 BLOCK_CACHE_ENCODED_DATA_MISS_COUNT,
 BLOCK_CACHE_EVICTION_COUNT,
 BLOCK_CACHE_EVICTION_COUNT_DESC,
 BLOCK_CACHE_EXPRESS_HIT_PERCENT,
 BLOCK_CACHE_EXPRESS_HIT_PERCENT_DESC,
 BLOCK_CACHE_FAILED_INSERTION_COUNT,
 BLOCK_CACHE_FAILED_INSERTION_COUNT_DESC,
 BLOCK_CACHE_FILE_INFO_HIT_COUNT,
 BLOCK_CACHE_FILE_INFO_MISS_COUNT,
 BLOCK_CACHE_FREE_DESC,
 BLOCK_CACHE_FREE_SIZE,
 BLOCK_CACHE_GENERAL_BLOOM_META_HIT_COUNT,
 BLOCK_CACHE_GENERAL_BLOOM_META_MISS_COUNT,
 BLOCK_CACHE_HIT_COUNT,
 BLOCK_CACHE_HIT_COUNT_DESC,
 BLOCK_CACHE_HIT_PERCENT,
 BLOCK_CACHE_HIT_PERCENT_DESC,
 BLOCK_CACHE_INTERMEDIATE_INDEX_HIT_COUNT, BLOCK_CACHE_INTERMEDIATE_INDEX_MISS_COUNT,
 BLOCK_CACHE_LEAF_INDEX_HIT_COUNT,
 BLOCK_CACHE_LEAF_INDEX_MISS_COUNT,
 BLOCK_CACHE_META_HIT_COUNT,
 BLOCK_CACHE_META_MISS_COUNT,
 BLOCK_CACHE_MISS_COUNT, BLOCK_CACHE_PRIMARY_EVICTION_COUNT,
 BLOCK_CACHE_PRIMARY_EVICTION_COUNT_DESC,
 BLOCK_CACHE_PRIMARY_HIT_COUNT,
 BLOCK_CACHE_PRIMARY_HIT_COUNT_DESC,
 BLOCK_CACHE_PRIMARY_MISS_COUNT,
 B
 LOCK_CACHE_ROOT_INDEX_HIT_COUNT, BLOCK_CACHE_ROOT_INDEX_MISS_COUNT,
 BLOCK_CACHE_SIZE,
 BLOCK_CACHE_SIZE_DESC,
 BLOCK_CACHE_TRAILER_HIT_COUNT,
 BLOCK_CACHE_TRAILER_MISS_COUNT,
 BLOCK_COUNT_MISS_COUNT_DESC,
 BLOCK_COUNT_PRIMARY_MISS_COUNT_DESC,
 BLOCKED_REQUESTS_COUNT,
 BLOCKED_REQUESTS_COUNT_DESC,
 CELLS_COUNT_COMPACTED_FROM_MOB,
 CELLS_COUNT_COMPACTED_FROM_MOB_DESC,
 CELLS_COUNT_COMPACTED_TO_MOB,
 CELLS_COUNT_COMPACTED_TO_MOB_DESC, CELLS_SIZE_COMPACTED_FROM_MOB,
 CELLS_SIZE_COMPACTED_FROM_MOB_DESC,
 CELLS_SIZE_COMPACTED_TO_MOB,
 CELLS_SIZE_COMPACTED_TO_MOB_DESC,
 CHECK_MUTATE_FAILED_COUNT,
 CHEC
 K_MUTATE_FAILED_COUNT_DESC, CHECK_MUTATE_PASSED_COUNT,
 CHECK_MUTATE_PASSED_COUNT_DESC,
 CLUSTER_ID_DESC,
 CLUSTER_ID_NAME,
 COMPACTED_CELLS,
 COMPACTED_CELLS_DESC,
 COMPACTED_C
 ELLS_SIZE, COMPACTED_CELLS_SIZE_DESC,
 COMPACTED_INPUT_BYTES,
 COMPACTED_INPUT_BYTES_DESC,
 COMPACTED_OUTPUT_BYTES,
 COMPACTED_OUTPUT_BYTES_DESC,
 COMPACTION_INPUT_FILE_COUNT,
 COMPACTION_INPUT_FILE_COUNT_DESC, 
COMPACTION_INPUT_SIZE,
 COMPACTION_INPUT_SIZE_DESC,
 COMPACTION_OUTPUT_FILE_COUNT,
 COMPACTION_OUTPUT_FILE_COUNT_DESC,
 COMPACTION_OUTPUT_SIZE,
 COMPACTION_OUTPUT_SIZE_DESC,
 COMPACTION_QUEUE_LENGTH,
 COMPACTION_QUEUE_LENGTH_DESC,
 COMPACTION_TIME,
 COMPACTION_TIME_DESC,
 DATA_SIZE_WITHOUT_WAL,
 DATA_SIZE_WITHOUT_WAL_DESC,
 DELETE_KEY,
 FILTERED_READ_REQUEST_COUNT,
 FILTERED_READ_REQUEST_COUNT_DESC,
 FLUSH_MEMSTORE_SIZE,
 FLUSH_MEMSTORE_SIZE_DESC,
 FLUSH_OUTPUT_SIZE,
 FLUSH_OUTPUT_SIZE_DESC,
 FLUSH_QUEUE_LENGTH<
 /a>, FLUSH_QUEUE_LENGTH_DESC,
 FLUSH_TIME,
 FLUSH_TIME_DESC,
 FLUSHED_CELLS,
 FLUSHED_CELLS_DESC,
 FLUSHED_CELLS_SIZE,
 FLUSHED_CELLS_SIZE_DESC,
 FLUSHED_MEMSTORE_BYTES,
 FLUSHED_MEMSTORE_BYTES_DESC,
 FLUSHED_OUTPUT_BYTES,
 FLUSHED_OUTPUT_BYTES_DESC,
 GET_KEY,
 GET_SIZE_KEY,
 HEDGED_READ_WINS,
 HEDGED_READ_WINS_DESC, HEDGED_READS,
 HEDGED_READS_DESC,
 INCREMENT_KEY,
 LARGE_COMPACTION_QUEUE_LENGTH,
 LARGE_COMPACTION_QUEUE_LENGTH_DESC,
 MAJOR_COMPACTED_CELLS,
 MAJOR_COMPACTED_CELLS_DESC, MAJOR_COMPACTED_CELLS_SIZE,
 MAJOR_COMPACTED_CELLS_SIZE_DESC,
 MAJOR_COMPACTED_INPUT_BYTES,
 MAJOR_COMPACTED_INPUT_BYTES_DESC,
 MAJOR_COMPACTED_OUTPUT_BYTES,
 MAJOR_COMPACTED_OUTPUT_B
 YTES_DESC, MAJOR_COMPACTION_INPUT_FILE_COUNT,
 MAJOR_COMPACTION_INPUT_FILE_COUNT_DESC,
 MAJOR_COMPACTION_INPUT_SIZE,
 MAJOR_COMPACTION_INPUT_SIZE_DESC,
 MAJOR_COMPACTION_OUTPUT_FILE_COUNT,
 MAJOR_COMPACTION_OUTP
 UT_FILE_COUNT_DESC, MAJOR_COMPACTION_OUTPUT_SIZE,
 MAJOR_COMPACTION_OUTPUT_SIZE_DESC,
 MAJOR_COMPACTION_TIME,
 MAJOR_COMPACTION_TIME_DESC,
 MAX_STORE_FILE_AGE,
 MAX_STORE_FILE_AGE_DESC,
 MEMSTORE_SIZE, MEMSTORE_SIZE_DESC,
 METRICS_CONTEXT,
 METRICS_DESCRIPTION,
 METRICS_JMX_CONTEXT,
 METRICS_NAME,
 MIN_STORE_FILE_AGE,
 MIN_STORE_FILE_AGE_DESC
 , MOB_FILE_CACHE_ACCESS_COUNT,
 MOB_FILE_CACHE_ACCESS_COUNT_DESC,
 MOB_FILE_CACHE_COUNT

[44/52] [partial] hbase-site git commit: Published site at 8a6d6aa23944bbfd5047cf0c09fb4d8045735dab.

2016-11-11 Thread stack

http://git-wip-us.apache.org/repos/asf/hbase-site/blob/74ea7fbd/apidocs/src-html/org/apache/hadoop/hbase/snapshot/ExportSnapshot.html
--
diff --git 
a/apidocs/src-html/org/apache/hadoop/hbase/snapshot/ExportSnapshot.html 
b/apidocs/src-html/org/apache/hadoop/hbase/snapshot/ExportSnapshot.html
index 99a2002..3355b2e 100644
--- a/apidocs/src-html/org/apache/hadoop/hbase/snapshot/ExportSnapshot.html
+++ b/apidocs/src-html/org/apache/hadoop/hbase/snapshot/ExportSnapshot.html
@@ -39,1076 +39,1084 @@
 031import java.util.List;
 032import java.util.Random;
 033
-034import org.apache.commons.logging.Log;
-035import 
org.apache.commons.logging.LogFactory;
-036import 
org.apache.hadoop.hbase.classification.InterfaceAudience;
-037import 
org.apache.hadoop.hbase.classification.InterfaceStability;
-038import 
org.apache.hadoop.conf.Configuration;
-039import 
org.apache.hadoop.conf.Configured;
-040import 
org.apache.hadoop.fs.FSDataInputStream;
-041import 
org.apache.hadoop.fs.FSDataOutputStream;
-042import 
org.apache.hadoop.fs.FileChecksum;
-043import org.apache.hadoop.fs.FileStatus;
-044import org.apache.hadoop.fs.FileSystem;
-045import org.apache.hadoop.fs.FileUtil;
-046import org.apache.hadoop.fs.Path;
-047import 
org.apache.hadoop.fs.permission.FsPermission;
-048import 
org.apache.hadoop.hbase.TableName;
-049import 
org.apache.hadoop.hbase.HBaseConfiguration;
-050import 
org.apache.hadoop.hbase.HConstants;
-051import 
org.apache.hadoop.hbase.HRegionInfo;
-052import 
org.apache.hadoop.hbase.io.FileLink;
-053import 
org.apache.hadoop.hbase.io.HFileLink;
-054import 
org.apache.hadoop.hbase.io.WALLink;
-055import 
org.apache.hadoop.hbase.mapreduce.TableMapReduceUtil;
-056import 
org.apache.hadoop.hbase.mob.MobUtils;
-057import 
org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.SnapshotDescription;
-058import 
org.apache.hadoop.hbase.shaded.protobuf.generated.SnapshotProtos.SnapshotFileInfo;
-059import 
org.apache.hadoop.hbase.shaded.protobuf.generated.SnapshotProtos.SnapshotRegionManifest;
-060import 
org.apache.hadoop.hbase.util.FSUtils;
-061import 
org.apache.hadoop.hbase.util.HFileArchiveUtil;
-062import 
org.apache.hadoop.hbase.util.Pair;
-063import 
org.apache.hadoop.io.BytesWritable;
-064import org.apache.hadoop.io.IOUtils;
-065import 
org.apache.hadoop.io.NullWritable;
-066import org.apache.hadoop.io.Writable;
-067import org.apache.hadoop.mapreduce.Job;
-068import 
org.apache.hadoop.mapreduce.JobContext;
-069import 
org.apache.hadoop.mapreduce.Mapper;
-070import 
org.apache.hadoop.mapreduce.InputFormat;
-071import 
org.apache.hadoop.mapreduce.InputSplit;
-072import 
org.apache.hadoop.mapreduce.RecordReader;
-073import 
org.apache.hadoop.mapreduce.TaskAttemptContext;
-074import 
org.apache.hadoop.mapreduce.lib.output.NullOutputFormat;
-075import 
org.apache.hadoop.mapreduce.security.TokenCache;
-076import 
org.apache.hadoop.hbase.io.hadoopbackport.ThrottledInputStream;
-077import 
org.apache.hadoop.util.StringUtils;
-078import org.apache.hadoop.util.Tool;
-079import 
org.apache.hadoop.util.ToolRunner;
-080
-081/**
-082 * Export the specified snapshot to a 
given FileSystem.
-083 *
-084 * The .snapshot/name folder is copied to 
the destination cluster
-085 * and then all the hfiles/wals are 
copied using a Map-Reduce Job in the .archive/ location.
-086 * When everything is done, the second 
cluster can restore the snapshot.
-087 */
-088@InterfaceAudience.Public
-089@InterfaceStability.Evolving
-090public class ExportSnapshot extends 
Configured implements Tool {
-091  public static final String NAME = 
"exportsnapshot";
-092  /** Configuration prefix for overrides 
for the source filesystem */
-093  public static final String 
CONF_SOURCE_PREFIX = NAME + ".from.";
-094  /** Configuration prefix for overrides 
for the destination filesystem */
-095  public static final String 
CONF_DEST_PREFIX = NAME + ".to.";
-096
-097  private static final Log LOG = 
LogFactory.getLog(ExportSnapshot.class);
-098
-099  private static final String MR_NUM_MAPS 
= "mapreduce.job.maps";
-100  private static final String 
CONF_NUM_SPLITS = "snapshot.export.format.splits";
-101  private static final String 
CONF_SNAPSHOT_NAME = "snapshot.export.format.snapshot.name";
-102  private static final String 
CONF_SNAPSHOT_DIR = "snapshot.export.format.snapshot.dir";
-103  private static final String 
CONF_FILES_USER = "snapshot.export.files.attributes.user";
-104  private static final String 
CONF_FILES_GROUP = "snapshot.export.files.attributes.group";
-105  private static final String 
CONF_FILES_MODE = "snapshot.export.files.attributes.mode";
-106  private static final String 
CONF_CHECKSUM_VERIFY = "snapshot.export.checksum.verify";
-107  private static final String 
CONF_OUTPUT_ROOT = "snapshot.export.output.root";
-108  private static final String 
CONF_INPUT_ROOT = "snapshot.export.input.root";
-109  private static final String 
CONF_BUFFER_SIZE = "snapshot.

[25/52] [partial] hbase-site git commit: Published site at 8a6d6aa23944bbfd5047cf0c09fb4d8045735dab.

2016-11-11 Thread stack

http://git-wip-us.apache.org/repos/asf/hbase-site/blob/74ea7fbd/devapidocs/org/apache/hadoop/hbase/client/CompleteScanResultCache.html
--
diff --git 
a/devapidocs/org/apache/hadoop/hbase/client/CompleteScanResultCache.html 
b/devapidocs/org/apache/hadoop/hbase/client/CompleteScanResultCache.html
new file mode 100644
index 000..50d195e
--- /dev/null
+++ b/devapidocs/org/apache/hadoop/hbase/client/CompleteScanResultCache.html
@@ -0,0 +1,400 @@
+http://www.w3.org/TR/html4/loose.dtd";>
+
+
+
+
+
+CompleteScanResultCache (Apache HBase 2.0.0-SNAPSHOT API)
+
+
+
+
+
+var methods = {"i0":10,"i1":10,"i2":10,"i3":10};
+var tabs = {65535:["t0","All Methods"],2:["t2","Instance 
Methods"],8:["t4","Concrete Methods"]};
+var altColor = "altColor";
+var rowColor = "rowColor";
+var tableTab = "tableTab";
+var activeTableTab = "activeTableTab";
+
+
+JavaScript is disabled on your browser.
+
+
+
+
+
+Skip navigation links
+
+
+
+
+Overview
+Package
+Class
+Use
+Tree
+Deprecated
+Index
+Help
+
+
+
+
+Prev Class
+Next Class
+
+
+Frames
+No Frames
+
+
+All Classes
+
+
+
+
+
+
+
+Summary: 
+Nested | 
+Field | 
+Constr | 
+Method
+
+
+Detail: 
+Field | 
+Constr | 
+Method
+
+
+
+
+
+
+
+
+org.apache.hadoop.hbase.client
+Class 
CompleteScanResultCache
+
+
+
+http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true";
 title="class or interface in java.lang">java.lang.Object
+
+
+org.apache.hadoop.hbase.client.CompleteScanResultCache
+
+
+
+
+
+
+
+All Implemented Interfaces:
+ScanResultCache
+
+
+
+@InterfaceAudience.Private
+class CompleteScanResultCache
+extends http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true";
 title="class or interface in java.lang">Object
+implements ScanResultCache
+A scan result cache that only returns complete result.
+
+
+
+
+
+
+
+
+
+
+
+Field Summary
+
+Fields 
+
+Modifier and Type
+Field and Description
+
+
+private http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true";
 title="class or interface in java.util">List
+partialResults 
+
+
+
+
+
+
+Fields inherited from interface org.apache.hadoop.hbase.client.ScanResultCache
+EMPTY_RESULT_ARRAY
+
+
+
+
+
+
+
+
+Constructor Summary
+
+Constructors 
+
+Constructor and Description
+
+
+CompleteScanResultCache() 
+
+
+
+
+
+
+
+
+
+Method Summary
+
+All Methods Instance Methods Concrete Methods 
+
+Modifier and Type
+Method and Description
+
+
+Result[]
+addAndGet(Result[] results,
+ boolean isHeartbeatMessage)
+Add the given results to cache and get valid results 
back.
+
+
+
+void
+clear()
+Clear the cached result if any.
+
+
+
+private Result
+combine() 
+
+
+private Result[]
+prependCombined(Result[] results,
+   int length) 
+
+
+
+
+
+
+Methods inherited from class java.lang.http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true";
 title="class or interface in java.lang">Object
+http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true#clone--";
 title="class or interface in java.lang">clone, http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true#equals-java.lang.Object-";
 title="class or interface in java.lang">equals, http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true#finalize--";
 title="class or interface in java.lang">finalize, http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true#getClass--";
 title="class or interface in java.lang">getClass, http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true#hashCode--";
 title="class or interface in java.lang">hashCode, http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true#notify--";
 title="class or interface in java.lang">notify, http://docs.oracle.com/javase/8/docs/api/java/lang
 /Object.html?is-external=true#notifyAll--" title="class or interface in 
java.lang">notifyAll, http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true#toString--";
 title="class or interface in java.lang">toString, http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true#wait--";
 title="class or interface in java.lang">wait, http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true#wait-long-";
 title="class or interface in java.lang">wait, http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true#wait-long-int-";
 title="class or interface in java.lang">wa

[03/52] [partial] hbase-site git commit: Published site at 8a6d6aa23944bbfd5047cf0c09fb4d8045735dab.

2016-11-11 Thread stack

http://git-wip-us.apache.org/repos/asf/hbase-site/blob/74ea7fbd/devapidocs/org/apache/hadoop/hbase/regionserver/HeapMemStoreLAB.html
--
diff --git 
a/devapidocs/org/apache/hadoop/hbase/regionserver/HeapMemStoreLAB.html 
b/devapidocs/org/apache/hadoop/hbase/regionserver/HeapMemStoreLAB.html
index fa91e00..f7d0414 100644
--- a/devapidocs/org/apache/hadoop/hbase/regionserver/HeapMemStoreLAB.html
+++ b/devapidocs/org/apache/hadoop/hbase/regionserver/HeapMemStoreLAB.html
@@ -207,6 +207,13 @@ implements reclaimed 
 
 
+
+
+
+
+Fields inherited from 
interface org.apache.hadoop.hbase.regionserver.MemStoreLAB
+USEMSLAB_DEFAULT,
 USEMSLAB_KEY
+
 
 
 

http://git-wip-us.apache.org/repos/asf/hbase-site/blob/74ea7fbd/devapidocs/org/apache/hadoop/hbase/regionserver/ImmutableMemStoreLAB.html
--
diff --git 
a/devapidocs/org/apache/hadoop/hbase/regionserver/ImmutableMemStoreLAB.html 
b/devapidocs/org/apache/hadoop/hbase/regionserver/ImmutableMemStoreLAB.html
index 80c3a41..dbea8f4 100644
--- a/devapidocs/org/apache/hadoop/hbase/regionserver/ImmutableMemStoreLAB.html
+++ b/devapidocs/org/apache/hadoop/hbase/regionserver/ImmutableMemStoreLAB.html
@@ -151,6 +151,13 @@ implements openScannerCount 
 
 
+
+
+
+
+Fields inherited from 
interface org.apache.hadoop.hbase.regionserver.MemStoreLAB
+USEMSLAB_DEFAULT,
 USEMSLAB_KEY
+
 
 
 

http://git-wip-us.apache.org/repos/asf/hbase-site/blob/74ea7fbd/devapidocs/org/apache/hadoop/hbase/regionserver/LogRoller.html
--
diff --git a/devapidocs/org/apache/hadoop/hbase/regionserver/LogRoller.html 
b/devapidocs/org/apache/hadoop/hbase/regionserver/LogRoller.html
index f316118..ceb5b79 100644
--- a/devapidocs/org/apache/hadoop/hbase/regionserver/LogRoller.html
+++ b/devapidocs/org/apache/hadoop/hbase/regionserver/LogRoller.html
@@ -18,7 +18,7 @@
 catch(err) {
 }
 //-->
-var methods = {"i0":10,"i1":10,"i2":10,"i3":10,"i4":10,"i5":10};
+var methods = {"i0":10,"i1":10,"i2":10,"i3":10,"i4":10,"i5":10,"i6":10};
 var tabs = {65535:["t0","All Methods"],2:["t2","Instance 
Methods"],8:["t4","Concrete Methods"]};
 var altColor = "altColor";
 var rowColor = "rowColor";
@@ -114,13 +114,14 @@ var activeTableTab = "activeTableTab";
 
 
 All Implemented Interfaces:
-http://docs.oracle.com/javase/8/docs/api/java/lang/Runnable.html?is-external=true";
 title="class or interface in java.lang">Runnable
+http://docs.oracle.com/javase/8/docs/api/java/io/Closeable.html?is-external=true";
 title="class or interface in java.io">Closeable, http://docs.oracle.com/javase/8/docs/api/java/lang/AutoCloseable.html?is-external=true";
 title="class or interface in java.lang">AutoCloseable, http://docs.oracle.com/javase/8/docs/api/java/lang/Runnable.html?is-external=true";
 title="class or interface in java.lang">Runnable
 
 
 
 @InterfaceAudience.Private
-public class LogRoller
-extends HasThread
+public class LogRoller
+extends HasThread
+implements http://docs.oracle.com/javase/8/docs/api/java/io/Closeable.html?is-external=true";
 title="class or interface in java.io">Closeable
 Runs periodically to determine if the WAL should be rolled.
 
  NOTE: This class extends Thread rather than Chore because the sleep time
@@ -167,18 +168,22 @@ extends rollperiod 
 
 
+private boolean
+running 
+
+
 private Server
 server 
 
-
+
 protected RegionServerServices
 services 
 
-
+
 private int
 threadWakeFrequency 
 
-
+
 private http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/ConcurrentHashMap.html?is-external=true";
 title="class or interface in java.util.concurrent">ConcurrentHashMapBoolean>
 walNeedsRoll 
 
@@ -221,21 +226,25 @@ extends 
 
 void
-interrupt() 
+close() 
 
 
 void
-requestRollAll() 
+interrupt() 
 
 
 void
-run() 
+requestRollAll() 
 
 
+void
+run() 
+
+
 private void
 scheduleFlush(byte[] encodedRegionName) 
 
-
+
 boolean
 walRollFinished()
 For testing only
@@ -276,7 +285,7 @@ extends 
 
 LOG
-private static final org.apache.commons.logging.Log LOG
+private static final org.apache.commons.logging.Log LOG
 
 
 
@@ -285,7 +294,7 @@ extends 
 
 rollLock
-private final http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/locks/ReentrantLock.html?is-external=true";
 title="class or interface in java.util.concurrent.locks">ReentrantLock rollLock
+private final http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/locks/ReentrantLock.html?is-external=true";
 title="class or interface in java.util.concurrent.locks">ReentrantLock rollLock
 
 
 
@@ -294,7 +303,7 @@ extends 
 
 rollLog
-private final http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/atomic/AtomicBoolean.html?is-external=true";
 title="class or interface in java.util.concurrent.atom

[47/52] [partial] hbase-site git commit: Published site at 8a6d6aa23944bbfd5047cf0c09fb4d8045735dab.

2016-11-11 Thread stack

http://git-wip-us.apache.org/repos/asf/hbase-site/blob/74ea7fbd/apidocs/org/apache/hadoop/hbase/snapshot/ExportSnapshot.html
--
diff --git a/apidocs/org/apache/hadoop/hbase/snapshot/ExportSnapshot.html 
b/apidocs/org/apache/hadoop/hbase/snapshot/ExportSnapshot.html
index 31f1354..8a4a217 100644
--- a/apidocs/org/apache/hadoop/hbase/snapshot/ExportSnapshot.html
+++ b/apidocs/org/apache/hadoop/hbase/snapshot/ExportSnapshot.html
@@ -18,7 +18,7 @@
 catch(err) {
 }
 //-->
-var methods = {"i0":9,"i1":10};
+var methods = {"i0":10,"i1":10,"i2":9,"i3":10,"i4":10};
 var tabs = {65535:["t0","All Methods"],1:["t1","Static 
Methods"],2:["t2","Instance Methods"],8:["t4","Concrete Methods"]};
 var altColor = "altColor";
 var rowColor = "rowColor";
@@ -100,7 +100,7 @@ var activeTableTab = "activeTableTab";
 http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true";
 title="class or interface in java.lang">java.lang.Object
 
 
-org.apache.hadoop.conf.Configured
+org.apache.hadoop.hbase.util.AbstractHBaseTool
 
 
 org.apache.hadoop.hbase.snapshot.ExportSnapshot
@@ -120,8 +120,8 @@ var activeTableTab = "activeTableTab";
 
 @InterfaceAudience.Public
  @InterfaceStability.Evolving
-public class ExportSnapshot
-extends org.apache.hadoop.conf.Configured
+public class ExportSnapshot
+extends org.apache.hadoop.hbase.util.AbstractHBaseTool
 implements org.apache.hadoop.util.Tool
 Export the specified snapshot to a given FileSystem.
 
@@ -167,6 +167,13 @@ implements org.apache.hadoop.util.Tool
 NAME 
 
 
+
+
+
+
+Fields inherited from 
class org.apache.hadoop.hbase.util.AbstractHBaseTool
+cmdLineArgs, conf, EXIT_FAILURE, EXIT_SUCCESS
+
 
 
 
@@ -199,22 +206,39 @@ implements org.apache.hadoop.util.Tool
 Method and Description
 
 
-static void
-main(http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
 title="class or interface in 
java.lang">String[] args) 
+protected void
+addOptions()
+Override this to add command-line options using 
AbstractHBaseTool.addOptWithArg(java.lang.String, java.lang.String)
+ and similar methods.
+
 
 
 int
-run(http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
 title="class or interface in java.lang">String[] args)
+doWork()
 Execute the export snapshot by copying the snapshot 
metadata, hfiles and wals.
 
 
+
+static void
+main(http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
 title="class or interface in 
java.lang">String[] args) 
+
+
+protected void
+printUsage() 
+
+
+protected void
+processOptions(org.apache.commons.cli.CommandLine cmd)
+This method is called to process the options after they 
have been parsed.
+
+
 
 
-
+
 
 
-Methods inherited from class org.apache.hadoop.conf.Configured
-getConf, setConf
+Methods inherited from 
class org.apache.hadoop.hbase.util.AbstractHBaseTool
+addOption, addOptNoArg, addOptNoArg, addOptWithArg, addOptWithArg, 
addRequiredOption, addRequiredOptWithArg, addRequiredOptWithArg, doStaticMain, 
getConf, getOptionAsDouble, getOptionAsInt, parseInt, parseLong, printUsage, 
processOldArgs, run, setConf
 
 
 
@@ -224,6 +248,13 @@ implements org.apache.hadoop.util.Tool
 http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true#clone--";
 title="class or interface in java.lang">clone, http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true#equals-java.lang.Object-";
 title="class or interface in java.lang">equals, http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true#finalize--";
 title="class or interface in java.lang">finalize, http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true#getClass--";
 title="class or interface in java.lang">getClass, http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true#hashCode--";
 title="class or interface in java.lang">hashCode, http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true#notify--";
 title="class or interface in java.lang">notify, http://docs.oracle.com/javase/8/docs/api/java/lang
 /Object.html?is-external=true#notifyAll--" title="class or interface in 
java.lang">notifyAll, http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true#toString--";
 title="class or interface in java.lang">toString, http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true#wait--";
 title="class or interface in java.lang">wait, http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true#wait-long-";
 title="class or interface in java.lang">wait, http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true#wait-long-int-";
 title="class or interface in java.lang">wait
 
 
+
+
+
+Methods inherited from interface org.apache.hadoop.util.Tool
+run
+
+
 
 
 
@@ -250,7 +281,7 @@ implements org.apache.hadoop.util.Tool
 
 
 NAME
-public st

[43/52] [partial] hbase-site git commit: Published site at 8a6d6aa23944bbfd5047cf0c09fb4d8045735dab.

2016-11-11 Thread stack

http://git-wip-us.apache.org/repos/asf/hbase-site/blob/74ea7fbd/bulk-loads.html
--
diff --git a/bulk-loads.html b/bulk-loads.html
index 1340642..f082317 100644
--- a/bulk-loads.html
+++ b/bulk-loads.html
@@ -7,7 +7,7 @@
   
 
 
-
+
 
 Apache HBase –  
   Bulk Loads in Apache HBase (TM)
@@ -191,6 +191,18 @@
 
   
   
+  1.1 Documentation
+  
+API
+
+X-Ref
+
+Ref Guide (single-page)
+
+  
+
+
+  
   0.94 Documentation
   
 API
@@ -305,7 +317,7 @@ under the License. -->
 http://www.apache.org/";>The Apache Software 
Foundation.
 All rights reserved.  
 
-  Last Published: 
2016-11-07
+  Last Published: 
2016-11-11

[21/52] [partial] hbase-site git commit: Published site at 8a6d6aa23944bbfd5047cf0c09fb4d8045735dab.

2016-11-11 Thread stack

http://git-wip-us.apache.org/repos/asf/hbase-site/blob/74ea7fbd/devapidocs/org/apache/hadoop/hbase/client/package-use.html
--
diff --git a/devapidocs/org/apache/hadoop/hbase/client/package-use.html 
b/devapidocs/org/apache/hadoop/hbase/client/package-use.html
index 42f1c88..e391b49 100644
--- a/devapidocs/org/apache/hadoop/hbase/client/package-use.html
+++ b/devapidocs/org/apache/hadoop/hbase/client/package-use.html
@@ -432,79 +432,85 @@ service.
 
 
 
+AsyncClientScanner.OpenScannerResponse 
+
+
 AsyncConnection
 The asynchronous version of Connection.
 
 
-
+
 AsyncConnectionConfiguration
 Timeout configs.
 
 
-
+
 AsyncConnectionImpl
 The implementation of AsyncConnection.
 
 
-
+
 AsyncProcess
 This class  allows a continuous flow of requests.
 
 
-
+
 AsyncProcess.RowChecker
 Provide a way to control the flow of rows iteration.
 
 
-
+
 AsyncProcess.RowChecker.ReturnCode 
 
-
+
 AsyncProcess.RowCheckerHost
 Collect all advices from checkers and make the final 
decision.
 
 
-
+
 AsyncRegionLocator
 The asynchronous region locator.
 
 
-
+
 AsyncRegistry
 Implementations hold cluster information such as this 
cluster's id, location of hbase:meta, etc..
 
 
-
+
 AsyncRequestFuture
 The context used to wait for results from one submit 
call.
 
 
-
+
 AsyncRequestFutureImpl
 The context, and return value, for a single 
submit/submitAll call.
 
 
-
+
 AsyncRequestFutureImpl.ReplicaResultState
 Sync point for calls to multiple replicas for the same user 
request (Get).
 
 
-
+
 AsyncRequestFutureImpl.Retry
 For AsyncRequestFutureImpl.manageError(int,
 Row, Retry, Throwable, ServerName).
 
 
-
+
 AsyncRequestFutureImpl.SingleServerRequestRunnable
 Runnable (that can be submitted to thread pool) that 
submits MultiAction to a
  single server.
 
 
-
+
 AsyncRpcRetryingCallerFactory
 Factory to create an AsyncRpcRetryCaller.
 
 
+
+AsyncRpcRetryingCallerFactory.ScanSingleRegionCallerBuilder 
+
 
 AsyncRpcRetryingCallerFactory.SingleRequestCallerBuilder 
 
@@ -512,538 +518,553 @@ service.
 AsyncRpcRetryingCallerFactory.SmallScanCallerBuilder 
 
 
+AsyncScanSingleRegionRpcRetryingCaller
+Retry caller for scanning a region.
+
+
+
 AsyncSingleRequestRpcRetryingCaller
 Retry caller for a single request, such as get, put, 
delete, etc.
 
 
-
+
 AsyncSingleRequestRpcRetryingCaller.Callable 
 
-
+
 AsyncSmallScanRpcRetryingCaller
 Retry caller for smaller scan.
 
 
-
+
 AsyncSmallScanRpcRetryingCaller.SmallScanResponse 
 
-
+
 AsyncTable
 The asynchronous version of Table.
 
 
-
+
 AsyncTableImpl.Converter 
 
-
+
 AsyncTableImpl.NoncedConverter 
 
-
+
 AsyncTableImpl.RpcCall 
 
-
+
 AsyncTableRegionLocator
 The asynchronous version of RegionLocator.
 
 
-
+
 Attributes 
 
-
+
 BatchErrors 
 
-
+
 BufferedMutator
 Used to communicate with a single HBase table similar to Table but 
meant for
  batched, asynchronous puts.
 
 
-
+
 BufferedMutator.ExceptionListener
 Listens for asynchronous exceptions on a BufferedMutator.
 
 
-
+
 BufferedMutatorImpl
 
  Used to communicate with a single HBase table similar to Table
  but meant for batched, potentially asynchronous puts.
 
 
-
+
 BufferedMutatorParams
 Parameters for instantiating a BufferedMutator.
 
 
-
+
 Cancellable
 This should be implemented by the Get/Scan implementations 
that
  talk to replica regions.
 
 
-
+
 CancellableRegionServerCallable
 This class is used to unify HTable calls with AsyncProcess 
Framework.
 
 
-
+
 ClientAsyncPrefetchScanner.PrefetchRunnable 
 
-
+
 ClientScanner
 Implements the scanner interface for the HBase client.
 
 
-
+
 ClientServiceCallable
 A RegionServerCallable set to use the Client protocol.
 
 
-
+
 ClientSideRegionScanner
 A client scanner for a region opened for read-only on the 
client side.
 
 
-
+
 ClientSimpleScanner
 ClientSimpleScanner implements a sync scanner 
behaviour.
 
 
-
+
 ClientSmallReversedScanner.SmallReversedScannerCallableFactory 
 
-
+
 ClientSmallScanner.SmallScannerCallableFactory 
 
-
+
 ClusterConnection
 Internal methods on Connection that should not be used by 
user code.
 
 
-
+
 ClusterStatusListener
 A class that receives the cluster status, and provide it as 
a set of service to the client.
 
 
-
+
 ClusterStatusListener.DeadServerHandler
 Class to be extended to manage a new dead server.
 
 
-
+
 ClusterStatusListener.Listener
 The interface to be implemented by a listener of a cluster 
status event.
 
 
-
+
 CompactionState
 POJO representing the compaction state
 
 
-
+
 CompactType
 Currently, there are only two compact types:
  NORMAL means do store files compaction;
  MOB means do mob files compaction.
 
 
-
+
 Connection
 A cluster connection encapsulating lower level individual 
connections to actual servers and
  a connection to zookeeper.
 
 
-
+
 ConnectionConfiguration
 Configuration parameters for the connection.
 
 
-
+
 ConnectionImplementation
 Main implementation of Connection 
and ClusterConnection 
interfaces

[12/52] [partial] hbase-site git commit: Published site at 8a6d6aa23944bbfd5047cf0c09fb4d8045735dab.

2016-11-11 Thread stack

http://git-wip-us.apache.org/repos/asf/hbase-site/blob/74ea7fbd/devapidocs/org/apache/hadoop/hbase/master/HMasterCommandLine.LocalHMaster.html
--
diff --git 
a/devapidocs/org/apache/hadoop/hbase/master/HMasterCommandLine.LocalHMaster.html
 
b/devapidocs/org/apache/hadoop/hbase/master/HMasterCommandLine.LocalHMaster.html
index c3c7b34..dad1aa5 100644
--- 
a/devapidocs/org/apache/hadoop/hbase/master/HMasterCommandLine.LocalHMaster.html
+++ 
b/devapidocs/org/apache/hadoop/hbase/master/HMasterCommandLine.LocalHMaster.html
@@ -255,7 +255,7 @@ extends 
 
 Methods inherited from class org.apache.hadoop.hbase.regionserver.HRegionServer
-abort,
 addToMovedRegions,
 addToOnlineRegions,
 checkFileSystem,
 cleanMovedRegions,
 closeAllRegions,
 closeAndOfflineRegionForSp
 lit, closeRegion,
 constructRegionServer,
 convertThrowableToIOE,
 createClusterConnection,
 createRegionLoad,
 createRegionServerStatusStub, href="../../../../../org/apache/hadoop/hbase/regionserver/HRegionServer.html#createRegionServerStatusStub-boolean-">createRegionServerStatusStub,
 > href="../../../../../org/apache/hadoop/hbase/regionserver/HRegionServer.html#ensureMetaWALRoller--">ensureMetaWALRoller,
 > href="../../../../../org/apache/hadoop/hbase/regionserver/HRegionServer.html#execRegionServerService-org.apache.hadoop.hbase.shaded.com.google.protobuf.RpcController-org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.CoprocessorServiceRequest-">execRegionServerService,
 > href="../../../../../org/apache/hadoop/hbase/regionserver/HRegionServer.html#getCacheConfig--">getCacheConfig,
 > href="../../../../../org/apache/hadoop/hbase/regionserver/HRegionServer.html#getChoreService--">getChoreService,
 > href="../../../../../org/apache/hadoop/hbase/regionserver/HRegionServer.html#getClusterConnection--">getClusterConnection,
 > getClusterId, getCompactionPressure,
 getCompactionRequester,
 getCompactSplitThread,
 getConfiguration,
 getConfigurationManager,
 getConnection,
 getCoordinatedStateManager,
 getExecutorService,
 getFavoredNodesForRegion,
 getFileSystem,
 getFlushPressure,
 getFlushRequester,
 getFlushThroughputController,
 getFromOnlineRegions,
 getHeapMemoryManager, getInfoServer,
 getLastSequenceId,
 getLeases,
 getMasterAddressTracker,
 getMetaTableLocator,
 getMetrics,
 getMostLoadedRegions,
 getNonceManager, getNumberOfOnlineRegions,
 getOnlineRegion,
 getOnlineRegions,
 getOnlineRegions,
 getOnlineRegionsLocalContext,
 getOnlineTables,
 getRecoveringRegions,
 getRegion, 
getRegionBlockLocations,
 getRegionByEncodedName,
 getRegionByEncodedName,
 getRegionServerAccounting,
 getRegionServerCoprocessorHost,
 getRegionServerCoprocessors,
 getRegionServerMetrics,
 getRegionServerQuotaManager,
 getRegionsInTransitionInRS,
 getRootDir,
 getRpcServer,
 getRSRpcServices,
 getSecureBulkLoadManager,
 getStartcode,
 getTableLockManager,
 getThreadWakeFrequency,
 getWAL,
 getWALs,
 handleReportForDutyResponse,
 isAborted,
 isOnline,
 isProcedureFinished,
 isStopped,
 isStopping,
 kill,
 movedRegionCleanerPeriod,
 onConfigurationChange,
 postOpenDeployTasks,
 postOpenDeployTasks,
 removeFromOnlineRegions,
 reportRegionStateTransition,
 reportRegionStateTransition,
 reportRegionStateTransition,
 requestRegionSplit,
 setInitLatch,
 setupClusterConnection,
 shouldUseThisHostnameInstead,
 stop,
 toString,
 tryRegionServerReport,
 updateConfiguration,
 updateRegionFavoredNodesMapping,
 waitForServerOnline,
 walRollRequestFinished
+abort,
 addToMovedRegions,
 addToOnlineRegions,
 checkFileSystem,
 cleanMovedRegions,
 closeAllRegions,
 closeAndOfflineRegionForSp
 lit, closeRegion,
 constructRegionServer,
 convertThrowableToIOE,
 createClusterConnection,
 createRegionLoad,
 createRegionServerStatusStub, href="../../../../../org/apache/hadoop/hbase/regionserver/HRegionServer.html#createRegionServerStatusStub-boolean-">createRegionServerStatusStub,
 > href="../../../../../org/apache/hadoop/hbase/regionserver/HRegionServer.html#execRegionServerService-org.apache.hadoop.hbase.shaded.com.google.protobuf.RpcController-org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.CoprocessorServiceRequest-">execRegionServerService,
 > href="../../../../../org/apache/hadoop/hbase/regionserver/HRegionServer.html#getCacheConfig--">getCacheConfig,
 > href="../../../../../org/apache/hadoop/hbase/regionserver/HRegionServer.html#getChoreService--">getChoreService,
 > href="../../../../../org/apache/hadoop/hbase/regionserver/HRegionServer.html#getClusterConnection--">getClusterConnection,
 > href="../../../../../org/apache/hadoop/hbase/regionserver/HRegionServer.html#getClusterId--">getClusterId,
 > getCompactionPressure, getCompactionRequester,
 getCompactSplitThread,
 getConfiguration,
 getConfigurationManager,
 getConnection,
 getCoordinatedStateManager,
 getExecutorService,
 getFavoredNodesForRegion,
 getFileSystem,
 getFlushPressure,
 getFlushRequester,
 getFlushThroughputController,
 ge

[23/52] [partial] hbase-site git commit: Published site at 8a6d6aa23944bbfd5047cf0c09fb4d8045735dab.

2016-11-11 Thread stack

http://git-wip-us.apache.org/repos/asf/hbase-site/blob/74ea7fbd/devapidocs/org/apache/hadoop/hbase/client/class-use/Connection.html
--
diff --git 
a/devapidocs/org/apache/hadoop/hbase/client/class-use/Connection.html 
b/devapidocs/org/apache/hadoop/hbase/client/class-use/Connection.html
index bb243c5..ff4d11a 100644
--- a/devapidocs/org/apache/hadoop/hbase/client/class-use/Connection.html
+++ b/devapidocs/org/apache/hadoop/hbase/client/class-use/Connection.html
@@ -474,24 +474,31 @@ Input/OutputFormats, a table indexing MapReduce job, and 
utility methods.
 
 
 static http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
 title="class or interface in java.lang">String
+MetaTableAccessor.getSerialReplicationParentRegion(Connection connection,
+byte[] encodedName)
+Get parent region(s) for a region, only used in serial 
replication.
+
+
+
+static http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
 title="class or interface in java.lang">String
 MetaTableAccessor.getSerialReplicationTableName(Connection connection,
  byte[] encodedName)
 Get the table name for a region, only used in serial 
replication.
 
 
-
+
 static http://docs.oracle.com/javase/8/docs/api/java/util/NavigableMap.html?is-external=true";
 title="class or interface in java.util">NavigableMap
 MetaTableAccessor.getServerUserRegions(Connection connection,
 ServerName serverName) 
 
-
+
 static http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true";
 title="class or interface in java.util">List
 MetaTableAccessor.getTableRegions(Connection connection,
TableName tableName)
 Gets all of the regions of the specified table.
 
 
-
+
 static http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true";
 title="class or interface in java.util">List
 MetaTableAccessor.getTableRegions(Connection connection,
TableName tableName,
@@ -499,14 +506,14 @@ Input/OutputFormats, a table indexing MapReduce job, and 
utility methods.
 Gets all of the regions of the specified table.
 
 
-
+
 static http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true";
 title="class or interface in java.util">List>
 MetaTableAccessor.getTableRegionsAndLocations(Connection connection,
TableName tableName)
 Do not use this method to get meta table regions, use 
methods in MetaTableLocator instead.
 
 
-
+
 static http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true";
 title="class or interface in java.util">List>
 MetaTableAccessor.getTableRegionsAndLocations(Connection connection,
TableName tableName,
@@ -514,20 +521,20 @@ Input/OutputFormats, a table indexing MapReduce job, and 
utility methods.
 Do not use this method to get meta table regions, use 
methods in MetaTableLocator instead.
 
 
-
+
 static TableState
 MetaTableAccessor.getTableState(Connection conn,
  TableName tableName)
 Fetch table state for given table from META table
 
 
-
+
 static http://docs.oracle.com/javase/8/docs/api/java/util/Map.html?is-external=true";
 title="class or interface in java.util">Map
 MetaTableAccessor.getTableStates(Connection conn)
 Fetch table states from META table
 
 
-
+
 static void
 MetaTableAccessor.mergeRegions(Connection connection,
 HRegionInfo mergedRegion,
@@ -540,7 +547,7 @@ Input/OutputFormats, a table indexing MapReduce job, and 
utility methods.
 Merge the two regions into one in an atomic operation.
 
 
-
+
 static void
 MetaTableAccessor.multiMutate(Connection connection,
Table table,
@@ -549,21 +556,21 @@ Input/OutputFormats, a table indexing MapReduce job, and 
utility methods.
 Performs an atomic multi-mutate operation against the given 
table.
 
 
-
+
 private static void
 MetaTableAccessor.multiMutate(Connection connection,
Table table,
byte[] row,
Mutation... mutations) 
 
-
+
 static void
 MetaTableAccessor.mutateMetaTable(Connection connection,
http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true";
 title="class or interface in java.util">List mutations)
 Execute the passed mutations against 
hbase:meta table.
 
 
-
+
 static void
 MetaTableAccessor.mutateRegions(Connection connection,
  http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true";
 title="class or interface in java.util">List regionsToRemove,
@@ -571,7 +578,7 @@ Input/OutputFormats, a table indexing MapReduce job, and 
utility methods.
 Adds and Removes the specified regions from hbase:meta
 
 
-
+
 static void
 MetaTableAccessor.ove

[38/52] [partial] hbase-site git commit: Published site at 8a6d6aa23944bbfd5047cf0c09fb4d8045735dab.

2016-11-11 Thread stack

http://git-wip-us.apache.org/repos/asf/hbase-site/blob/74ea7fbd/devapidocs/org/apache/hadoop/hbase/HConstants.Modify.html
--
diff --git a/devapidocs/org/apache/hadoop/hbase/HConstants.Modify.html 
b/devapidocs/org/apache/hadoop/hbase/HConstants.Modify.html
index 9a183fa..3091b39 100644
--- a/devapidocs/org/apache/hadoop/hbase/HConstants.Modify.html
+++ b/devapidocs/org/apache/hadoop/hbase/HConstants.Modify.html
@@ -123,7 +123,7 @@ var activeTableTab = "activeTableTab";
 
 
 @InterfaceAudience.Private
-public static enum HConstants.Modify
+public static enum HConstants.Modify
 extends http://docs.oracle.com/javase/8/docs/api/java/lang/Enum.html?is-external=true";
 title="class or interface in java.lang">Enum
 modifyTable op for replacing the table descriptor
 
@@ -224,7 +224,7 @@ the order they are declared.
 
 
 CLOSE_REGION
-public static final HConstants.Modify CLOSE_REGION
+public static final HConstants.Modify CLOSE_REGION
 
 
 
@@ -233,7 +233,7 @@ the order they are declared.
 
 
 TABLE_COMPACT
-public static final HConstants.Modify TABLE_COMPACT
+public static final HConstants.Modify TABLE_COMPACT
 
 
 
@@ -242,7 +242,7 @@ the order they are declared.
 
 
 TABLE_FLUSH
-public static final HConstants.Modify TABLE_FLUSH
+public static final HConstants.Modify TABLE_FLUSH
 
 
 
@@ -251,7 +251,7 @@ the order they are declared.
 
 
 TABLE_MAJOR_COMPACT
-public static final HConstants.Modify TABLE_MAJOR_COMPACT
+public static final HConstants.Modify TABLE_MAJOR_COMPACT
 
 
 
@@ -260,7 +260,7 @@ the order they are declared.
 
 
 TABLE_SET_HTD
-public static final HConstants.Modify TABLE_SET_HTD
+public static final HConstants.Modify TABLE_SET_HTD
 
 
 
@@ -269,7 +269,7 @@ the order they are declared.
 
 
 TABLE_SPLIT
-public static final HConstants.Modify TABLE_SPLIT
+public static final HConstants.Modify TABLE_SPLIT
 
 
 
@@ -286,7 +286,7 @@ the order they are declared.
 
 
 values
-public static HConstants.Modify[] values()
+public static HConstants.Modify[] values()
 Returns an array containing the constants of this enum 
type, in
 the order they are declared.  This method may be used to iterate
 over the constants as follows:
@@ -306,7 +306,7 @@ for (HConstants.Modify c : HConstants.Modify.values())
 
 
 valueOf
-public static HConstants.Modify valueOf(http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
 title="class or interface in java.lang">String name)
+public static HConstants.Modify valueOf(http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
 title="class or interface in java.lang">String name)
 Returns the enum constant of this type with the specified 
name.
 The string must match exactly an identifier used to declare an
 enum constant in this type.  (Extraneous whitespace characters are

[48/52] [partial] hbase-site git commit: Published site at 8a6d6aa23944bbfd5047cf0c09fb4d8045735dab.

2016-11-11 Thread stack

http://git-wip-us.apache.org/repos/asf/hbase-site/blob/74ea7fbd/apidocs/org/apache/hadoop/hbase/client/AsyncTable.html
--
diff --git a/apidocs/org/apache/hadoop/hbase/client/AsyncTable.html 
b/apidocs/org/apache/hadoop/hbase/client/AsyncTable.html
index 92b8875..a16afbf 100644
--- a/apidocs/org/apache/hadoop/hbase/client/AsyncTable.html
+++ b/apidocs/org/apache/hadoop/hbase/client/AsyncTable.html
@@ -18,7 +18,7 @@
 catch(err) {
 }
 //-->
-var methods = 
{"i0":6,"i1":18,"i2":6,"i3":18,"i4":6,"i5":18,"i6":6,"i7":6,"i8":18,"i9":6,"i10":6,"i11":6,"i12":6,"i13":6,"i14":6,"i15":6,"i16":18,"i17":18,"i18":6,"i19":6,"i20":6,"i21":6,"i22":6,"i23":18,"i24":6};
+var methods = 
{"i0":6,"i1":18,"i2":6,"i3":18,"i4":6,"i5":18,"i6":6,"i7":6,"i8":18,"i9":6,"i10":6,"i11":6,"i12":6,"i13":6,"i14":6,"i15":6,"i16":6,"i17":18,"i18":18,"i19":6,"i20":6,"i21":6,"i22":6,"i23":6,"i24":6,"i25":6,"i26":18,"i27":6};
 var tabs = {65535:["t0","All Methods"],2:["t2","Instance 
Methods"],4:["t3","Abstract Methods"],16:["t5","Default Methods"]};
 var altColor = "altColor";
 var rowColor = "rowColor";
@@ -242,17 +242,23 @@ public interface 
 long
+getScanTimeout(http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/TimeUnit.html?is-external=true";
 title="class or interface in 
java.util.concurrent">TimeUnit unit)
+Get the timeout of a single operation in a scan.
+
+
+
+long
 getWriteRpcTimeout(http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/TimeUnit.html?is-external=true";
 title="class or interface in 
java.util.concurrent">TimeUnit unit)
 Get timeout of each rpc write request in this Table 
instance.
 
 
-
+
 http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/CompletableFuture.html?is-external=true";
 title="class or interface in java.util.concurrent">CompletableFuture
 increment(Increment increment)
 Increments one or more columns within a single row.
 
 
-
+
 default http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/CompletableFuture.html?is-external=true";
 title="class or interface in java.util.concurrent">CompletableFutureLong>
 incrementColumnValue(byte[] row,
 byte[] family,
@@ -261,7 +267,7 @@ public interface See incrementColumnValue(byte[],
 byte[], byte[], long, Durability)
 
 
-
+
 default http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/CompletableFuture.html?is-external=true";
 title="class or interface in java.util.concurrent">CompletableFutureLong>
 incrementColumnValue(byte[] row,
 byte[] family,
@@ -271,19 +277,26 @@ public interface Atomically increments a column value.
 
 
-
+
 http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/CompletableFuture.html?is-external=true";
 title="class or interface in java.util.concurrent">CompletableFutureVoid>
 mutateRow(RowMutations mutation)
 Performs multiple mutations atomically on a single 
row.
 
 
-
+
 http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/CompletableFuture.html?is-external=true";
 title="class or interface in java.util.concurrent">CompletableFutureVoid>
 put(Put put)
 Puts some data to the table.
 
 
-
+
+void
+scan(Scan scan,
+ScanResultConsumer consumer)
+The basic scan API uses the observer pattern.
+
+
+
 void
 setOperationTimeout(long timeout,
http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/TimeUnit.html?is-external=true";
 title="class or interface in 
java.util.concurrent">TimeUnit unit)
@@ -291,7 +304,7 @@ public interface 
+
 void
 setReadRpcTimeout(long timeout,
  http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/TimeUnit.html?is-external=true";
 title="class or interface in 
java.util.concurrent">TimeUnit unit)
@@ -299,7 +312,14 @@ public interface 
+
+void
+setScanTimeout(long timeout,
+  http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/TimeUnit.html?is-external=true";
 title="class or interface in 
java.util.concurrent">TimeUnit unit)
+Set timeout of a single operation in a scan, such as 
openScanner and next.
+
+
+
 void
 setWriteRpcTimeout(long timeout,
   http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/TimeUnit.html?is-external=true";
 title="class or interface in 
java.util.concurrent">TimeUnit unit)
@@ -307,13 +327,13 @@ public interface 
+
 default http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/CompletableFuture.html?is-external=true";

[05/52] [partial] hbase-site git commit: Published site at 8a6d6aa23944bbfd5047cf0c09fb4d8045735dab.

2016-11-11 Thread stack

http://git-wip-us.apache.org/repos/asf/hbase-site/blob/74ea7fbd/devapidocs/org/apache/hadoop/hbase/regionserver/HRegionServer.CompactionChecker.html
--
diff --git 
a/devapidocs/org/apache/hadoop/hbase/regionserver/HRegionServer.CompactionChecker.html
 
b/devapidocs/org/apache/hadoop/hbase/regionserver/HRegionServer.CompactionChecker.html
index f23a8e6..0a84858 100644
--- 
a/devapidocs/org/apache/hadoop/hbase/regionserver/HRegionServer.CompactionChecker.html
+++ 
b/devapidocs/org/apache/hadoop/hbase/regionserver/HRegionServer.CompactionChecker.html
@@ -122,7 +122,7 @@ var activeTableTab = "activeTableTab";
 
 
 
-private static class HRegionServer.CompactionChecker
+private static class HRegionServer.CompactionChecker
 extends ScheduledChore
 
 
@@ -233,7 +233,7 @@ extends 
 
 instance
-private final HRegionServer instance
+private final HRegionServer instance
 
 
 
@@ -242,7 +242,7 @@ extends 
 
 majorCompactPriority
-private final int majorCompactPriority
+private final int majorCompactPriority
 
 
 
@@ -251,7 +251,7 @@ extends 
 
 DEFAULT_PRIORITY
-private static final int DEFAULT_PRIORITY
+private static final int DEFAULT_PRIORITY
 
 See Also:
 Constant
 Field Values
@@ -264,7 +264,7 @@ extends 
 
 iteration
-private long iteration
+private long iteration
 
 
 
@@ -281,7 +281,7 @@ extends 
 
 CompactionChecker
-CompactionChecker(HRegionServer h,
+CompactionChecker(HRegionServer h,
   int sleepTime,
   Stoppable stopper)
 
@@ -300,7 +300,7 @@ extends 
 
 chore
-protected void chore()
+protected void chore()
 Description copied from 
class: ScheduledChore
 The task to execute on each scheduled execution of the 
Chore
 

http://git-wip-us.apache.org/repos/asf/hbase-site/blob/74ea7fbd/devapidocs/org/apache/hadoop/hbase/regionserver/HRegionServer.MovedRegionInfo.html
--
diff --git 
a/devapidocs/org/apache/hadoop/hbase/regionserver/HRegionServer.MovedRegionInfo.html
 
b/devapidocs/org/apache/hadoop/hbase/regionserver/HRegionServer.MovedRegionInfo.html
index 98558db..3a4e75a 100644
--- 
a/devapidocs/org/apache/hadoop/hbase/regionserver/HRegionServer.MovedRegionInfo.html
+++ 
b/devapidocs/org/apache/hadoop/hbase/regionserver/HRegionServer.MovedRegionInfo.html
@@ -113,7 +113,7 @@ var activeTableTab = "activeTableTab";
 
 
 
-private static class HRegionServer.MovedRegionInfo
+private static class HRegionServer.MovedRegionInfo
 extends http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true";
 title="class or interface in java.lang">Object
 
 
@@ -218,7 +218,7 @@ extends http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?
 
 
 serverName
-private final ServerName serverName
+private final ServerName serverName
 
 
 
@@ -227,7 +227,7 @@ extends http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?
 
 
 seqNum
-private final long seqNum
+private final long seqNum
 
 
 
@@ -236,7 +236,7 @@ extends http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?
 
 
 ts
-private final long ts
+private final long ts
 
 
 
@@ -253,7 +253,7 @@ extends http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?
 
 
 MovedRegionInfo
-public MovedRegionInfo(ServerName serverName,
+public MovedRegionInfo(ServerName serverName,
long closeSeqNum)
 
 
@@ -271,7 +271,7 @@ extends http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?
 
 
 getServerName
-public ServerName getServerName()
+public ServerName getServerName()
 
 
 
@@ -280,7 +280,7 @@ extends http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?
 
 
 getSeqNum
-public long getSeqNum()
+public long getSeqNum()
 
 
 
@@ -289,7 +289,7 @@ extends http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?
 
 
 getMoveTime
-public long getMoveTime()
+public long getMoveTime()
 
 
 

http://git-wip-us.apache.org/repos/asf/hbase-site/blob/74ea7fbd/devapidocs/org/apache/hadoop/hbase/regionserver/HRegionServer.MovedRegionsCleaner.html
--
diff --git 
a/devapidocs/org/apache/hadoop/hbase/regionserver/HRegionServer.MovedRegionsCleaner.html
 
b/devapidocs/org/apache/hadoop/hbase/regionserver/HRegionServer.MovedRegionsCleaner.html
index 3c90c2a..2c5c7b0 100644
--- 
a/devapidocs/org/apache/hadoop/hbase/regionserver/HRegionServer.MovedRegionsCleaner.html
+++ 
b/devapidocs/org/apache/hadoop/hbase/regionserver/HRegionServer.MovedRegionsCleaner.html
@@ -122,7 +122,7 @@ var activeTableTab = "activeTableTab";
 
 
 
-protected static final class HRegionServer.MovedRegionsCleaner
+protected static final class HRegionServer.MovedRegionsCleaner
 extends ScheduledChore
 implements Stoppable
 Creates a Chore thread to clean the moved region 
cache.
@@ -242,7 +242,7 @@ implements 
 
 regionServer
-private HRegionServer regionServer
+private HRegionServer regionServer

[08/52] [partial] hbase-site git commit: Published site at 8a6d6aa23944bbfd5047cf0c09fb4d8045735dab.

2016-11-11 Thread stack

http://git-wip-us.apache.org/repos/asf/hbase-site/blob/74ea7fbd/devapidocs/org/apache/hadoop/hbase/master/procedure/SplitTableRegionProcedure.html
--
diff --git 
a/devapidocs/org/apache/hadoop/hbase/master/procedure/SplitTableRegionProcedure.html
 
b/devapidocs/org/apache/hadoop/hbase/master/procedure/SplitTableRegionProcedure.html
index 8481f42..5519b3b 100644
--- 
a/devapidocs/org/apache/hadoop/hbase/master/procedure/SplitTableRegionProcedure.html
+++ 
b/devapidocs/org/apache/hadoop/hbase/master/procedure/SplitTableRegionProcedure.html
@@ -18,8 +18,8 @@
 catch(err) {
 }
 //-->
-var methods = 
{"i0":10,"i1":10,"i2":10,"i3":10,"i4":10,"i5":10,"i6":10,"i7":10,"i8":10,"i9":10,"i10":10,"i11":10,"i12":10,"i13":10,"i14":10,"i15":10,"i16":10,"i17":10,"i18":10,"i19":10,"i20":10,"i21":10,"i22":10,"i23":10,"i24":10,"i25":10,"i26":10,"i27":10,"i28":10,"i29":10,"i30":10,"i31":10};
-var tabs = {65535:["t0","All Methods"],2:["t2","Instance 
Methods"],8:["t4","Concrete Methods"]};
+var methods = 
{"i0":10,"i1":10,"i2":9,"i3":10,"i4":10,"i5":10,"i6":10,"i7":9,"i8":10,"i9":10,"i10":10,"i11":10,"i12":10,"i13":10,"i14":10,"i15":10,"i16":10,"i17":10,"i18":10,"i19":10,"i20":10,"i21":10,"i22":10,"i23":10,"i24":10,"i25":10,"i26":10,"i27":10,"i28":10,"i29":10,"i30":10,"i31":10,"i32":10,"i33":10};
+var tabs = {65535:["t0","All Methods"],1:["t1","Static 
Methods"],2:["t2","Instance Methods"],8:["t4","Concrete Methods"]};
 var altColor = "altColor";
 var rowColor = "rowColor";
 var tableTab = "tableTab";
@@ -129,7 +129,7 @@ var activeTableTab = "activeTableTab";
 
 
 @InterfaceAudience.Private
-public class SplitTableRegionProcedure
+public class SplitTableRegionProcedure
 extends AbstractStateMachineTableProcedure
 The procedure to split a region in a table.
 
@@ -203,21 +203,9 @@ extends parentHRI 
 
 
-private byte[]
-splitRow 
-
-
-private TableName
-tableName 
-
-
 private http://docs.oracle.com/javase/8/docs/api/java/lang/Boolean.html?is-external=true";
 title="class or interface in java.lang">Boolean
 traceEnabled 
 
-
-private User
-user 
-
 
 
 
@@ -243,9 +231,8 @@ extends SplitTableRegionProcedure() 
 
 
-SplitTableRegionProcedure(MasterProcedureEnv env,
- TableName tableName,
- HRegionInfo parentHRI,
+SplitTableRegionProcedure(MasterProcedureEnv env,
+ HRegionInfo regionToSplit,
  byte[] splitRow) 
 
 
@@ -258,7 +245,7 @@ extends 
-All Methods Instance Methods Concrete Methods 
+All Methods Static Methods Instance Methods Concrete Methods 
 
 Modifier and Type
 Method and Description
@@ -276,186 +263,195 @@ extends 
+private static void
+checkSplitRow(HRegionInfo regionToSplit,
+ byte[] splitRow) 
+
+
 void
 closeParentRegionForSplit(MasterProcedureEnv env)
 RPC to region server that host the parent region, ask for 
close the parent regions and
  creating daughter regions
 
 
-
+
 void
 createDaughterRegions(MasterProcedureEnv env)
 Create daughter regions
 
 
-
+
 void
 deserializeStateData(http://docs.oracle.com/javase/8/docs/api/java/io/InputStream.html?is-external=true";
 title="class or interface in java.io">InputStream stream)
 Called on store load to allow the user to decode the 
previously serialized
  state.
 
 
-
+
 protected StateMachineProcedure.Flow
 executeFromState(MasterProcedureEnv env,
 
org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.SplitTableRegionState state)
 called to perform a single step of the specified 'state' of 
the procedure
 
 
-
-private long
+
+private static long
 getDaughterRegionIdTimestamp(HRegionInfo hri)
 Calculate daughter regionid to use.
 
 
-
+
 protected 
org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.SplitTableRegionState
 getInitialState()
 Return the initial state object that will be used for the 
first call to executeFromState().
 
 
-
+
 private RegionState
 getParentRegionState(MasterProcedureEnv env)
 Get parent region state
 
 
-
+
+private byte[]
+getSplitRow() 
+
+
 protected 
org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.SplitTableRegionState
 getState(int stateId)
 Convert an ordinal (or state id) to an Enum (or more 
descriptive) state object.
 
 
-
+
 protected int
 getStateId(org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.SplitTableRegionState state)
 Convert the Enum (or more descriptive) state object to an 
ordinal (or state id).
 
 
-
+
 TableName
 getTableName() 
 
-
+
 TableProcedureInterface.TableOperationType
 getTableOperationType()
 Given an operation type we can take decisions about what to 
do with pending operations.
 
 
-
+
 protected boolean
 isRollbackSupported(org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.SplitTableRegionState state)

[40/52] [partial] hbase-site git commit: Published site at 8a6d6aa23944bbfd5047cf0c09fb4d8045735dab.

2016-11-11 Thread stack

http://git-wip-us.apache.org/repos/asf/hbase-site/blob/74ea7fbd/devapidocs/constant-values.html
--
diff --git a/devapidocs/constant-values.html b/devapidocs/constant-values.html
index cdb73b2..f98cfb4 100644
--- a/devapidocs/constant-values.html
+++ b/devapidocs/constant-values.html
@@ -2279,377 +2279,384 @@
 "hbase.replication.conf.dir"
 
 
+
+
+public static final http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
 title="class or interface in java.lang">String
+REPLICATION_META_FAMILY_STR
+"rep_meta"
+
+
 
 
 public static final http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
 title="class or interface in java.lang">String
 REPLICATION_POSITION_FAMILY_STR
 "rep_position"
 
-
+
 
 
 public static final int
 REPLICATION_QOS
 5
 
-
+
 
 
 public static final int
 REPLICATION_SCOPE_GLOBAL
 1
 
-
+
 
 
 public static final int
 REPLICATION_SCOPE_LOCAL
 0
 
-
+
 
 
 public static final int
 REPLICATION_SCOPE_SERIAL
 2
 
-
+
 
 
 public static final long
 REPLICATION_SERIALLY_WAITING_DEFAULT
 1L
 
-
+
 
 
 public static final http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
 title="class or interface in java.lang">String
 REPLICATION_SERIALLY_WAITING_KEY
 "hbase.serial.replication.waitingMs"
 
-
+
 
 
 public static final http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
 title="class or interface in java.lang">String
 REPLICATION_SERVICE_CLASSNAME_DEFAULT
 "org.apache.hadoop.hbase.replication.regionserver.Replication"
 
-
+
 
 
 public static final http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
 title="class or interface in java.lang">String
 REPLICATION_SINK_SERVICE_CLASSNAME
 "hbase.replication.sink.service"
 
-
+
 
 
 public static final int
 REPLICATION_SOURCE_MAXTHREADS_DEFAULT
 10
 
-
+
 
 
 public static final http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
 title="class or interface in java.lang">String
 REPLICATION_SOURCE_MAXTHREADS_KEY
 "hbase.replication.source.maxthreads"
 
-
+
 
 
 public static final http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
 title="class or interface in java.lang">String
 REPLICATION_SOURCE_SERVICE_CLASSNAME
 "hbase.replication.source.service"
 
-
+
 
 
 public static final http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
 title="class or interface in java.lang">String
 RPC_CODEC_CONF_KEY
 "hbase.client.rpc.codec"
 
-
+
 
 
 public static final byte
 RPC_CURRENT_VERSION
 0
 
-
+
 
 
 public static final http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
 title="class or interface in java.lang">String
 SEQNUM_QUALIFIER_STR
 "seqnumDuringOpen"
 
-
+
 
 
 public static final http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
 title="class or interface in java.lang">String
 SERVER_QUALIFIER_STR
 "server"
 
-
+
 
 
 public static final http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
 title="class or interface in java.lang">String
 SERVERNAME_QUALIFIER_STR
 "sn"
 
-
+
 
 
 public static final http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
 title="class or interface in java.lang">String
 SNAPSHOT_DIR_NAME
 ".hbase-snapshot"
 
-
+
 
 
 public static final int
 SOCKET_RETRY_WAIT_MS
 200
 
-
+
 
 
 public static final http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
 title="class or interface in java.lang">String
 SPLIT_LOGDIR_NAME
 "splitWAL"
 
-
+
 
 
 public static final http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
 title="class or interface in java.lang">String
 STARTCODE_QUALIFIER_STR
 "serverstartcode"
 
-
+
 
 
 public static final http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
 title="class or interface in java.lang">String
 STATE_QUALIFIER_STR
 "state"
 
-
+
 
 
 public static final http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
 title="class or interface in java.lang">String
 STATUS_MULTICAST_ADDRESS
 "hbase.status.multicast.address.ip"
 
-
+
 
 
 public static final http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
 title="class or interface in java.lang">String
 STATUS_MULTICAST_BIND_ADDRESS
 "hbase.status.multicast.bind.address.ip"
 
-
+
 
 
 public static final http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
 title="class or interface in java.lang">String
 STATUS_MULTICAST_PORT
 "hbase.status.multicast.address.port"
 
-
+
 
 
 public static final http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
 title="class or interface in java.lang">String
 STATUS_PUBLISHED
 "hbase.status

[34/52] [partial] hbase-site git commit: Published site at 8a6d6aa23944bbfd5047cf0c09fb4d8045735dab.

2016-11-11 Thread stack

http://git-wip-us.apache.org/repos/asf/hbase-site/blob/74ea7fbd/devapidocs/org/apache/hadoop/hbase/class-use/Cell.html
--
diff --git a/devapidocs/org/apache/hadoop/hbase/class-use/Cell.html 
b/devapidocs/org/apache/hadoop/hbase/class-use/Cell.html
index 7e493ed..b5e5988 100644
--- a/devapidocs/org/apache/hadoop/hbase/class-use/Cell.html
+++ b/devapidocs/org/apache/hadoop/hbase/class-use/Cell.html
@@ -1655,6 +1655,10 @@ service.
 Result.cells 
 
 
+private Cell
+AllowPartialScanResultCache.lastCell 
+
+
 protected Cell
 ClientScanner.lastCellLoadedToCache
 The last cell from a not full Row which is added to 
cache

http://git-wip-us.apache.org/repos/asf/hbase-site/blob/74ea7fbd/devapidocs/org/apache/hadoop/hbase/class-use/HDFSBlocksDistribution.html
--
diff --git 
a/devapidocs/org/apache/hadoop/hbase/class-use/HDFSBlocksDistribution.html 
b/devapidocs/org/apache/hadoop/hbase/class-use/HDFSBlocksDistribution.html
index 7083680..bd2cf52 100644
--- a/devapidocs/org/apache/hadoop/hbase/class-use/HDFSBlocksDistribution.html
+++ b/devapidocs/org/apache/hadoop/hbase/class-use/HDFSBlocksDistribution.html
@@ -183,10 +183,6 @@ Input/OutputFormats, a table indexing MapReduce job, and 
utility methods.
 private com.google.common.cache.CacheLoader
 RegionLocationFinder.loader 
 
-
-(package private) http://docs.oracle.com/javase/8/docs/api/java/util/ArrayList.html?is-external=true";
 title="class or interface in 
java.util">ArrayList>
-BaseLoadBalancer.Cluster.regionLocationFutures 
-
 
 
 
@@ -217,7 +213,7 @@ Input/OutputFormats, a table indexing MapReduce job, and 
utility methods.
 
 
 
-com.google.common.util.concurrent.ListenableFuture
+private 
com.google.common.util.concurrent.ListenableFuture
 RegionLocationFinder.asyncGetBlockDistribution(HRegionInfo hri) 
 
 
@@ -226,18 +222,9 @@ Input/OutputFormats, a table indexing MapReduce job, and 
utility methods.
 Create a cache for region to list of servers
 
 
-
-
-
-Methods in org.apache.hadoop.hbase.master.balancer
 with parameters of type HDFSBlocksDistribution 
-
-Modifier and Type
-Method and Description
-
-
 
-protected http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true";
 title="class or interface in java.util">List
-RegionLocationFinder.getTopBlockLocations(HDFSBlocksDistribution blocksDistribution) 
+(package private) 
com.google.common.cache.LoadingCache
+RegionLocationFinder.getCache() 
 
 
 

http://git-wip-us.apache.org/repos/asf/hbase-site/blob/74ea7fbd/devapidocs/org/apache/hadoop/hbase/class-use/HRegionInfo.html
--
diff --git a/devapidocs/org/apache/hadoop/hbase/class-use/HRegionInfo.html 
b/devapidocs/org/apache/hadoop/hbase/class-use/HRegionInfo.html
index 6ec1c4c..4f92aaa 100644
--- a/devapidocs/org/apache/hadoop/hbase/class-use/HRegionInfo.html
+++ b/devapidocs/org/apache/hadoop/hbase/class-use/HRegionInfo.html
@@ -3182,33 +3182,37 @@ Input/OutputFormats, a table indexing MapReduce job, 
and utility methods.
 FavoredNodesPlan.getAssignmentMap() 
 
 
+(package private) 
com.google.common.cache.LoadingCache
+RegionLocationFinder.getCache() 
+
+
 (package private) http://docs.oracle.com/javase/8/docs/api/java/util/Map.html?is-external=true";
 title="class or interface in java.util">MapList>
 ClusterLoadState.getClusterState() 
 
-
+
 protected http://docs.oracle.com/javase/8/docs/api/java/util/Map.html?is-external=true";
 title="class or interface in java.util">MapList>
 BaseLoadBalancer.getRegionAssignmentsByServer(http://docs.oracle.com/javase/8/docs/api/java/util/Collection.html?is-external=true";
 title="class or interface in java.util">Collection regions) 
 
-
+
 (package private) http://docs.oracle.com/javase/8/docs/api/java/util/NavigableMap.html?is-external=true";
 title="class or interface in java.util">NavigableMapList>
 ClusterLoadState.getServersByLoad() 
 
-
+
 private http://docs.oracle.com/javase/8/docs/api/java/util/Map.html?is-external=true";
 title="class or interface in java.util">MapSet

[19/52] [partial] hbase-site git commit: Published site at 8a6d6aa23944bbfd5047cf0c09fb4d8045735dab.

2016-11-11 Thread stack

http://git-wip-us.apache.org/repos/asf/hbase-site/blob/74ea7fbd/devapidocs/org/apache/hadoop/hbase/coprocessor/BaseRegionObserver.html
--
diff --git 
a/devapidocs/org/apache/hadoop/hbase/coprocessor/BaseRegionObserver.html 
b/devapidocs/org/apache/hadoop/hbase/coprocessor/BaseRegionObserver.html
index 0fe0b60..b8e34be 100644
--- a/devapidocs/org/apache/hadoop/hbase/coprocessor/BaseRegionObserver.html
+++ b/devapidocs/org/apache/hadoop/hbase/coprocessor/BaseRegionObserver.html
@@ -18,7 +18,7 @@
 catch(err) {
 }
 //-->
-var methods = 
{"i0":10,"i1":10,"i2":10,"i3":10,"i4":10,"i5":10,"i6":10,"i7":10,"i8":10,"i9":10,"i10":10,"i11":10,"i12":10,"i13":10,"i14":10,"i15":10,"i16":10,"i17":10,"i18":10,"i19":10,"i20":10,"i21":10,"i22":10,"i23":10,"i24":10,"i25":10,"i26":10,"i27":10,"i28":42,"i29":10,"i30":10,"i31":10,"i32":10,"i33":10,"i34":10,"i35":10,"i36":10,"i37":10,"i38":10,"i39":10,"i40":10,"i41":10,"i42":10,"i43":10,"i44":10,"i45":10,"i46":10,"i47":10,"i48":10,"i49":10,"i50":10,"i51":10,"i52":10,"i53":10,"i54":10,"i55":10,"i56":10,"i57":10,"i58":10,"i59":10,"i60":10,"i61":10,"i62":10,"i63":10,"i64":10,"i65":10,"i66":10,"i67":10,"i68":10,"i69":10,"i70":10,"i71":10,"i72":10,"i73":10,"i74":10,"i75":10,"i76":10,"i77":10,"i78":10,"i79":10};
+var methods = 
{"i0":10,"i1":10,"i2":10,"i3":10,"i4":10,"i5":10,"i6":10,"i7":10,"i8":10,"i9":10,"i10":10,"i11":10,"i12":10,"i13":10,"i14":10,"i15":10,"i16":10,"i17":10,"i18":10,"i19":10,"i20":10,"i21":10,"i22":10,"i23":10,"i24":10,"i25":10,"i26":10,"i27":10,"i28":42,"i29":10,"i30":10,"i31":10,"i32":10,"i33":10,"i34":10,"i35":10,"i36":10,"i37":10,"i38":10,"i39":10,"i40":10,"i41":10,"i42":10,"i43":10,"i44":10,"i45":10,"i46":10,"i47":10,"i48":10,"i49":10,"i50":10,"i51":10,"i52":10,"i53":10,"i54":10,"i55":10,"i56":10,"i57":10,"i58":10,"i59":10,"i60":10,"i61":10,"i62":10,"i63":10,"i64":10,"i65":10,"i66":10,"i67":10,"i68":10,"i69":10,"i70":10,"i71":10,"i72":10,"i73":10,"i74":10,"i75":10,"i76":10,"i77":10,"i78":10,"i79":10,"i80":10,"i81":10};
 var tabs = {65535:["t0","All Methods"],2:["t2","Instance 
Methods"],8:["t4","Concrete Methods"],32:["t6","Deprecated Methods"]};
 var altColor = "altColor";
 var rowColor = "rowColor";
@@ -651,6 +651,20 @@ implements 
+InternalScanner
+preCompactScannerOpen(ObserverContext c,
+ Store store,
+ http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true";
 title="class or interface in java.util">List scanners,
+ ScanType scanType,
+ long earliestPutTs,
+ InternalScanner s,
+ CompactionRequest request,
+ long readPoint)
+Called prior to writing the StoreFiles selected for 
compaction into a new
+ StoreFile and prior to creating the scanner used to read the 
input files.
+
+
+
 void
 preCompactSelection(ObserverContext c,
Store store,
@@ -659,7 +673,7 @@ implements 
+
 void
 preCompactSelection(ObserverContext c,
Store store,
@@ -669,7 +683,7 @@ implements 
+
 void
 preDelete(ObserverContext e,
  Delete delete,
@@ -678,7 +692,7 @@ implements Called before the client deletes a value.
 
 
-
+
 boolean
 preExists(ObserverContext e,
  Get get,
@@ -686,13 +700,13 @@ implements Called before the client tests for existence using a 
Get.
 
 
-
+
 void
 preFlush(ObserverContext e)
 Called before the memstore is flushed to disk.
 
 
-
+
 InternalScanner
 preFlush(ObserverContext e,
 Store store,
@@ -700,7 +714,7 @@ implements Called before a Store's memstore is flushed to disk.
 
 
-
+
 InternalScanner
 preFlushScannerOpen(ObserverContext c,
Store store,
@@ -710,7 +724,18 @@ implements 
+
+InternalScanner
+preFlushScannerOpen(ObserverContext c,
+   Store store,
+   KeyValueScanner memstoreScanner,
+   InternalScanner s,
+   long readPoint)
+Called before a memstore is flushed to disk and prior to 
creating the scanner to read from
+ the memstore.
+
+
+
 void
 preGetOp(ObserverContext e,
 Get get,
@@ -718,21 +743,21 @@ implements Called before the client performs a Get
 
 
-
+
 Result
 preIncrement(ObserverContext e,
 Increment increment)
 Called before Increment.
 
 
-
+
 Result
 preIncrementAfterRowLock(ObserverContext e,
 Increment increment)
 Called before Increment but after acquiring rowlock.
 
 
-
+
 long
 preIncrementColumnValue(ObserverContext

[17/52] [partial] hbase-site git commit: Published site at 8a6d6aa23944bbfd5047cf0c09fb4d8045735dab.

2016-11-11 Thread stack

http://git-wip-us.apache.org/repos/asf/hbase-site/blob/74ea7fbd/devapidocs/org/apache/hadoop/hbase/coprocessor/RegionObserver.html
--
diff --git a/devapidocs/org/apache/hadoop/hbase/coprocessor/RegionObserver.html 
b/devapidocs/org/apache/hadoop/hbase/coprocessor/RegionObserver.html
index c03fd42..900a3d7 100644
--- a/devapidocs/org/apache/hadoop/hbase/coprocessor/RegionObserver.html
+++ b/devapidocs/org/apache/hadoop/hbase/coprocessor/RegionObserver.html
@@ -18,7 +18,7 @@
 catch(err) {
 }
 //-->
-var methods = 
{"i0":6,"i1":6,"i2":6,"i3":6,"i4":6,"i5":6,"i6":6,"i7":6,"i8":38,"i9":6,"i10":38,"i11":6,"i12":6,"i13":6,"i14":6,"i15":38,"i16":6,"i17":6,"i18":6,"i19":38,"i20":6,"i21":6,"i22":6,"i23":6,"i24":6,"i25":6,"i26":38,"i27":6,"i28":38,"i29":6,"i30":6,"i31":6,"i32":38,"i33":6,"i34":6,"i35":6,"i36":38,"i37":6,"i38":6,"i39":6,"i40":6,"i41":6,"i42":6,"i43":6,"i44":6,"i45":6,"i46":38,"i47":6,"i48":38,"i49":6,"i50":38,"i51":6,"i52":6,"i53":6,"i54":38,"i55":6,"i56":6,"i57":6,"i58":6,"i59":6,"i60":38,"i61":6,"i62":6,"i63":6,"i64":6,"i65":38,"i66":6,"i67":6,"i68":6,"i69":38,"i70":38,"i71":38,"i72":38,"i73":6,"i74":38,"i75":6,"i76":6,"i77":38};
+var methods = 
{"i0":6,"i1":6,"i2":6,"i3":6,"i4":6,"i5":6,"i6":6,"i7":6,"i8":38,"i9":6,"i10":38,"i11":6,"i12":6,"i13":6,"i14":6,"i15":38,"i16":6,"i17":6,"i18":6,"i19":38,"i20":6,"i21":6,"i22":6,"i23":6,"i24":6,"i25":6,"i26":38,"i27":6,"i28":38,"i29":6,"i30":6,"i31":6,"i32":38,"i33":6,"i34":6,"i35":6,"i36":38,"i37":6,"i38":6,"i39":6,"i40":6,"i41":6,"i42":6,"i43":6,"i44":6,"i45":6,"i46":38,"i47":6,"i48":38,"i49":38,"i50":6,"i51":38,"i52":6,"i53":6,"i54":6,"i55":38,"i56":6,"i57":38,"i58":6,"i59":6,"i60":6,"i61":6,"i62":38,"i63":6,"i64":6,"i65":6,"i66":6,"i67":38,"i68":6,"i69":6,"i70":6,"i71":38,"i72":38,"i73":38,"i74":38,"i75":6,"i76":38,"i77":6,"i78":6,"i79":38};
 var tabs = {65535:["t0","All Methods"],2:["t2","Instance 
Methods"],4:["t3","Abstract Methods"],32:["t6","Deprecated Methods"]};
 var altColor = "altColor";
 var rowColor = "rowColor";
@@ -633,8 +633,8 @@ extends InternalScanner s)
 Deprecated. 
 Use
- preCompactScannerOpen(ObserverContext,
 Store, List, ScanType, long,
- InternalScanner, CompactionRequest) 
instead.
+ preCompactScannerOpen(ObserverContext,
 Store, List, ScanType, long,
+ InternalScanner, CompactionRequest, long) 
instead.
 
 
 
@@ -647,11 +647,27 @@ extends InternalScanner s,
  CompactionRequest request)
+Deprecated. 
+Use preCompactScannerOpen(ObserverContext,
 Store, List, ScanType, long,
+ InternalScanner, CompactionRequest, long) 
instead.
+
+
+
+
+InternalScanner
+preCompactScannerOpen(ObserverContext c,
+ Store store,
+ http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true";
 title="class or interface in java.util">List scanners,
+ ScanType scanType,
+ long earliestPutTs,
+ InternalScanner s,
+ CompactionRequest request,
+ long readPoint)
 Called prior to writing the StoreFiles selected for 
compaction into a new
  StoreFile and prior to creating the scanner used to read the 
input files.
 
 
-
+
 void
 preCompactSelection(ObserverContext c,
Store store,
@@ -662,7 +678,7 @@ extends 
 
 
-
+
 void
 preCompactSelection(ObserverContext c,
Store store,
@@ -672,7 +688,7 @@ extends 
 
 
-
+
 void
 preDelete(ObserverContext c,
  Delete delete,
@@ -681,7 +697,7 @@ extends Called before the client deletes a value.
 
 
-
+
 boolean
 preExists(ObserverContext c,
  Get get,
@@ -689,7 +705,7 @@ extends Called before the client tests for existence using a 
Get.
 
 
-
+
 void
 preFlush(ObserverContext c)
 Deprecated. 
@@ -697,7 +713,7 @@ extends 
 
 
-
+
 InternalScanner
 preFlush(ObserverContext c,
 Store store,
@@ -705,17 +721,30 @@ extends Called before a Store's memstore is flushed to disk.
 
 
-
+
 InternalScanner
 preFlushScannerOpen(ObserverContext c,
Store store,
KeyValueScanner memstoreScanner,
InternalScanner s)
+Deprecated. 
+Use preFlushScannerOpen(ObserverContext,
 Store, KeyValueScanner,
+ InternalScanner, long)
+
+
+
+
+InternalScanner
+preFlushScannerOpen(ObserverContext c,
+   Store store,
+   KeyValueScanner memstoreScanner,
+   InternalScanner s,
+   long readPoint)
 Called before a memstore is flushed to disk and prior to 
creating the

[52/52] hbase-site git commit: Empty commit

2016-11-11 Thread stack

Empty commit


Project: http://git-wip-us.apache.org/repos/asf/hbase-site/repo
Commit: http://git-wip-us.apache.org/repos/asf/hbase-site/commit/ca662680
Tree: http://git-wip-us.apache.org/repos/asf/hbase-site/tree/ca662680
Diff: http://git-wip-us.apache.org/repos/asf/hbase-site/diff/ca662680

Branch: refs/heads/asf-site
Commit: ca662680db22790e4a75906c3d1220d06b415092
Parents: 74ea7fb
Author: Michael Stack 
Authored: Fri Nov 11 10:45:32 2016 -0800
Committer: Michael Stack 
Committed: Fri Nov 11 10:45:32 2016 -0800

--

--

[26/52] [partial] hbase-site git commit: Published site at 8a6d6aa23944bbfd5047cf0c09fb4d8045735dab.

2016-11-11 Thread stack

http://git-wip-us.apache.org/repos/asf/hbase-site/blob/74ea7fbd/devapidocs/org/apache/hadoop/hbase/client/ClientScanner.html
--
diff --git a/devapidocs/org/apache/hadoop/hbase/client/ClientScanner.html 
b/devapidocs/org/apache/hadoop/hbase/client/ClientScanner.html
index a84d200..d580178 100644
--- a/devapidocs/org/apache/hadoop/hbase/client/ClientScanner.html
+++ b/devapidocs/org/apache/hadoop/hbase/client/ClientScanner.html
@@ -520,7 +520,7 @@ extends 
 
 LOG
-private static final org.apache.commons.logging.Log LOG
+private static final org.apache.commons.logging.Log LOG
 
 
 
@@ -529,7 +529,7 @@ extends 
 
 scan
-protected Scan scan
+protected Scan scan
 
 
 
@@ -538,7 +538,7 @@ extends 
 
 closed
-protected boolean closed
+protected boolean closed
 
 
 
@@ -547,7 +547,7 @@ extends 
 
 currentRegion
-protected HRegionInfo currentRegion
+protected HRegionInfo currentRegion
 
 
 
@@ -556,7 +556,7 @@ extends 
 
 callable
-protected ScannerCallableWithReplicas callable
+protected ScannerCallableWithReplicas callable
 
 
 
@@ -565,7 +565,7 @@ extends 
 
 cache
-protected http://docs.oracle.com/javase/8/docs/api/java/util/Queue.html?is-external=true";
 title="class or interface in java.util">Queue cache
+protected http://docs.oracle.com/javase/8/docs/api/java/util/Queue.html?is-external=true";
 title="class or interface in java.util">Queue cache
 
 
 
@@ -574,7 +574,7 @@ extends 
 
 partialResults
-protected final http://docs.oracle.com/javase/8/docs/api/java/util/LinkedList.html?is-external=true";
 title="class or interface in java.util">LinkedList partialResults
+protected final http://docs.oracle.com/javase/8/docs/api/java/util/LinkedList.html?is-external=true";
 title="class or interface in java.util">LinkedList partialResults
 A list of partial results that have been returned from the 
server. This list should only
  contain results if this scanner does not have enough partial results to form 
the complete
  result.
@@ -586,7 +586,7 @@ extends 
 
 partialResultsRow
-protected byte[] partialResultsRow
+protected byte[] partialResultsRow
 The row for which we are accumulating partial Results (i.e. 
the row of the Results stored
  inside partialResults). Changes to partialResultsRow and partialResults are 
kept in sync via
  the methods addToPartialResults(Result)
 and clearPartialResults()
@@ -598,7 +598,7 @@ extends 
 
 lastCellLoadedToCache
-protected Cell lastCellLoadedToCache
+protected Cell lastCellLoadedToCache
 The last cell from a not full Row which is added to 
cache
 
 
@@ -608,7 +608,7 @@ extends 
 
 caching
-protected final int caching
+protected final int caching
 
 
 
@@ -617,7 +617,7 @@ extends 
 
 lastNext
-protected long lastNext
+protected long lastNext
 
 
 
@@ -626,7 +626,7 @@ extends 
 
 lastResult
-protected Result lastResult
+protected Result lastResult
 
 
 
@@ -635,7 +635,7 @@ extends 
 
 maxScannerResultSize
-protected final long maxScannerResultSize
+protected final long maxScannerResultSize
 
 
 
@@ -644,7 +644,7 @@ extends 
 
 connection
-private final ClusterConnection connection
+private final ClusterConnection connection
 
 
 
@@ -653,7 +653,7 @@ extends 
 
 tableName
-private final TableName tableName
+private final TableName tableName
 
 
 
@@ -662,7 +662,7 @@ extends 
 
 scannerTimeout
-protected final int scannerTimeout
+protected final int scannerTimeout
 
 
 
@@ -671,7 +671,7 @@ extends 
 
 scanMetricsPublished
-protected boolean scanMetricsPublished
+protected boolean scanMetricsPublished
 
 
 
@@ -680,7 +680,7 @@ extends 
 
 caller
-protected RpcRetryingCaller caller
+protected RpcRetryingCaller caller
 
 
 
@@ -689,7 +689,7 @@ extends 
 
 rpcControllerFactory
-protected RpcControllerFactory rpcControllerFactory
+protected RpcControllerFactory rpcControllerFactory
 
 
 
@@ -698,7 +698,7 @@ extends 
 
 conf
-protected org.apache.hadoop.conf.Configuration conf
+protected org.apache.hadoop.conf.Configuration conf
 
 
 
@@ -707,7 +707,7 @@ extends 
 
 primaryOperationTimeout
-protected final int primaryOperationTimeout
+protected final int primaryOperationTimeout
 
 
 
@@ -716,7 +716,7 @@ extends 
 
 retries
-private int retries
+private int retries
 
 
 
@@ -725,7 +725,7 @@ extends 
 
 pool
-protected final http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/ExecutorService.html?is-external=true";
 title="class or interface in java.util.concurrent">ExecutorService pool
+protected final http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/ExecutorService.html?is-external=true";
 title="class or interface in java.util.concurrent">ExecutorService pool
 
 
 
@@ -742,7 +742,7 @@ extends 
 
 ClientScanner
-public ClientScanner(org.apache.hadoop.conf.Configuration conf,
+public ClientScanner(org.apache.hadoop.conf.Configuration conf,
  Scan scan,
  TableName tableName,
  ClusterCon

[28/52] [partial] hbase-site git commit: Published site at 8a6d6aa23944bbfd5047cf0c09fb4d8045735dab.

2016-11-11 Thread stack

http://git-wip-us.apache.org/repos/asf/hbase-site/blob/74ea7fbd/devapidocs/org/apache/hadoop/hbase/client/AsyncTable.html
--
diff --git a/devapidocs/org/apache/hadoop/hbase/client/AsyncTable.html 
b/devapidocs/org/apache/hadoop/hbase/client/AsyncTable.html
index 8ffc7b3..ad7e7db 100644
--- a/devapidocs/org/apache/hadoop/hbase/client/AsyncTable.html
+++ b/devapidocs/org/apache/hadoop/hbase/client/AsyncTable.html
@@ -18,7 +18,7 @@
 catch(err) {
 }
 //-->
-var methods = 
{"i0":6,"i1":18,"i2":6,"i3":18,"i4":6,"i5":18,"i6":6,"i7":6,"i8":18,"i9":6,"i10":6,"i11":6,"i12":6,"i13":6,"i14":6,"i15":6,"i16":18,"i17":18,"i18":6,"i19":6,"i20":6,"i21":6,"i22":6,"i23":18,"i24":6};
+var methods = 
{"i0":6,"i1":18,"i2":6,"i3":18,"i4":6,"i5":18,"i6":6,"i7":6,"i8":18,"i9":6,"i10":6,"i11":6,"i12":6,"i13":6,"i14":6,"i15":6,"i16":6,"i17":18,"i18":18,"i19":6,"i20":6,"i21":6,"i22":6,"i23":6,"i24":6,"i25":6,"i26":18,"i27":6};
 var tabs = {65535:["t0","All Methods"],2:["t2","Instance 
Methods"],4:["t3","Abstract Methods"],16:["t5","Default Methods"]};
 var altColor = "altColor";
 var rowColor = "rowColor";
@@ -246,17 +246,23 @@ public interface 
 long
+getScanTimeout(http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/TimeUnit.html?is-external=true";
 title="class or interface in 
java.util.concurrent">TimeUnit unit)
+Get the timeout of a single operation in a scan.
+
+
+
+long
 getWriteRpcTimeout(http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/TimeUnit.html?is-external=true";
 title="class or interface in 
java.util.concurrent">TimeUnit unit)
 Get timeout of each rpc write request in this Table 
instance.
 
 
-
+
 http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/CompletableFuture.html?is-external=true";
 title="class or interface in java.util.concurrent">CompletableFuture
 increment(Increment increment)
 Increments one or more columns within a single row.
 
 
-
+
 default http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/CompletableFuture.html?is-external=true";
 title="class or interface in java.util.concurrent">CompletableFutureLong>
 incrementColumnValue(byte[] row,
 byte[] family,
@@ -265,7 +271,7 @@ public interface See incrementColumnValue(byte[],
 byte[], byte[], long, Durability)
 
 
-
+
 default http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/CompletableFuture.html?is-external=true";
 title="class or interface in java.util.concurrent">CompletableFutureLong>
 incrementColumnValue(byte[] row,
 byte[] family,
@@ -275,19 +281,26 @@ public interface Atomically increments a column value.
 
 
-
+
 http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/CompletableFuture.html?is-external=true";
 title="class or interface in java.util.concurrent">CompletableFutureVoid>
 mutateRow(RowMutations mutation)
 Performs multiple mutations atomically on a single 
row.
 
 
-
+
 http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/CompletableFuture.html?is-external=true";
 title="class or interface in java.util.concurrent">CompletableFutureVoid>
 put(Put put)
 Puts some data to the table.
 
 
-
+
+void
+scan(Scan scan,
+ScanResultConsumer consumer)
+The basic scan API uses the observer pattern.
+
+
+
 void
 setOperationTimeout(long timeout,
http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/TimeUnit.html?is-external=true";
 title="class or interface in 
java.util.concurrent">TimeUnit unit)
@@ -295,7 +308,7 @@ public interface 
+
 void
 setReadRpcTimeout(long timeout,
  http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/TimeUnit.html?is-external=true";
 title="class or interface in 
java.util.concurrent">TimeUnit unit)
@@ -303,7 +316,14 @@ public interface 
+
+void
+setScanTimeout(long timeout,
+  http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/TimeUnit.html?is-external=true";
 title="class or interface in 
java.util.concurrent">TimeUnit unit)
+Set timeout of a single operation in a scan, such as 
openScanner and next.
+
+
+
 void
 setWriteRpcTimeout(long timeout,
   http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/TimeUnit.html?is-external=true";
 title="class or interface in 
java.util.concurrent">TimeUnit unit)
@@ -311,13 +331,13 @@ public interface 
+
 default http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/CompletableFuture.html?is-ex

[15/52] [partial] hbase-site git commit: Published site at 8a6d6aa23944bbfd5047cf0c09fb4d8045735dab.

2016-11-11 Thread stack

http://git-wip-us.apache.org/repos/asf/hbase-site/blob/74ea7fbd/devapidocs/org/apache/hadoop/hbase/io/hfile/HFileBlockIndex.BlockIndexChunk.html
--
diff --git 
a/devapidocs/org/apache/hadoop/hbase/io/hfile/HFileBlockIndex.BlockIndexChunk.html
 
b/devapidocs/org/apache/hadoop/hbase/io/hfile/HFileBlockIndex.BlockIndexChunk.html
index 6a2ff13..133801a 100644
--- 
a/devapidocs/org/apache/hadoop/hbase/io/hfile/HFileBlockIndex.BlockIndexChunk.html
+++ 
b/devapidocs/org/apache/hadoop/hbase/io/hfile/HFileBlockIndex.BlockIndexChunk.html
@@ -113,7 +113,7 @@ var activeTableTab = "activeTableTab";
 
 
 
-static class HFileBlockIndex.BlockIndexChunk
+static class HFileBlockIndex.BlockIndexChunk
 extends http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true";
 title="class or interface in java.lang">Object
 A single chunk of the block index in the process of 
writing. The data in
  this chunk can become a leaf-level, intermediate-level, or root index
@@ -318,7 +318,7 @@ extends http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?
 
 
 blockKeys
-private final http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true";
 title="class or interface in java.util">List blockKeys
+private final http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true";
 title="class or interface in java.util">List blockKeys
 First keys of the key range corresponding to each index 
entry.
 
 
@@ -328,7 +328,7 @@ extends http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?
 
 
 blockOffsets
-private final http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true";
 title="class or interface in java.util">ListLong> blockOffsets
+private final http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true";
 title="class or interface in java.util">ListLong> blockOffsets
 Block offset in backing stream.
 
 
@@ -338,7 +338,7 @@ extends http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?
 
 
 onDiskDataSizes
-private final http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true";
 title="class or interface in java.util">ListInteger> onDiskDataSizes
+private final http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true";
 title="class or interface in java.util">ListInteger> onDiskDataSizes
 On-disk data sizes of lower-level data or index 
blocks.
 
 
@@ -348,7 +348,7 @@ extends http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?
 
 
 numSubEntriesAt
-private final http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true";
 title="class or interface in java.util">ListLong> numSubEntriesAt
+private final http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true";
 title="class or interface in java.util">ListLong> numSubEntriesAt
 The cumulative number of sub-entries, i.e. entries on 
deeper-level block
  index entries. numSubEntriesAt[i] is the number of sub-entries in the
  blocks corresponding to this chunk's entries #0 through #i inclusively.
@@ -360,7 +360,7 @@ extends http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?
 
 
 curTotalNonRootEntrySize
-private int curTotalNonRootEntrySize
+private int curTotalNonRootEntrySize
 The offset of the next entry to be added, relative to the 
end of the
  "secondary index" in the "non-root" format representation of this index
  chunk. This is the next value to be added to the secondary index.
@@ -372,7 +372,7 @@ extends http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?
 
 
 curTotalRootSize
-private int curTotalRootSize
+private int curTotalRootSize
 The accumulated size of this chunk if stored in the root 
index format.
 
 
@@ -382,7 +382,7 @@ extends http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?
 
 
 secondaryIndexOffsetMarks
-private final http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true";
 title="class or interface in java.util">ListInteger> secondaryIndexOffsetMarks
+private

[35/52] [partial] hbase-site git commit: Published site at 8a6d6aa23944bbfd5047cf0c09fb4d8045735dab.

2016-11-11 Thread stack

http://git-wip-us.apache.org/repos/asf/hbase-site/blob/74ea7fbd/devapidocs/org/apache/hadoop/hbase/MetaTableAccessor.html
--
diff --git a/devapidocs/org/apache/hadoop/hbase/MetaTableAccessor.html 
b/devapidocs/org/apache/hadoop/hbase/MetaTableAccessor.html
index 8bdb730..8ef28c6 100644
--- a/devapidocs/org/apache/hadoop/hbase/MetaTableAccessor.html
+++ b/devapidocs/org/apache/hadoop/hbase/MetaTableAccessor.html
@@ -18,7 +18,7 @@
 catch(err) {
 }
 //-->
-var methods = 
{"i0":9,"i1":9,"i2":9,"i3":9,"i4":9,"i5":9,"i6":9,"i7":9,"i8":9,"i9":9,"i10":9,"i11":41,"i12":9,"i13":9,"i14":9,"i15":9,"i16":9,"i17":9,"i18":9,"i19":9,"i20":9,"i21":9,"i22":9,"i23":9,"i24":9,"i25":9,"i26":9,"i27":9,"i28":9,"i29":9,"i30":9,"i31":9,"i32":9,"i33":9,"i34":9,"i35":9,"i36":9,"i37":9,"i38":41,"i39":9,"i40":9,"i41":9,"i42":9,"i43":9,"i44":9,"i45":9,"i46":9,"i47":9,"i48":9,"i49":9,"i50":9,"i51":41,"i52":9,"i53":9,"i54":9,"i55":9,"i56":9,"i57":9,"i58":9,"i59":9,"i60":9,"i61":9,"i62":9,"i63":9,"i64":9,"i65":9,"i66":9,"i67":9,"i68":9,"i69":9,"i70":9,"i71":9,"i72":9,"i73":9,"i74":9,"i75":9,"i76":9,"i77":9,"i78":9,"i79":9,"i80":9,"i81":9,"i82":9,"i83":9,"i84":9,"i85":9,"i86":9,"i87":9,"i88":9,"i89":9,"i90":9,"i91":9,"i92":9,"i93":9,"i94":9,"i95":9,"i96":9,"i97":9,"i98":9,"i99":9,"i100":9,"i101":9,"i102":9,"i103":9,"i104":9};
+var methods = 
{"i0":9,"i1":9,"i2":9,"i3":9,"i4":9,"i5":9,"i6":9,"i7":9,"i8":9,"i9":9,"i10":9,"i11":41,"i12":9,"i13":9,"i14":9,"i15":9,"i16":9,"i17":9,"i18":9,"i19":9,"i20":9,"i21":9,"i22":9,"i23":9,"i24":9,"i25":9,"i26":9,"i27":9,"i28":9,"i29":9,"i30":9,"i31":9,"i32":9,"i33":9,"i34":9,"i35":9,"i36":9,"i37":9,"i38":41,"i39":9,"i40":9,"i41":9,"i42":9,"i43":9,"i44":9,"i45":9,"i46":9,"i47":9,"i48":9,"i49":9,"i50":9,"i51":41,"i52":9,"i53":9,"i54":9,"i55":9,"i56":9,"i57":9,"i58":9,"i59":9,"i60":9,"i61":9,"i62":9,"i63":9,"i64":9,"i65":9,"i66":9,"i67":9,"i68":9,"i69":9,"i70":9,"i71":9,"i72":9,"i73":9,"i74":9,"i75":9,"i76":9,"i77":9,"i78":9,"i79":9,"i80":9,"i81":9,"i82":9,"i83":9,"i84":9,"i85":9,"i86":9,"i87":9,"i88":9,"i89":9,"i90":9,"i91":9,"i92":9,"i93":9,"i94":9,"i95":9,"i96":9,"i97":9,"i98":9,"i99":9,"i100":9,"i101":9,"i102":9,"i103":9,"i104":9,"i105":9,"i106":9};
 var tabs = {65535:["t0","All Methods"],1:["t1","Static 
Methods"],8:["t4","Concrete Methods"],32:["t6","Deprecated Methods"]};
 var altColor = "altColor";
 var rowColor = "rowColor";
@@ -194,7 +194,7 @@ extends http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?
 
 
 private static byte[]
-daughterNamePosCq 
+daughterNameCq 
 
 
 private static 
org.apache.commons.logging.Log
@@ -215,18 +215,18 @@ extends http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?
 METALOG 
 
 
+private static byte[]
+parentNameCq 
+
+
 private static http://docs.oracle.com/javase/8/docs/api/java/util/regex/Pattern.html?is-external=true";
 title="class or interface in java.util.regex">Pattern
 SERVER_COLUMN_PATTERN
 A regex for parsing server columns from meta.
 
 
-
-private static http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
 title="class or interface in java.lang">String
-tableNamePeer 
-
 
 private static byte[]
-tableNamePosCq 
+tableNameCq 
 
 
 
@@ -642,55 +642,62 @@ extends http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?
 
 
 static http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
 title="class or interface in java.lang">String
+getSerialReplicationParentRegion(Connection connection,
+byte[] encodedName)
+Get parent region(s) for a region, only used in serial 
replication.
+
+
+
+static http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
 title="class or interface in java.lang">String
 getSerialReplicationTableName(Connection connection,
  byte[] encodedName)
 Get the table name for a region, only used in serial 
replication.
 
 
-
+
 static byte[]
 getServerColumn(int replicaId)
 Returns the column qualifier for server column for 
replicaId
 
 
-
+
 static ServerName
 getServerName(Result r,
  int replicaId)
 Returns a ServerName from catalog table Result.
 
 
-
+
 static http://docs.oracle.com/javase/8/docs/api/java/util/NavigableMap.html?is-external=true";
 title="class or interface in java.util">NavigableMap
 getServerUserRegions(Connection connection,
 ServerName serverName) 
 
-
+
 static byte[]
 getStartCodeColumn(int replicaId)
 Returns the column qualifier for server start code column 
for replicaId
 
 
-
+
 protected static byte[]
 getStateColumn()
 Returns the column qualifier for serialized table 
state
 
 
-
+
 protected static byte[]
 getTableFamily()
 Returns the column family used for table columns.
 
 
-
+
 static http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true";
 title="class or interface in java.util">List

[13/52] [partial] hbase-site git commit: Published site at 8a6d6aa23944bbfd5047cf0c09fb4d8045735dab.

2016-11-11 Thread stack

http://git-wip-us.apache.org/repos/asf/hbase-site/blob/74ea7fbd/devapidocs/org/apache/hadoop/hbase/master/HMaster.html
--
diff --git a/devapidocs/org/apache/hadoop/hbase/master/HMaster.html 
b/devapidocs/org/apache/hadoop/hbase/master/HMaster.html
index 7c56a68..c040712 100644
--- a/devapidocs/org/apache/hadoop/hbase/master/HMaster.html
+++ b/devapidocs/org/apache/hadoop/hbase/master/HMaster.html
@@ -1189,7 +1189,7 @@ implements HRegionServer
-abort,
 addToMovedRegions,
 addToOnlineRegions,
 checkFileSystem,
 cleanMovedRegions,
 closeAllRegions,
 closeAndOfflineRegionForSp
 lit, closeRegion,
 constructRegionServer,
 convertThrowableToIOE,
 createClusterConnection,
 createRegionLoad,
 createRegionServerStatusStub, href="../../../../../org/apache/hadoop/hbase/regionserver/HRegionServer.html#createRegionServerStatusStub-boolean-">createRegionServerStatusStub,
 > href="../../../../../org/apache/hadoop/hbase/regionserver/HRegionServer.html#ensureMetaWALRoller--">ensureMetaWALRoller,
 > href="../../../../../org/apache/hadoop/hbase/regionserver/HRegionServer.html#execRegionServerService-org.apache.hadoop.hbase.shaded.com.google.protobuf.RpcController-org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.CoprocessorServiceRequest-">execRegionServerService,
 > href="../../../../../org/apache/hadoop/hbase/regionserver/HRegionServer.html#getCacheConfig--">getCacheConfig,
 > href="../../../../../org/apache/hadoop/hbase/regionserver/HRegionServer.html#getChoreService--">getChoreService,
 > href="../../../../../org/apache/hadoop/hbase/regionserver/HRegionServer.html#getClusterConnection--">getClusterConnection,
 > getClusterId, getCompactionPressure,
 getCompactionRequester,
 getCompactSplitThread,
 getConfiguration,
 getConfigurationManager,
 getConnection,
 getCoordinatedStateManager,
 getExecutorService,
 getFavoredNodesForRegion,
 getFileSystem,
 getFlushPressure,
 getFlushRequester,
 getFlushThroughputController,
 getFromOnlineRegions,
 getHeapMemoryManager, getInfoServer,
 getLastSequenceId,
 getLeases,
 getMasterAddressTracker,
 getMetaTableLocator,
 getMetrics,
 getMostLoadedRegions,
 getNonceManager, getNumberOfOnlineRegions,
 getOnlineRegion,
 getOnlineRegions,
 getOnlineRegions,
 getOnlineRegionsLocalContext,
 getOnlineTables,
 getRecoveringRegions,
 getRegion, 
getRegionBlockLocations,
 getRegionByEncodedName,
 getRegionByEncodedName,
 getRegionServerAccounting,
 getRegionServerCoprocessorHost,
 getRegionServerCoprocessors,
 getRegionServerMetrics,
 getRegionServerQuotaManager,
 getRegionsInTransitionInRS,
 getRootDir,
 getRpcServer,
 getRSRpcServices,
 getSecureBulkLoadManager,
 getStartcode,
 getTableLockManager,
 getThreadWakeFrequency,
 getWAL,
 getWALs,
 handleReportForDutyResponse,
 isAborted,
 isOnline,
 isProcedureFinished,
 isStopped,
 isStopping,
 kill,
 movedRegionCleanerPeriod,
 onConfigurationChange,
 postOpenDeployTasks,
 postOpenDeployTasks,
 removeFromOnlineRegions,
 reportRegionStateTransition,
 reportRegionStateTransition,
 reportRegionStateTransition,
 requestRegionSplit,
 run,
 setInitLatch,
 setupClusterConnection,
 shouldUseThisHostnameInstead,
 stop,
 toString, tryRegionServerReport,
 updateConfiguration,
 updateRegionFavoredNodesMapping,
 waitForServerOnline,
 walRollRequestFinished
+abort,
 addToMovedRegions,
 addToOnlineRegions,
 checkFileSystem,
 cleanMovedRegions,
 closeAllRegions,
 closeAndOfflineRegionForSp
 lit, closeRegion,
 constructRegionServer,
 convertThrowableToIOE,
 createClusterConnection,
 createRegionLoad,
 createRegionServerStatusStub, href="../../../../../org/apache/hadoop/hbase/regionserver/HRegionServer.html#createRegionServerStatusStub-boolean-">createRegionServerStatusStub,
 > href="../../../../../org/apache/hadoop/hbase/regionserver/HRegionServer.html#execRegionServerService-org.apache.hadoop.hbase.shaded.com.google.protobuf.RpcController-org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.CoprocessorServiceRequest-">execRegionServerService,
 > href="../../../../../org/apache/hadoop/hbase/regionserver/HRegionServer.html#getCacheConfig--">getCacheConfig,
 > href="../../../../../org/apache/hadoop/hbase/regionserver/HRegionServer.html#getChoreService--">getChoreService,
 > href="../../../../../org/apache/hadoop/hbase/regionserver/HRegionServer.html#getClusterConnection--">getClusterConnection,
 > href="../../../../../org/apache/hadoop/hbase/regionserver/HRegionServer.html#getClusterId--">getClusterId,
 > getCompactionPressure, getCompactionRequester,
 getCompactSplitThread,
 getConfiguration,
 getConfigurationManager,
 getConnection,
 getCoordinatedStateManager,
 getExecutorService,
 getFavoredNodesForRegion,
 getFileSystem,
 getFlushPressure,
 getFlushRequester,
 getFlushThroughputController,
 getFromOnlineRegions,
 getHeapMemoryManager,
 getInfoServer, getLastSequenceId,
 getLeases,
 getMasterAddressTracker,
 getMetaTableLocator,
 getMetrics,
 getMostLoadedRegions,
 getNonceM

[45/52] [partial] hbase-site git commit: Published site at 8a6d6aa23944bbfd5047cf0c09fb4d8045735dab.

2016-11-11 Thread stack

http://git-wip-us.apache.org/repos/asf/hbase-site/blob/74ea7fbd/apidocs/src-html/org/apache/hadoop/hbase/client/AsyncTable.html
--
diff --git a/apidocs/src-html/org/apache/hadoop/hbase/client/AsyncTable.html 
b/apidocs/src-html/org/apache/hadoop/hbase/client/AsyncTable.html
index b655608..d2f6544 100644
--- a/apidocs/src-html/org/apache/hadoop/hbase/client/AsyncTable.html
+++ b/apidocs/src-html/org/apache/hadoop/hbase/client/AsyncTable.html
@@ -108,242 +108,279 @@
 100  long getOperationTimeout(TimeUnit 
unit);
 101
 102  /**
-103   * Test for the existence of columns in 
the table, as specified by the Get.
-104   * 
-105   * This will return true if the Get 
matches one or more keys, false if not.
-106   * 

-107   * This is a server-side call so it 
prevents any data from being transfered to the client.
-108   * @return true if the specified Get 
matches one or more keys, false if not. The return value will
-109   * be wrapped by a {@link 
CompletableFuture}.
-110   */
-111  default 
CompletableFuture exists(Get get) {
-112if (!get.isCheckExistenceOnly()) {
-113  get = 
ReflectionUtils.newInstance(get.getClass(), get);
-114  get.setCheckExistenceOnly(true);
-115}
-116return get(get).thenApply(r -> 
r.getExists());
-117  }
-118
-119  /**
-120   * Extracts certain cells from a given 
row.
-121   * @param get The object that specifies 
what data to fetch and from which row.
-122   * @return The data coming from the 
specified row, if it exists. If the row specified doesn't
-123   * exist, the {@link Result} 
instance returned won't contain any
-124   * {@link 
org.apache.hadoop.hbase.KeyValue}, as indicated by {@link Result#isEmpty()}. 
The
-125   * return value will be wrapped 
by a {@link CompletableFuture}.
-126   */
-127  CompletableFuture get(Get 
get);
-128
-129  /**
-130   * Puts some data to the table.
-131   * @param put The data to put.
-132   * @return A {@link CompletableFuture} 
that always returns null when complete normally.
-133   */
-134  CompletableFuture put(Put 
put);
-135
-136  /**
-137   * Deletes the specified cells/row.
-138   * @param delete The object that 
specifies what to delete.
-139   * @return A {@link CompletableFuture} 
that always returns null when complete normally.
-140   */
-141  CompletableFuture 
delete(Delete delete);
-142
-143  /**
-144   * Appends values to one or more 
columns within a single row.
-145   * 

-146   * This operation does not appear 
atomic to readers. Appends are done under a single row lock, so
-147   * write operations to a row are 
synchronized, but readers do not take row locks so get and scan
-148   * operations can see this operation 
partially completed.
-149   * @param append object that specifies 
the columns and amounts to be used for the increment
-150   *  operations
-151   * @return values of columns after the 
append operation (maybe null). The return value will be
-152   * wrapped by a {@link 
CompletableFuture}.
-153   */
-154  CompletableFuture 
append(Append append);
-155
-156  /**
-157   * Increments one or more columns 
within a single row.
-158   * 

-159   * This operation does not appear 
atomic to readers. Increments are done under a single row lock,
-160   * so write operations to a row are 
synchronized, but readers do not take row locks so get and
-161   * scan operations can see this 
operation partially completed.
-162   * @param increment object that 
specifies the columns and amounts to be used for the increment
-163   *  operations
-164   * @return values of columns after the 
increment. The return value will be wrapped by a
-165   * {@link CompletableFuture}.
-166   */
-167  CompletableFuture 
increment(Increment increment);
-168
-169  /**
-170   * See {@link 
#incrementColumnValue(byte[], byte[], byte[], long, Durability)}
-171   * 

-172   * The {@link Durability} is defaulted 
to {@link Durability#SYNC_WAL}.
-173   * @param row The row that contains the 
cell to increment.
-174   * @param family The column family of 
the cell to increment.
-175   * @param qualifier The column 
qualifier of the cell to increment.
-176   * @param amount The amount to 
increment the cell with (or decrement, if the amount is negative).
-177   * @return The new value, post 
increment. The return value will be wrapped by a
-178   * {@link CompletableFuture}.
-179   */
-180  default CompletableFuture 
incrementColumnValue(byte[] row, byte[] family, byte[] qualifier,
-181  long amount) {
-182return incrementColumnValue(row, 
family, qualifier, amount, Durability.SYNC_WAL);
-183  }
-184
-185  /**
-186   * Atomically increments a column 
value. If the column value already exists and is not a
-187   * big-endian long, this could throw an 
exception. If the column value does not yet exist it is
-188   * initialized

[32/52] [partial] hbase-site git commit: Published site at 8a6d6aa23944bbfd5047cf0c09fb4d8045735dab.

2016-11-11 Thread stack

http://git-wip-us.apache.org/repos/asf/hbase-site/blob/74ea7fbd/devapidocs/org/apache/hadoop/hbase/classification/class-use/InterfaceAudience.Private.html
--
diff --git 
a/devapidocs/org/apache/hadoop/hbase/classification/class-use/InterfaceAudience.Private.html
 
b/devapidocs/org/apache/hadoop/hbase/classification/class-use/InterfaceAudience.Private.html
index 099bb2e..4baed2c 100644
--- 
a/devapidocs/org/apache/hadoop/hbase/classification/class-use/InterfaceAudience.Private.html
+++ 
b/devapidocs/org/apache/hadoop/hbase/classification/class-use/InterfaceAudience.Private.html
@@ -1208,6 +1208,18 @@ service.
 
 
 (package private) class 
+AllowPartialScanResultCache
+A ScanResultCache that may return partial result.
+
+
+
+(package private) class 
+AsyncClientScanner
+The asynchronous client scanner implementation.
+
+
+
+(package private) class 
 AsyncConnectionConfiguration
 Timeout configs.
 
@@ -1237,23 +1249,35 @@ service.
 
 
 
+(package private) class 
+AsyncRegistryFactory
+Get instance of configured Registry.
+
+
+
 interface 
 AsyncRequestFuture
 The context used to wait for results from one submit 
call.
 
 
-
+
 (package private) class 
 AsyncRequestFutureImpl
 The context, and return value, for a single 
submit/submitAll call.
 
 
-
+
 (package private) class 
 AsyncRpcRetryingCallerFactory
 Factory to create an AsyncRpcRetryCaller.
 
 
+
+(package private) class 
+AsyncScanSingleRegionRpcRetryingCaller
+Retry caller for scanning a region.
+
+
 
 (package private) class 
 AsyncSingleRequestRpcRetryingCaller
@@ -1361,14 +1385,14 @@ service.
 
 
 (package private) class 
-ClusterRegistryFactory
-Get instance of configured Registry.
+ClusterStatusListener
+A class that receives the cluster status, and provide it as 
a set of service to the client.
 
 
 
 (package private) class 
-ClusterStatusListener
-A class that receives the cluster status, and provide it as 
a set of service to the client.
+CompleteScanResultCache
+A scan result cache that only returns complete result.
 
 
 
@@ -1665,56 +1689,62 @@ service.
 
 
 
+(package private) interface 
+ScanResultCache
+Used to separate the row constructing logic.
+
+
+
 class 
 SecureBulkLoadClient
 Client proxy for SecureBulkLoadProtocol
 
 
-
+
 class 
 ServerStatisticTracker
 Tracks the statistics for multiple regions
 
 
-
+
 class 
 SingleResponse
 Class for single action response
 
 
-
+
 static class 
 SingleResponse.Entry 
 
-
+
 interface 
 StatisticTrackable
 Parent interface for an object to get updates about 
per-region statistics.
 
 
-
+
 class 
 TableState
 Represents table state.
 
 
-
+
 static class 
 TableState.State 
 
-
+
 class 
 VersionInfoUtil
 Class to help with parsing the version info.
 
 
-
+
 (package private) class 
 ZKAsyncRegistry
 Cache the cluster registry data in memory and use zk 
watcher to update.
 
 
-
+
 (package private) class 
 ZooKeeperRegistry
 A cluster registry that stores to zookeeper.
@@ -6667,7 +6697,7 @@ service.
 
 (package private) class 
 RingBufferTruck
-A 'truck' to carry a payload across the FSHLog ring buffer 
from Handler to WAL.
+A 'truck' to carry a payload across the ring buffer from 
Handler to WAL.
 
 
 
@@ -6943,7 +6973,7 @@ service.
 
 class 
 TableCFsUpdater
-This class is used to upgrade TableCFs from HBase 1.x to 
HBase 2.x.
+This class is used to upgrade TableCFs from HBase 1.0, 1.1, 
1.2, 1.3 to HBase 1.4 or 2.x.
 
 
 

http://git-wip-us.apache.org/repos/asf/hbase-site/blob/74ea7fbd/devapidocs/org/apache/hadoop/hbase/classification/class-use/InterfaceAudience.Public.html
--
diff --git 
a/devapidocs/org/apache/hadoop/hbase/classification/class-use/InterfaceAudience.Public.html
 
b/devapidocs/org/apache/hadoop/hbase/classification/class-use/InterfaceAudience.Public.html
index 37aa887..f669f25 100644
--- 
a/devapidocs/org/apache/hadoop/hbase/classification/class-use/InterfaceAudience.Public.html
+++ 
b/devapidocs/org/apache/hadoop/hbase/classification/class-use/InterfaceAudience.Public.html
@@ -870,47 +870,53 @@ Input/OutputFormats, a table indexing MapReduce job, and 
utility methods.
 
 
 
+interface 
+ScanResultConsumer
+Receives Result from an 
asynchronous scanner.
+
+
+
 class 
 SnapshotDescription
 The POJO equivalent of HBaseProtos.SnapshotDescription
 
 
-
+
 class 
 SnapshotType
 POJO representing the snapshot type
 
 
-
+
 (package private) class 
 SyncCoprocessorRpcChannel
 Base class which provides clients with an RPC connection to
  call coprocessor endpoint Services.
 
 
-
+
 interface 
 Table
 Used to communicate with a single HBase table.
 
 
-
+
 class 
 TableSnapshotScanner
 A Scanner which performs a scan over snapshot files.
 
 
-
+
 (package private) class 
 UnmodifyableHRegionInfo 
 
-
+
 class 
 UnmodifyableHTableDescriptor
 Read-only table descriptor.
 
 
-
+
 class 
 WrongRowIOException 
 

http://git-wip-us.apache

[31/52] [partial] hbase-site git commit: Published site at 8a6d6aa23944bbfd5047cf0c09fb4d8045735dab.

2016-11-11 Thread stack

http://git-wip-us.apache.org/repos/asf/hbase-site/blob/74ea7fbd/devapidocs/org/apache/hadoop/hbase/client/AsyncClientScanner.html
--
diff --git a/devapidocs/org/apache/hadoop/hbase/client/AsyncClientScanner.html 
b/devapidocs/org/apache/hadoop/hbase/client/AsyncClientScanner.html
new file mode 100644
index 000..71c22cc
--- /dev/null
+++ b/devapidocs/org/apache/hadoop/hbase/client/AsyncClientScanner.html
@@ -0,0 +1,465 @@
+http://www.w3.org/TR/html4/loose.dtd";>
+
+
+
+
+
+AsyncClientScanner (Apache HBase 2.0.0-SNAPSHOT API)
+
+
+
+
+
+var methods = {"i0":10,"i1":10,"i2":10,"i3":10};
+var tabs = {65535:["t0","All Methods"],2:["t2","Instance 
Methods"],8:["t4","Concrete Methods"]};
+var altColor = "altColor";
+var rowColor = "rowColor";
+var tableTab = "tableTab";
+var activeTableTab = "activeTableTab";
+
+
+JavaScript is disabled on your browser.
+
+
+
+
+
+Skip navigation links
+
+
+
+
+Overview
+Package
+Class
+Use
+Tree
+Deprecated
+Index
+Help
+
+
+
+
+Prev Class
+Next Class
+
+
+Frames
+No Frames
+
+
+All Classes
+
+
+
+
+
+
+
+Summary: 
+Nested | 
+Field | 
+Constr | 
+Method
+
+
+Detail: 
+Field | 
+Constr | 
+Method
+
+
+
+
+
+
+
+
+org.apache.hadoop.hbase.client
+Class 
AsyncClientScanner
+
+
+
+http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true";
 title="class or interface in java.lang">java.lang.Object
+
+
+org.apache.hadoop.hbase.client.AsyncClientScanner
+
+
+
+
+
+
+
+
+@InterfaceAudience.Private
+class AsyncClientScanner
+extends http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true";
 title="class or interface in java.lang">Object
+The asynchronous client scanner implementation.
+ 
+ Here we will call OpenScanner first and use the returned scannerId to create a
+ AsyncScanSingleRegionRpcRetryingCaller
 to do the real scan operation. The return value of
+ AsyncScanSingleRegionRpcRetryingCaller
 will tell us whether open a new scanner or finish
+ scan.
+
+
+
+
+
+
+
+
+
+
+
+Nested Class Summary
+
+Nested Classes 
+
+Modifier and Type
+Class and Description
+
+
+private static class 
+AsyncClientScanner.OpenScannerResponse 
+
+
+
+
+
+
+
+
+
+Field Summary
+
+Fields 
+
+Modifier and Type
+Field and Description
+
+
+private AsyncConnectionImpl
+conn 
+
+
+private ScanResultConsumer
+consumer 
+
+
+private ScanResultCache
+resultCache 
+
+
+private long
+rpcTimeoutNs 
+
+
+private Scan
+scan 
+
+
+private long
+scanTimeoutNs 
+
+
+private TableName
+tableName 
+
+
+
+
+
+
+
+
+
+Constructor Summary
+
+Constructors 
+
+Constructor and Description
+
+
+AsyncClientScanner(Scan scan,
+  ScanResultConsumer consumer,
+  TableName tableName,
+  AsyncConnectionImpl conn,
+  long scanTimeoutNs,
+  long rpcTimeoutNs) 
+
+
+
+
+
+
+
+
+
+Method Summary
+
+All Methods Instance Methods Concrete Methods 
+
+Modifier and Type
+Method and Description
+
+
+private http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/CompletableFuture.html?is-external=true";
 title="class or interface in java.util.concurrent">CompletableFuture
+callOpenScanner(HBaseRpcController controller,
+   HRegionLocation loc,
+   
org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ClientService.Interface stub) 
+
+
+private void
+openScanner(boolean locateToPreviousRegion) 
+
+
+void
+start() 
+
+
+private void
+startScan(AsyncClientScanner.OpenScannerResponse resp) 
+
+
+
+
+
+
+Methods inherited from class java.lang.http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true";
 title="class or interface in java.lang">Object
+http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true#clone--";
 title="class or interface in java.lang">clone, http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true#equals-java.lang.Object-";
 title="class or interface in java.lang">equals, http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true#finalize--";
 title="class or interface in java.lang">finalize, http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true#getClass--";
 title="class or interface in java.lang">getClass, http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true#hashCode--";
 title="class or interface in java.lang">hashCode, http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-exter

[10/52] [partial] hbase-site git commit: Published site at 8a6d6aa23944bbfd5047cf0c09fb4d8045735dab.

2016-11-11 Thread stack

http://git-wip-us.apache.org/repos/asf/hbase-site/blob/74ea7fbd/devapidocs/org/apache/hadoop/hbase/master/balancer/BaseLoadBalancer.html
--
diff --git 
a/devapidocs/org/apache/hadoop/hbase/master/balancer/BaseLoadBalancer.html 
b/devapidocs/org/apache/hadoop/hbase/master/balancer/BaseLoadBalancer.html
index a1b441f..d45963d 100644
--- a/devapidocs/org/apache/hadoop/hbase/master/balancer/BaseLoadBalancer.html
+++ b/devapidocs/org/apache/hadoop/hbase/master/balancer/BaseLoadBalancer.html
@@ -117,7 +117,7 @@ var activeTableTab = "activeTableTab";
 
 
 
-public abstract class BaseLoadBalancer
+public abstract class BaseLoadBalancer
 extends http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true";
 title="class or interface in java.lang">Object
 implements LoadBalancer
 The base class for load balancers. It provides the the 
functions used to by
@@ -305,8 +305,9 @@ implements 
 protected BaseLoadBalancer.Cluster
-createCluster(http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true";
 title="class or interface in java.util">List servers,
- http://docs.oracle.com/javase/8/docs/api/java/util/Collection.html?is-external=true";
 title="class or interface in java.util">Collection regions) 
+createCluster(http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true";
 title="class or interface in java.util">List servers,
+ http://docs.oracle.com/javase/8/docs/api/java/util/Collection.html?is-external=true";
 title="class or interface in java.util">Collection regions,
+ boolean forceRefresh) 
 
 
 org.apache.hadoop.conf.Configuration
@@ -480,7 +481,7 @@ implements 
 
 MIN_SERVER_BALANCE
-protected static final int MIN_SERVER_BALANCE
+protected static final int MIN_SERVER_BALANCE
 
 See Also:
 Constant
 Field Values
@@ -493,7 +494,7 @@ implements 
 
 stopped
-private volatile boolean stopped
+private volatile boolean stopped
 
 
 
@@ -502,7 +503,7 @@ implements 
 
 EMPTY_REGION_LIST
-private static final http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true";
 title="class or interface in java.util">List EMPTY_REGION_LIST
+private static final http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true";
 title="class or interface in java.util">List EMPTY_REGION_LIST
 
 
 
@@ -511,7 +512,7 @@ implements 
 
 regionFinder
-protected final RegionLocationFinder regionFinder
+protected final RegionLocationFinder regionFinder
 
 
 
@@ -520,7 +521,7 @@ implements 
 
 slop
-protected float slop
+protected float slop
 
 
 
@@ -529,7 +530,7 @@ implements 
 
 config
-protected org.apache.hadoop.conf.Configuration config
+protected org.apache.hadoop.conf.Configuration config
 
 
 
@@ -538,7 +539,7 @@ implements 
 
 rackManager
-protected RackManager rackManager
+protected RackManager rackManager
 
 
 
@@ -547,7 +548,7 @@ implements 
 
 RANDOM
-private static final http://docs.oracle.com/javase/8/docs/api/java/util/Random.html?is-external=true";
 title="class or interface in java.util">Random RANDOM
+private static final http://docs.oracle.com/javase/8/docs/api/java/util/Random.html?is-external=true";
 title="class or interface in java.util">Random RANDOM
 
 
 
@@ -556,7 +557,7 @@ implements 
 
 LOG
-private static final org.apache.commons.logging.Log LOG
+private static final org.apache.commons.logging.Log LOG
 
 
 
@@ -565,7 +566,7 @@ implements 
 
 DEFAULT_TABLES_ON_MASTER
-private static final http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
 title="class or interface in java.lang">String[] DEFAULT_TABLES_ON_MASTER
+private static final http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
 title="class or interface in java.lang">String[] DEFAULT_TABLES_ON_MASTER
 
 
 
@@ -574,7 +575,7 @@ implements 
 
 TABLES_ON_MASTER
-public static final http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
 title="class or interface in java.lang">String TABLES_ON_MASTER
+public static final http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
 title="class or interface in java.lang">String TABLES_ON_MASTER
 
 See Also:
 Constant
 Field Values
@@ -587,7 +588,7 @@ implements 
 
 tablesOnMaster
-protected final http://docs.oracle.com/javase/8/docs/api/java/util/Set.html?is-external=true";
 title="class or interface in java.util">SetString> tablesOnMaster
+protected final http://docs.oracle.com/javase/8/docs/api/java/util/Set.html?is-external=true";
 title="class or interface in java.util">SetString> tabl

[22/52] [partial] hbase-site git commit: Published site at 8a6d6aa23944bbfd5047cf0c09fb4d8045735dab.

2016-11-11 Thread stack

http://git-wip-us.apache.org/repos/asf/hbase-site/blob/74ea7fbd/devapidocs/org/apache/hadoop/hbase/client/class-use/Scan.html
--
diff --git a/devapidocs/org/apache/hadoop/hbase/client/class-use/Scan.html 
b/devapidocs/org/apache/hadoop/hbase/client/class-use/Scan.html
index 3832742..67655b3 100644
--- a/devapidocs/org/apache/hadoop/hbase/client/class-use/Scan.html
+++ b/devapidocs/org/apache/hadoop/hbase/client/class-use/Scan.html
@@ -234,6 +234,14 @@ service.
 
 
 private Scan
+AsyncClientScanner.scan 
+
+
+private Scan
+AsyncScanSingleRegionRpcRetryingCaller.scan 
+
+
+private Scan
 ScannerCallable.scan 
 
 
@@ -242,6 +250,10 @@ service.
 
 
 private Scan
+AsyncRpcRetryingCallerFactory.ScanSingleRegionCallerBuilder.scan 
+
+
+private Scan
 TableSnapshotScanner.scan 
 
 
@@ -514,6 +526,18 @@ service.
 
 
 
+void
+AsyncTable.scan(Scan scan,
+ScanResultConsumer consumer)
+The basic scan API uses the observer pattern.
+
+
+
+void
+AsyncTableImpl.scan(Scan scan,
+ScanResultConsumer consumer) 
+
+
 private Scan
 AsyncTableImpl.setDefaultScanConfig(Scan scan) 
 
@@ -522,19 +546,23 @@ service.
 AsyncRpcRetryingCallerFactory.SmallScanCallerBuilder.setScan(Scan scan) 
 
 
+AsyncRpcRetryingCallerFactory.ScanSingleRegionCallerBuilder
+AsyncRpcRetryingCallerFactory.ScanSingleRegionCallerBuilder.setScan(Scan scan) 
+
+
 default http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/CompletableFuture.html?is-external=true";
 title="class or interface in java.util.concurrent">CompletableFutureList>
 AsyncTable.smallScan(Scan scan)
 Just call AsyncTable.smallScan(Scan,
 int) with http://docs.oracle.com/javase/8/docs/api/java/lang/Integer.html?is-external=true#MAX_VALUE";
 title="class or interface in 
java.lang">Integer.MAX_VALUE.
 
 
-
+
 http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/CompletableFuture.html?is-external=true";
 title="class or interface in java.util.concurrent">CompletableFutureList>
 AsyncTable.smallScan(Scan scan,
  int limit)
 Return all the results that match the given scan 
object.
 
 
-
+
 http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/CompletableFuture.html?is-external=true";
 title="class or interface in java.util.concurrent">CompletableFutureList>
 AsyncTableImpl.smallScan(Scan scan,
  int limit) 
@@ -548,6 +576,29 @@ service.
 
 
 
+AsyncClientScanner(Scan scan,
+  ScanResultConsumer consumer,
+  TableName tableName,
+  AsyncConnectionImpl conn,
+  long scanTimeoutNs,
+  long rpcTimeoutNs) 
+
+
+AsyncScanSingleRegionRpcRetryingCaller(io.netty.util.HashedWheelTimer retryTimer,
+  AsyncConnectionImpl conn,
+  Scan scan,
+  long scannerId,
+  ScanResultCache resultCache,
+  ScanResultConsumer consumer,
+  
org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ClientService.Interface stub,
+  HRegionLocation loc,
+  long pauseNs,
+  int maxRetries,
+  long scanTimeoutNs,
+  long rpcTimeoutNs,
+  
int startLogErrorsCnt) 
+
+
 AsyncSmallScanRpcRetryingCaller(AsyncConnectionImpl conn,
TableName tableName,
Scan scan,

http://git-wip-us.apache.org/repos/asf/hbase-site/blob/74ea7fbd/devapidocs/org/apache/hadoop/hbase/client/class-use/ScanResultCache.html
--
diff --git 
a/devapidocs/org/apache/hadoop/hbase/client/class-use/ScanResultCache.html 
b/devapidocs/org/apache/hadoop/hbase/client/class-use/ScanResultCache.html
new file mode 100644
index 000..fc4db01
--- /dev/null
+++ b/devapidocs/org/apache/hadoop/hbase/client/class-use/ScanResultCache.html
@@ -0,0 +1,232 @@
+http://www.w3.org/TR/html4/loose.dtd";>
+
+
+
+
+
+Uses of Interface org.apache.hadoop.hbase.client.ScanResultCache 
(Apache HBase 2.0.0-SNAPSHOT API)
+
+
+
+
+
+
+
+JavaScript is disabled on your browser.
+
+
+
+
+
+Skip navigation links
+
+
+
+
+Overview
+Package
+Class
+Use
+Tree
+Deprecated
+Index
+Help
+
+
+
+
+Prev
+Next
+
+
+Frames
+No Frames
+
+
+All Classes
+
+
+
+
+
+
+
+
+
+
+Uses of 
Classorg.apache.hadoop.hbase.client.AsyncClientScanner.OpenScannerResponse
+
+
+
+
+
+Packages that use AsyncClientScanner.OpenScannerResponse 
+
+Package
+Description
+
+
+
+org.apache.hadoop.hbase.client
+
+Provides HBase Client
+
+
+
+
+
+
+
+
+
+
+Uses of AsyncClientScanner.OpenScannerResponse in 
org.apache.hadoop.hbase.client
+
+Methods in org.apache.hadoop.hbase.client
 that return types with arguments of type AsyncClientScanner.OpenScannerResponse 
+
+Modifier and Type
+Method and Description
+
+
+
+private http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/CompletableFuture.html?is-external=true";
 title="class or interface in java.util.concurrent">CompletableFuture
+AsyncClientScanner.callOpenScanner(HBaseRpcController controller,
+   HRegionLocation loc,
+   
org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ClientService.Interface stub) 
+
+
+
+
+Methods in org.apache.hadoop.hbase.client
 with parameters of type AsyncClientScanner.OpenScannerResponse 
+
+Modifier and Type
+Method and Description
+
+
+
+private void
+AsyncClientScanner.startScan(AsyncClientScanner.OpenScannerResponse resp) 
+
+
+
+
+
+
+
+
+
+
+
+
+Skip navigation links
+
+
+
+
+Overview
+Package
+Class
+Use
+Tree
+Deprecated
+Index
+Help
+
+
+
+
+Prev
+Next
+
+
+Frames
+No Frames
+
+
+All Classes
+
+
+
+
+
+
+
+
+
+Copyright © 2007–2016 http://www.apache.org/";>The Apache Software Foundation. All rights 
reserved.
+
+

http://git-wip-us.apache.org/repos/asf/hbase-site/blob/74ea7fbd/devapidocs/org/apache/hadoop/hbase/client/class-use/AsyncClientScanner.html
--
diff --git 
a/devapidocs/org/apache/hadoop/hbase/client/class-use/AsyncClientScanner.html 
b/devapidocs/org/apache/hadoop/hbase/client/class-use/AsyncClientScanner.html
new file mode 100644
index 000..f99875b
--- /dev/null
+++ 
b/devapidocs/org/apache/hadoop/hbase/client/class-use/AsyncClientScanner.html
@@ -0,0 +1,125 @@
+http://www.w3.org/TR/html4/loose.dtd";>
+
+
+
+
+
+Uses of Class org.apache.hadoop.hbase.client.AsyncClientScanner (Apache 
HBase 2.0.0-SNAPSHOT API)
+
+
+
+
+
+
+
+JavaScript is disabled on your browser.
+
+
+
+
+
+Skip navigation links
+
+
+
+
+Overview
+Package
+Class
+Use
+Tree
+Deprecated
+Index
+Help
+
+
+
+
+Prev
+Next
+
+
+Frames
+No Frames
+
+
+All Classes
+
+
+
+
+
+
+
+
+
+
+Uses of 
Classorg.apache.hadoop.hbase.client.AsyncClientScanner
+
+No usage of 
org.apache.hadoop.hbase.client.AsyncClientScanner
+
+
+
+
+Skip navigation links
+
+
+
+
+Overview
+Package
+Class
+Use
+Tree
+Deprecated
+Index
+Help
+
+
+
+
+Prev
+Next
+
+
+Frames
+No Frames
+
+
+All Classes
+
+
+
+var methods = 
{"i0":10,"i1":10,"i2":10,"i3":10,"i4":10,"i5":10,"i6":10,"i7":10,"i8":10,"i9":10,"i10":10,"i11":10,"i12":10,"i13":10,"i14":10,"i15":10};
+var tabs = {65535:["t0","All Methods"],2:["t2","Instance 
Methods"],8:["t4","Concrete Methods"]};
+var altColor = "altColor";
+var rowColor = "rowColor";
+var tableTab = "tableTab";
+var activeTableTab = "activeTableTab";
+
+
+JavaScript is disabled on your browser.
+
+
+
+
+
+Skip navigation links
+
+
+
+
+Overview
+Package
+Class
+Use
+Tree
+Deprecated
+Index
+Help
+
+
+
+
+Prev Class
+Next Class
+
+
+Frames
+No Frames
+
+
+All Classes
+
+
+
+
+
+
+
+Summary: 
+Nested | 
+Field | 
+Constr | 
+Method
+
+
+Detail: 
+Field | 
+Constr | 
+Method
+
+
+
+
+
+
+
+
+org.apache.hadoop.hbase.client
+Class 
AsyncScanSingleRegionRpcRetryingCaller
+
+
+
+http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true";
 title="class or interface in java.lang">java.lang.Object
+
+
+org.apache.hadoop.hbase.client.AsyncScanSingleRegionRpcRetryingCaller
+
+
+
+
+
+
+
+
+@InterfaceAudience.Private
+class AsyncScanSingleRegionRpcRetryingCaller
+extends http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true";
 title="class or interface in java.lang">Object
+Retry caller for scanning a region.
+ 
+ We will modify the Scan object passed in 
directly. The upper layer should store the
+ reference of this object and use it to open new single region scanners.
+
+
+
+
+
+
+
+
+
+
+
+Field Summary
+
+Fields 
+
+Modifier and Type
+Field and Description
+
+
+private http://docs.oracle.com/javase/8/docs/api/java/lang/Runnable.html?is-external=true";
 title="class or interface in java.lang">Runnable
+completeWhenNoMoreResultsInRegion 
+
+
+private ScanResultConsumer
+consumer 
+
+
+private HBaseRpcController
+controller 
+
+
+private http://docs.oracle.com/javase/8/docs/api/java/util/function/Supplier.html?is-external=true";
 title="class or interface in 
java.util.function">Supplier
+createNextStartRowWhenError 
+
+
+private http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true";
 title="class or interface in java.util">List
+exceptions 
+
+
+private http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/CompletableFuture.html?is-external=true";
 title="class or interface in java.util.concurrent">CompletableFutureBoolean>
+future 
+
+
+private boolean
+includeNextStartRowWhenError 
+
+
+private HRegionLocation
+loc 
+
+
+private static 
org.apache.commons.logging.Log
+LOG 
+
+
+private int
+maxAttempts 
+
+
+private long
+nextCallSeq 
+
+
+private long
+nextCallStartNs 
+
+
+private byte[]
+nextStartRowWhenError 
+
+
+private long
+pauseNs 
+
+
+private ScanResultCache
+resultCache 
+
+
+private io.netty.util.HashedWheelTimer
+retryTimer 
+
+
+private long
+rpcTimeoutNs 
+
+
+private Scan
+scan 
+
+
+private long
+scannerId 
+
+
+private long
+scanTimeoutNs 
+
+
+private int
+startLogErrorsCnt 
+
+
+private 
org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ClientService.Interface
+stub 
+
+
+private int
+tries 
+
+
+
+
+
+
+
+
+
+Constructor Summary
+
+Constructors 
+
+Constructor and Description
+
+
+AsyncScanSingleRegionRpcRetryingCaller(io.netty.util.HashedWheelTimer retryTimer,
+  AsyncConnectionImpl conn,
+  Scan scan,
+  long scannerId,
+  ScanResultCache resultCache,
+  ScanResultConsumer consumer,
+  
org.apache.hadoop.hbase.shaded.protobuf.generated

[50/52] [partial] hbase-site git commit: Published site at 8a6d6aa23944bbfd5047cf0c09fb4d8045735dab.

2016-11-11 Thread stack

http://git-wip-us.apache.org/repos/asf/hbase-site/blob/74ea7fbd/apidocs/constant-values.html
--
diff --git a/apidocs/constant-values.html b/apidocs/constant-values.html
index 4b7ce9f..2258aae 100644
--- a/apidocs/constant-values.html
+++ b/apidocs/constant-values.html
@@ -2040,377 +2040,384 @@
 "hbase.replication.conf.dir"
 
 
+
+
+public static final http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
 title="class or interface in java.lang">String
+REPLICATION_META_FAMILY_STR
+"rep_meta"
+
+
 
 
 public static final http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
 title="class or interface in java.lang">String
 REPLICATION_POSITION_FAMILY_STR
 "rep_position"
 
-
+
 
 
 public static final int
 REPLICATION_QOS
 5
 
-
+
 
 
 public static final int
 REPLICATION_SCOPE_GLOBAL
 1
 
-
+
 
 
 public static final int
 REPLICATION_SCOPE_LOCAL
 0
 
-
+
 
 
 public static final int
 REPLICATION_SCOPE_SERIAL
 2
 
-
+
 
 
 public static final long
 REPLICATION_SERIALLY_WAITING_DEFAULT
 1L
 
-
+
 
 
 public static final http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
 title="class or interface in java.lang">String
 REPLICATION_SERIALLY_WAITING_KEY
 "hbase.serial.replication.waitingMs"
 
-
+
 
 
 public static final http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
 title="class or interface in java.lang">String
 REPLICATION_SERVICE_CLASSNAME_DEFAULT
 "org.apache.hadoop.hbase.replication.regionserver.Replication"
 
-
+
 
 
 public static final http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
 title="class or interface in java.lang">String
 REPLICATION_SINK_SERVICE_CLASSNAME
 "hbase.replication.sink.service"
 
-
+
 
 
 public static final int
 REPLICATION_SOURCE_MAXTHREADS_DEFAULT
 10
 
-
+
 
 
 public static final http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
 title="class or interface in java.lang">String
 REPLICATION_SOURCE_MAXTHREADS_KEY
 "hbase.replication.source.maxthreads"
 
-
+
 
 
 public static final http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
 title="class or interface in java.lang">String
 REPLICATION_SOURCE_SERVICE_CLASSNAME
 "hbase.replication.source.service"
 
-
+
 
 
 public static final http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
 title="class or interface in java.lang">String
 RPC_CODEC_CONF_KEY
 "hbase.client.rpc.codec"
 
-
+
 
 
 public static final byte
 RPC_CURRENT_VERSION
 0
 
-
+
 
 
 public static final http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
 title="class or interface in java.lang">String
 SEQNUM_QUALIFIER_STR
 "seqnumDuringOpen"
 
-
+
 
 
 public static final http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
 title="class or interface in java.lang">String
 SERVER_QUALIFIER_STR
 "server"
 
-
+
 
 
 public static final http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
 title="class or interface in java.lang">String
 SERVERNAME_QUALIFIER_STR
 "sn"
 
-
+
 
 
 public static final http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
 title="class or interface in java.lang">String
 SNAPSHOT_DIR_NAME
 ".hbase-snapshot"
 
-
+
 
 
 public static final int
 SOCKET_RETRY_WAIT_MS
 200
 
-
+
 
 
 public static final http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
 title="class or interface in java.lang">String
 SPLIT_LOGDIR_NAME
 "splitWAL"
 
-
+
 
 
 public static final http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
 title="class or interface in java.lang">String
 STARTCODE_QUALIFIER_STR
 "serverstartcode"
 
-
+
 
 
 public static final http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
 title="class or interface in java.lang">String
 STATE_QUALIFIER_STR
 "state"
 
-
+
 
 
 public static final http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
 title="class or interface in java.lang">String
 STATUS_MULTICAST_ADDRESS
 "hbase.status.multicast.address.ip"
 
-
+
 
 
 public static final http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
 title="class or interface in java.lang">String
 STATUS_MULTICAST_BIND_ADDRESS
 "hbase.status.multicast.bind.address.ip"
 
-
+
 
 
 public static final http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
 title="class or interface in java.lang">String
 STATUS_MULTICAST_PORT
 "hbase.status.multicast.address.port"
 
-
+
 
 
 public static final http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
 title="class or interface in java.lang">String
 STATUS_PUBLISHED
 "hbase.status.published"
 
-

[37/52] [partial] hbase-site git commit: Published site at 8a6d6aa23944bbfd5047cf0c09fb4d8045735dab.

2016-11-11 Thread stack

http://git-wip-us.apache.org/repos/asf/hbase-site/blob/74ea7fbd/devapidocs/org/apache/hadoop/hbase/HConstants.html
--
diff --git a/devapidocs/org/apache/hadoop/hbase/HConstants.html 
b/devapidocs/org/apache/hadoop/hbase/HConstants.html
index bdd073e..835e614 100644
--- a/devapidocs/org/apache/hadoop/hbase/HConstants.html
+++ b/devapidocs/org/apache/hadoop/hbase/HConstants.html
@@ -1523,14 +1523,26 @@ extends http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?
 
 
 static byte[]
+REPLICATION_META_FAMILY
+The replication meta family
+
+
+
+static http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
 title="class or interface in java.lang">String
+REPLICATION_META_FAMILY_STR
+The replication meta family as a string
+
+
+
+static byte[]
 REPLICATION_POSITION_FAMILY
-The replication barrier family
+The replication position family
 
 
 
 static http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
 title="class or interface in java.lang">String
 REPLICATION_POSITION_FAMILY_STR
-The replication barrier family as a string
+The replication position family as a string
 
 
 
@@ -3324,7 +3336,7 @@ public static final byte[] 
 REPLICATION_POSITION_FAMILY_STR
 public static final http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
 title="class or interface in java.lang">String REPLICATION_POSITION_FAMILY_STR
-The replication barrier family as a string
+The replication position family as a string
 
 See Also:
 Constant
 Field Values
@@ -3338,7 +3350,31 @@ public static final byte[] 
 REPLICATION_POSITION_FAMILY
 public static final byte[] REPLICATION_POSITION_FAMILY
-The replication barrier family
+The replication position family
+
+
+
+
+
+
+
+REPLICATION_META_FAMILY_STR
+public static final http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
 title="class or interface in java.lang">String REPLICATION_META_FAMILY_STR
+The replication meta family as a string
+
+See Also:
+Constant
 Field Values
+
+
+
+
+
+
+
+
+REPLICATION_META_FAMILY
+public static final byte[] REPLICATION_META_FAMILY
+The replication meta family
 
 
 
@@ -3347,7 +3383,7 @@ public static final byte[] 
 
 REGIONINFO_QUALIFIER_STR
-public static final http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
 title="class or interface in java.lang">String REGIONINFO_QUALIFIER_STR
+public static final http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
 title="class or interface in java.lang">String REGIONINFO_QUALIFIER_STR
 The RegionInfo qualifier as a string
 
 See Also:
@@ -3361,7 +3397,7 @@ public static final byte[] 
 
 REGIONINFO_QUALIFIER
-public static final byte[] REGIONINFO_QUALIFIER
+public static final byte[] REGIONINFO_QUALIFIER
 The regioninfo column qualifier
 
 
@@ -3371,7 +3407,7 @@ public static final byte[] 
 
 SERVER_QUALIFIER_STR
-public static final http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
 title="class or interface in java.lang">String SERVER_QUALIFIER_STR
+public static final http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
 title="class or interface in java.lang">String SERVER_QUALIFIER_STR
 The server column qualifier
 
 See Also:
@@ -3385,7 +3421,7 @@ public static final byte[] 
 
 SERVER_QUALIFIER
-public static final byte[] SERVER_QUALIFIER
+public static final byte[] SERVER_QUALIFIER
 The server column qualifier
 
 
@@ -3395,7 +3431,7 @@ public static final byte[] 
 
 STARTCODE_QUALIFIER_STR
-public static final http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
 title="class or interface in java.lang">String STARTCODE_QUALIFIER_STR
+public static final http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
 title="class or interface in java.lang">String STARTCODE_QUALIFIER_STR
 The startcode column qualifier
 
 See Also:
@@ -3409,7 +3445,7 @@ public static final byte[] 
 
 STARTCODE_QUALIFIER
-public static final byte[] STARTCODE_QUALIFIER
+public static final byte[] STARTCODE_QUALIFIER
 The startcode column qualifier
 
 
@@ -3419,7 +3455,7 @@ public static final byte[] 
 
 SEQNUM_QUALIFIER_STR
-public static final http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
 title="class or interface in java.lang">String SEQNUM_QUALIFIER_STR
+public static final http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
 title="class or interface in java.lang">String SEQNUM_QUALIFIER_STR
 The open seqnum column qualifier
 
 See Also:
@@ -3433,7 +3469,7 @@ public static final byte[] 
 
 SEQNUM_QUALIFIER
-public static final byte[] SEQNUM_QUALIFIER
+public static final byte[] SEQNUM_QUALIFIER
 The open seqnum column qualifier
 
 
@@ -3443,7 +3479,7 @@ public static final byte[] 
 
 STATE_QUALIFIER_STR
-pub

[41/52] [partial] hbase-site git commit: Published site at 8a6d6aa23944bbfd5047cf0c09fb4d8045735dab.

2016-11-11 Thread stack

http://git-wip-us.apache.org/repos/asf/hbase-site/blob/74ea7fbd/coc.html
--
diff --git a/coc.html b/coc.html
index 5db59bc..8b72a38 100644
--- a/coc.html
+++ b/coc.html
@@ -7,7 +7,7 @@
   
 
 
-
+
 
 Apache HBase – 
   Code of Conduct Policy
@@ -191,6 +191,18 @@
 
   
   
+  1.1 Documentation
+  
+API
+
+X-Ref
+
+Ref Guide (single-page)
+
+  
+
+
+  
   0.94 Documentation
   
 API
@@ -331,7 +343,7 @@ For flagrant violations requiring a firm response the PMC 
may opt to skip early
 http://www.apache.org/";>The Apache Software 
Foundation.
 All rights reserved.  
 
-  Last Published: 
2016-11-07
+  Last Published: 
2016-11-11
 
 
 

http://git-wip-us.apache.org/repos/asf/hbase-site/blob/74ea7fbd/cygwin.html
--
diff --git a/cygwin.html b/cygwin.html
index cdf2116..8238c67 100644
--- a/cygwin.html
+++ b/cygwin.html
@@ -7,7 +7,7 @@
   
 
 
-
+
 
 Apache HBase – Installing Apache HBase (TM) on Windows using 
Cygwin
 
@@ -189,6 +189,18 @@
 
   
   
+  1.1 Documentation
+  
+API
+
+X-Ref
+
+Ref Guide (single-page)
+
+  
+
+
+  
   0.94 Documentation
   
 API
@@ -673,7 +685,7 @@ Now your HBase server is running, start 
coding and build that next
 http://www.apache.org/";>The Apache Software 
Foundation.
 All rights reserved.  
 
-  Last Published: 
2016-11-07
+  Last Published: 
2016-11-11
 
 
 

http://git-wip-us.apache.org/repos/asf/hbase-site/blob/74ea7fbd/dependencies.html
--
diff --git a/dependencies.html b/dependencies.html
index daa81bc..6df5b3c 100644
--- a/dependencies.html
+++ b/dependencies.html
@@ -7,7 +7,7 @@
   
 
 
-
+
 
 Apache HBase – Project Dependencies
 
@@ -189,6 +189,18 @@
 
   
   
+  1.1 Documentation
+  
+API
+
+X-Ref
+
+Ref Guide (single-page)
+
+  
+
+
+  
   0.94 Documentation
   
 API
@@ -518,7 +530,7 @@
 http://www.apache.org/";>The Apache Software 
Foundation.
 All rights reserved.  
 
-  Last Published: 
2016-11-07
+  Last Published: 
2016-11-11
 
 
 

http://git-wip-us.apache.org/repos/asf/hbase-site/blob/74ea7fbd/dependency-convergence.html
--
diff --git a/dependency-convergence.html b/dependency-convergence.html
index a734924..986077d 100644
--- a/dependency-convergence.html
+++ b/dependency-convergence.html
@@ -7,7 +7,7 @@
   
 
 
-
+
 
 Apache HBase – Reactor Dependency Convergence
 
@@ -189,6 +189,18 @@
 
   
   
+  1.1 Documentation
+  
+API
+
+X-Ref
+
+Ref Guide (single-page)
+
+  
+
+
+  
   0.94 Documentation
   
 API
@@ -287,10 +299,10 @@
 31
 
 Number of dependencies (NOD):
-92
+93
 
 Number of unique artifacts (NOA):
-93
+94
 
 Number of SNAPSHOT artifacts (NOS):
 0
@@ -410,7 +422,7 @@
 
 
 
-3.3.0
+3.3.6
 
 
 http://hbase.apache.org/hbase-server";>org.apache.hbase:hbase-server
@@ -472,7 +484,7 @@
 
 
 
-1.2
+1.3.1
 
 
 http://hbase.apache.org/hbase-it";>org.apache.hbase:hbase-it
@@ -1072,6 +1084,18 @@
 http://hbase.apache.org/hbase-testing-util";>org.apache.hb

[42/52] [partial] hbase-site git commit: Published site at 8a6d6aa23944bbfd5047cf0c09fb4d8045735dab.

2016-11-11 Thread stack

http://git-wip-us.apache.org/repos/asf/hbase-site/blob/74ea7fbd/checkstyle-aggregate.html
--
diff --git a/checkstyle-aggregate.html b/checkstyle-aggregate.html
index 304a21b..88d1b6c 100644
--- a/checkstyle-aggregate.html
+++ b/checkstyle-aggregate.html
@@ -7,7 +7,7 @@
   
 
 
-
+
 
 Apache HBase – Checkstyle Results
 
@@ -189,6 +189,18 @@
 
   
   
+  1.1 Documentation
+  
+API
+
+X-Ref
+
+Ref Guide (single-page)
+
+  
+
+
+  
   0.94 Documentation
   
 API
@@ -280,10 +292,10 @@
  Warnings
  Errors
 
-2045
+2051
 0
 0
-13916
+13915
 
 Files
 
@@ -466,7 +478,7 @@
 org/apache/hadoop/hbase/MetaTableAccessor.java
 0
 0
-116
+117
 
 org/apache/hadoop/hbase/NamespaceDescriptor.java
 0
@@ -628,335 +640,345 @@
 0
 4
 
+org/apache/hadoop/hbase/client/AsyncClientScanner.java
+0
+0
+2
+
 org/apache/hadoop/hbase/client/AsyncProcess.java
 0
 0
 9
-
+
 org/apache/hadoop/hbase/client/AsyncRegionLocator.java
 0
 0
 7
-
+
 org/apache/hadoop/hbase/client/AsyncRequestFuture.java
 0
 0
 1
-
+
 org/apache/hadoop/hbase/client/AsyncRequestFutureImpl.java
 0
 0
 22
-
+
 org/apache/hadoop/hbase/client/AsyncSmallScanRpcRetryingCaller.java
 0
 0
 1
-
+
 org/apache/hadoop/hbase/client/AsyncTableImpl.java
 0
 0
 2
-
+
 org/apache/hadoop/hbase/client/BatchErrors.java
 0
 0
 1
-
+
 org/apache/hadoop/hbase/client/BufferedMutator.java
 0
 0
 1
-
+
 org/apache/hadoop/hbase/client/BufferedMutatorImpl.java
 0
 0
 1
-
+
 org/apache/hadoop/hbase/client/CancellableRegionServerCallable.java
 0
 0
 3
-
+
 org/apache/hadoop/hbase/client/ClientAsyncPrefetchScanner.java
 0
 0
 2
-
+
 org/apache/hadoop/hbase/client/ClientIdGenerator.java
 0
 0
 1
-
+
 org/apache/hadoop/hbase/client/ClientScanner.java
 0
 0
 162
-
+
 org/apache/hadoop/hbase/client/ClientServiceCallable.java
 0
 0
 2
-
+
 org/apache/hadoop/hbase/client/ClientSimpleScanner.java
 0
 0
 1
-
+
 org/apache/hadoop/hbase/client/ClientSmallReversedScanner.java
 0
 0
 4
-
+
 org/apache/hadoop/hbase/client/ClientSmallScanner.java
 0
 0
 6
-
+
 org/apache/hadoop/hbase/client/ClusterStatusListener.java
 0
 0
 1
-
+
 org/apache/hadoop/hbase/client/CompactType.java
 0
 0
 2
-
+
 org/apache/hadoop/hbase/client/ConnectionConfiguration.java
 0
 0
 1
-
+
 org/apache/hadoop/hbase/client/ConnectionFactory.java
 0
 0
 1
-
+
 org/apache/hadoop/hbase/client/ConnectionImplementation.java
 0
 0
 3
-
+
 org/apache/hadoop/hbase/client/CoprocessorHConnection.java
 0
 0
 3
-
+
 org/apache/hadoop/hbase/client/DelayingRunner.java
 0
 0
 3
-
+
 org/apache/hadoop/hbase/client/Delete.java
 0
 0
 6
-
+
 org/apache/hadoop/hbase/client/Get.java
 0
 0
 5
-
+
 org/apache/hadoop/hbase/client/HBaseAdmin.java
 0
 0
 75
-
+
 org/apache/hadoop/hbase/client/HRegionLocator.java
 0
 0
 2
-
+
 org/apache/hadoop/hbase/client/HTable.java
 0
 0
 18
-
+
 org/apache/hadoop/hbase/client/HTableInterface.java
 0
 0
 1
-
+
 org/apache/hadoop/hbase/client/HTableMultiplexer.java
 0
 0
 5
-
+
 org/apache/hadoop/hbase/client/HTableWrapper.java
 0
 0
 8
-
+
 org/apache/hadoop/hbase/client/Increment.java
 0
 0
 1
-
+
 org/apache/hadoop/hbase/client/MasterCallable.java
 0
 0
 1
-
+
 org/apache/hadoop/hbase/client/MetaCache.java
 0
 0
 8
-
+
 org/apache/hadoop/hbase/client/MetricsConnection.java
 0
 0
 44
-
+
 org/apache/hadoop/hbase/client/MultiAction.java
 0
 0
 3
-
+
 org/apache/hadoop/hbase/client/MultiResponse.java
 0
 0
 1
-
+
 org/apache/hadoop/hbase/client/MultiServerCallable.java
 0
 0
 7
-
+
 org/apache/hadoop/hbase/client/Mutation.java
 0
 0
 21
-
+
 org/apache/hadoop/hbase/client/Operation.java
 0
 0
 1
-
+
 org/apache/hadoop/hbase/client/PreemptiveFastFailInterceptor.java
 0
 0
 11
-
+
 org/apache/hadoop/hbase/client/Put.java
 0
 0
 15
-
+
 org/apache/hadoop/hbase/client/Query.java
 0
 0
 8
-
+
 org/apache/hadoop/hbase/client/RegionAdminServiceCallable.java
 0
 0
 3
-
+
 org/apache/hadoop/hbase/client/RegionCoprocessorRpcChannel.java
 0
 0
 1
-
+
 org/apache/hadoop/hbase/client/RegionCoprocessorServiceExec.java
 0
 0
 1
-
+
 org/apache/hadoop/hbase/client/RegionReplicaUtil.java
 0
 0
 6
-
+
 org/apache/hadoop/hbase/client/RegionServerCallable.java
 0
 0
 1
-
+
 org/apache/hadoop/hbase/client/Registry.java
 0
 0
 3
-
+
 org/apache/hadoop/hbase/client/RegistryFactory.java
 0
 0
 1
-
+
 org/apache/hadoop/hbase/client/Result.java
 0
 0
 11
-
+
 org/apache/hadoop/hbase/client/ResultBoundedCompletionService.java
 0
 0
 6
-
+
 org/apache/hadoop/hbase/client/ResultScanner.java
 0
 0
 1
-
+
 org/apache/hadoop/hbase/client/RetriesExhaustedException.java
 0
 0
 1
-
+
 org/apache/hadoop/hbase/client/RetriesE

[11/52] [partial] hbase-site git commit: Published site at 8a6d6aa23944bbfd5047cf0c09fb4d8045735dab.

2016-11-11 Thread stack

http://git-wip-us.apache.org/repos/asf/hbase-site/blob/74ea7fbd/devapidocs/org/apache/hadoop/hbase/master/balancer/BaseLoadBalancer.Cluster.html
--
diff --git 
a/devapidocs/org/apache/hadoop/hbase/master/balancer/BaseLoadBalancer.Cluster.html
 
b/devapidocs/org/apache/hadoop/hbase/master/balancer/BaseLoadBalancer.Cluster.html
index e44a3f8..6e77152 100644
--- 
a/devapidocs/org/apache/hadoop/hbase/master/balancer/BaseLoadBalancer.Cluster.html
+++ 
b/devapidocs/org/apache/hadoop/hbase/master/balancer/BaseLoadBalancer.Cluster.html
@@ -113,7 +113,7 @@ var activeTableTab = "activeTableTab";
 
 
 
-protected static class BaseLoadBalancer.Cluster
+protected static class BaseLoadBalancer.Cluster
 extends http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true";
 title="class or interface in java.lang">Object
 An efficient array based implementation similar to 
ClusterState for keeping
  the status of the cluster in terms of region assignment and distribution.
@@ -291,70 +291,66 @@ extends http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?
 regionLoads 
 
 
-(package private) http://docs.oracle.com/javase/8/docs/api/java/util/ArrayList.html?is-external=true";
 title="class or interface in 
java.util">ArrayList>
-regionLocationFutures 
-
-
 (package private) int[][]
 regionLocations 
 
-
+
 (package private) HRegionInfo[]
 regions 
 
-
+
 (package private) int[][]
 regionsPerHost 
 
-
+
 (package private) int[][]
 regionsPerRack 
 
-
+
 (package private) int[][]
 regionsPerServer 
 
-
+
 (package private) http://docs.oracle.com/javase/8/docs/api/java/util/Map.html?is-external=true";
 title="class or interface in java.util">MapInteger>
 regionsToIndex 
 
-
+
 (package private) int[]
 serverIndexToHostIndex 
 
-
+
 (package private) int[]
 serverIndexToRackIndex 
 
-
+
 (package private) http://docs.oracle.com/javase/8/docs/api/java/lang/Integer.html?is-external=true";
 title="class or interface in java.lang">Integer[]
 serverIndicesSortedByLocality 
 
-
+
 (package private) http://docs.oracle.com/javase/8/docs/api/java/lang/Integer.html?is-external=true";
 title="class or interface in java.lang">Integer[]
 serverIndicesSortedByRegionCount 
 
-
+
 (package private) ServerName[]
 servers 
 
-
+
 (package private) int[][]
 serversPerHost 
 
-
+
 (package private) int[][]
 serversPerRack 
 
-
+
 (package private) http://docs.oracle.com/javase/8/docs/api/java/util/Map.html?is-external=true";
 title="class or interface in java.util">MapString,http://docs.oracle.com/javase/8/docs/api/java/lang/Integer.html?is-external=true";
 title="class or interface in java.lang">Integer>
 serversToIndex 
 
-
+
 (package private) http://docs.oracle.com/javase/8/docs/api/java/util/ArrayList.html?is-external=true";
 title="class or interface in java.util">ArrayListString>
 tables 
 
-
+
 (package private) http://docs.oracle.com/javase/8/docs/api/java/util/Map.html?is-external=true";
 title="class or interface in java.util">MapString,http://docs.oracle.com/javase/8/docs/api/java/lang/Integer.html?is-external=true";
 title="class or interface in java.lang">Integer>
 tablesToIndex 
 
@@ -543,7 +539,7 @@ extends http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?
 
 
 servers
-ServerName[] servers
+ServerName[] servers
 
 
 
@@ -552,7 +548,7 @@ extends http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?
 
 
 hosts
-http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
 title="class or interface in java.lang">String[] hosts
+http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
 title="class or interface in java.lang">String[] hosts
 
 
 
@@ -561,7 +557,7 @@ extends http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?
 
 
 racks
-http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
 title="class or interface in java.lang">String[] racks
+http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
 title="class or interface in java.lang">String[] racks
 
 
 
@@ -570,7 +566,7 @@ extends http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?
 
 
 multiServersPerHost
-boolean multiServersPerHost
+boolean multiServersPerHost
 
 
 
@@ -579,7 +575,7 @@ extends http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?

[39/52] [partial] hbase-site git commit: Published site at 8a6d6aa23944bbfd5047cf0c09fb4d8045735dab.

2016-11-11 Thread stack

http://git-wip-us.apache.org/repos/asf/hbase-site/blob/74ea7fbd/devapidocs/index-all.html
--
diff --git a/devapidocs/index-all.html b/devapidocs/index-all.html
index 59549b1..c3c9c76 100644
--- a/devapidocs/index-all.html
+++ b/devapidocs/index-all.html
@@ -348,6 +348,8 @@
 
 AbstractHBaseTool()
 - Constructor for class org.apache.hadoop.hbase.util.AbstractHBaseTool
  
+AbstractHBaseTool.OptionsOrderComparator - 
Class in org.apache.hadoop.hbase.util
+ 
 AbstractMemStore - Class in org.apache.hadoop.hbase.regionserver
 
 An abstract class, which implements the behaviour shared by 
all concrete memstore instances.
@@ -1124,6 +1126,14 @@
  
 addAllTables(Collection)
 - Method in class org.apache.hadoop.hbase.rsgroup.RSGroupInfo
  
+addAndGet(Result[],
 boolean) - Method in class org.apache.hadoop.hbase.client.AllowPartialScanResultCache
+ 
+addAndGet(Result[],
 boolean) - Method in class org.apache.hadoop.hbase.client.CompleteScanResultCache
+ 
+addAndGet(Result[],
 boolean) - Method in interface org.apache.hadoop.hbase.client.ScanResultCache
+
+Add the given results to cache and get valid results 
back.
+
 addAndGetMemstoreSize(MemstoreSize)
 - Method in class org.apache.hadoop.hbase.regionserver.HRegion
 
 Increase the size of mem store in this region and the size 
of global mem
@@ -1824,6 +1834,8 @@
  
 addOptions()
 - Method in class org.apache.hadoop.hbase.snapshot.CreateSnapshot
  
+addOptions()
 - Method in class org.apache.hadoop.hbase.snapshot.ExportSnapshot
+ 
 addOptions()
 - Method in class org.apache.hadoop.hbase.util.AbstractHBaseTool
 
 Override this to add command-line options using AbstractHBaseTool.addOptWithArg(java.lang.String,
 java.lang.String)
@@ -2026,6 +2038,8 @@
 Create any replicas for the regions (the default replicas 
that was
  already created is passed to the method)
 
+addRequiredOption(Option)
 - Method in class org.apache.hadoop.hbase.util.AbstractHBaseTool
+ 
 addRequiredOptWithArg(String,
 String) - Method in class org.apache.hadoop.hbase.util.AbstractHBaseTool
  
 addRequiredOptWithArg(String,
 String, String) - Method in class org.apache.hadoop.hbase.util.AbstractHBaseTool
@@ -2580,6 +2594,12 @@
 
 Partial Results are Results must be combined to 
form a complete Result.
 
+AllowPartialScanResultCache - Class in org.apache.hadoop.hbase.client
+
+A ScanResultCache that may return partial result.
+
+AllowPartialScanResultCache()
 - Constructor for class org.apache.hadoop.hbase.client.AllowPartialScanResultCache
+ 
 allPeersHavePosition(Set,
 Map) - Method in class 
org.apache.hadoop.hbase.master.cleaner.ReplicationMetaCleaner
  
 allRegions
 - Variable in class org.apache.hadoop.hbase.tool.Canary.RegionServerMonitor
@@ -2781,6 +2801,8 @@
  
 APPEND_TIME_DESC
 - Static variable in interface org.apache.hadoop.hbase.regionserver.wal.MetricsWALSource
  
+appendAndSync()
 - Method in class org.apache.hadoop.hbase.regionserver.wal.AsyncFSWAL
+ 
 appendCount
 - Variable in class org.apache.hadoop.hbase.regionserver.wal.MetricsWALSourceImpl
  
 appendCurrentNonces(Mutation,
 boolean, WALEdit, long, long, long) - Method in class 
org.apache.hadoop.hbase.regionserver.HRegion
@@ -2797,10 +2819,6 @@
 
 appendEntry(WAL.Entry)
 - Method in class org.apache.hadoop.hbase.wal.WALSplitter.RegionEntryBuffer
  
-appendExecutor
 - Variable in class org.apache.hadoop.hbase.regionserver.wal.FSHLog
-
-An executorservice that runs the disruptor 
AppendEventHandler append executor.
-
 appendFileInfo(byte[],
 byte[]) - Method in interface org.apache.hadoop.hbase.io.hfile.HFile.Writer
 
 Add an element to the file info map.
@@ -3463,7 +3481,13 @@
  
 ASYNC_WAL_CREATE_MAX_RETRIES
 - Static variable in class org.apache.hadoop.hbase.regionserver.wal.AsyncFSWAL
  
-ASYNC_WAL_LOG_ROLLER_EXITED_CHECK_INTERVAL_MS
 - Static variable in class org.apache.hadoop.hbase.regionserver.wal.AsyncFSWAL
+AsyncClientScanner - Class in org.apache.hadoop.hbase.client
+
+The asynchronous client scanner implementation.
+
+AsyncClientScanner(Scan,
 ScanResultConsumer, TableName, AsyncConnectionImpl, long, long) - 
Constructor for class org.apache.hadoop.hbase.client.AsyncClientScanner
+ 
+AsyncClientScanner.OpenScannerResponse - Class 
in org.apache.hadoop.hbase.client
  
 AsyncConnection - Interface in org.apache.hadoop.hbase.client
 
@@ -3509,12 +3533,6 @@
 
 AsyncFSWAL(FileSystem,
 Path, String, String, Configuration, List, boolean, 
String, String, EventLoop) - Constructor for class 
org.apache.hadoop.hbase.regionserver.wal.AsyncFSWAL
  
-AsyncFSWAL.LogRollerExitedChecker - Class in org.apache.hadoop.hbase.regionserver.wal
- 
-AsyncFSWAL.Payload - Class in org.apache.hadoop.hbase.regionserver.wal
-
-Carry things that we want to pass to the consume task in 
event loop.
-
 AsyncFSWALProvider - Class in org.apache.hadoop.hbase.wal
 
 A WAL provider that use AsyncFSWAL.
@@ -3581,6 +3599,12 @@
 
 Implementat

[14/52] [partial] hbase-site git commit: Published site at 8a6d6aa23944bbfd5047cf0c09fb4d8045735dab.

2016-11-11 Thread stack

http://git-wip-us.apache.org/repos/asf/hbase-site/blob/74ea7fbd/devapidocs/org/apache/hadoop/hbase/ipc/class-use/HBaseRpcController.html
--
diff --git 
a/devapidocs/org/apache/hadoop/hbase/ipc/class-use/HBaseRpcController.html 
b/devapidocs/org/apache/hadoop/hbase/ipc/class-use/HBaseRpcController.html
index b206102..cb66016 100644
--- a/devapidocs/org/apache/hadoop/hbase/ipc/class-use/HBaseRpcController.html
+++ b/devapidocs/org/apache/hadoop/hbase/ipc/class-use/HBaseRpcController.html
@@ -128,10 +128,14 @@
 
 
 private HBaseRpcController
-RegionAdminServiceCallable.controller 
+AsyncScanSingleRegionRpcRetryingCaller.controller 
 
 
 private HBaseRpcController
+RegionAdminServiceCallable.controller 
+
+
+private HBaseRpcController
 MasterCallable.rpcController 
 
 
@@ -194,6 +198,12 @@
 AsyncTableImpl.Converter respConverter) 
 
 
+private http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/CompletableFuture.html?is-external=true";
 title="class or interface in java.util.concurrent">CompletableFuture
+AsyncClientScanner.callOpenScanner(HBaseRpcController controller,
+   HRegionLocation loc,
+   
org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ClientService.Interface stub) 
+
+
 private static  http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/CompletableFuture.html?is-external=true";
 title="class or interface in 
java.util.concurrent">CompletableFuture
 AsyncTableImpl.mutate(HBaseRpcController controller,
   HRegionLocation loc,
@@ -202,7 +212,7 @@
   AsyncTableImpl.Converter reqConvert,
   AsyncTableImpl.Converter respConverter) 
 
-
+
 private static  http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/CompletableFuture.html?is-external=true";
 title="class or interface in 
java.util.concurrent">CompletableFuture
 AsyncTableImpl.mutateRow(HBaseRpcController controller,
  HRegionLocation loc,
@@ -211,7 +221,7 @@
  AsyncTableImpl.Converter reqConvert,
  http://docs.oracle.com/javase/8/docs/api/java/util/function/Function.html?is-external=true";
 title="class or interface in java.util.function">Function respConverter) 
 
-
+
 private  http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/CompletableFuture.html?is-external=true";
 title="class or interface in 
java.util.concurrent">CompletableFuture
 AsyncTableImpl.noncedMutate(HBaseRpcController controller,
 HRegionLocation loc,
@@ -220,6 +230,11 @@
 AsyncTableImpl.NoncedConverter reqConvert,
 AsyncTableImpl.Converter respConverter) 
 
+
+(package private) static void
+ConnectionUtils.resetController(HBaseRpcController controller,
+   long timeoutNs) 
+
 
 private http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/CompletableFuture.html?is-external=true";
 title="class or interface in java.util.concurrent">CompletableFuture
 AsyncSmallScanRpcRetryingCaller.scan(HBaseRpcController controller,

http://git-wip-us.apache.org/repos/asf/hbase-site/blob/74ea7fbd/devapidocs/org/apache/hadoop/hbase/ipc/package-tree.html
--
diff --git a/devapidocs/org/apache/hadoop/hbase/ipc/package-tree.html 
b/devapidocs/org/apache/hadoop/hbase/ipc/package-tree.html
index 4c66f15..6eeb9db 100644
--- a/devapidocs/org/apache/hadoop/hbase/ipc/package-tree.html
+++ b/devapidocs/org/apache/hadoop/hbase/ipc/package-tree.html
@@ -295,9 +295,9 @@
 
 java.lang.http://docs.oracle.com/javase/8/docs/api/java/lang/Enum.html?is-external=true";
 title="class or interface in java.lang">Enum (implements java.lang.http://docs.oracle.com/javase/8/docs/api/java/lang/Comparable.html?is-external=true";
 title="class or interface in java.lang">Comparable, java.io.http://docs.oracle.com/javase/8/docs/api/java/io/Serializable.html?is-external=true";
 title="class or interface in java.io">Serializable)
 
-org.apache.hadoop.hbase.ipc.CallEvent.Type
-org.apache.hadoop.hbase.ipc.BufferCallBeforeInitHandler.BufferCallAction
 org.apache.hadoop.hbase.ipc.MetricsHBaseServerSourceFactoryImpl.SourceStorage
+org.apache.hadoop.hbase.ipc.BufferCallBeforeInitHandler.BufferCallAction
+org.apache.hadoop.hbase.ipc.CallEvent.Type
 
 
 

http://git-wip-us.apache.

[27/52] [partial] hbase-site git commit: Published site at 8a6d6aa23944bbfd5047cf0c09fb4d8045735dab.

2016-11-11 Thread stack

http://git-wip-us.apache.org/repos/asf/hbase-site/blob/74ea7fbd/devapidocs/org/apache/hadoop/hbase/client/AsyncTableImpl.html
--
diff --git a/devapidocs/org/apache/hadoop/hbase/client/AsyncTableImpl.html 
b/devapidocs/org/apache/hadoop/hbase/client/AsyncTableImpl.html
index 2701080..8272d4b 100644
--- a/devapidocs/org/apache/hadoop/hbase/client/AsyncTableImpl.html
+++ b/devapidocs/org/apache/hadoop/hbase/client/AsyncTableImpl.html
@@ -18,7 +18,7 @@
 catch(err) {
 }
 //-->
-var methods = 
{"i0":10,"i1":9,"i2":10,"i3":10,"i4":10,"i5":10,"i6":10,"i7":10,"i8":10,"i9":10,"i10":10,"i11":10,"i12":10,"i13":10,"i14":9,"i15":9,"i16":10,"i17":10,"i18":10,"i19":10,"i20":10,"i21":10,"i22":10,"i23":10,"i24":10,"i25":10,"i26":9,"i27":9};
+var methods = 
{"i0":10,"i1":9,"i2":10,"i3":10,"i4":10,"i5":10,"i6":10,"i7":10,"i8":10,"i9":10,"i10":10,"i11":10,"i12":10,"i13":10,"i14":10,"i15":9,"i16":9,"i17":10,"i18":10,"i19":10,"i20":10,"i21":10,"i22":10,"i23":10,"i24":10,"i25":10,"i26":10,"i27":10,"i28":10,"i29":9,"i30":9};
 var tabs = {65535:["t0","All Methods"],1:["t1","Static 
Methods"],2:["t2","Instance Methods"],8:["t4","Concrete Methods"]};
 var altColor = "altColor";
 var rowColor = "rowColor";
@@ -114,7 +114,7 @@ var activeTableTab = "activeTableTab";
 
 
 @InterfaceAudience.Private
-class AsyncTableImpl
+class AsyncTableImpl
 extends http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true";
 title="class or interface in java.lang">Object
 implements AsyncTable
 The implementation of AsyncTable.
@@ -176,22 +176,26 @@ implements defaultScannerMaxResultSize 
 
 
+private static 
org.apache.commons.logging.Log
+LOG 
+
+
 private long
 operationTimeoutNs 
 
-
+
 private long
 readRpcTimeoutNs 
 
-
+
 private long
 scanTimeoutNs 
 
-
+
 private TableName
 tableName 
 
-
+
 private long
 writeRpcTimeoutNs 
 
@@ -319,17 +323,23 @@ implements 
 long
+getScanTimeout(http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/TimeUnit.html?is-external=true";
 title="class or interface in 
java.util.concurrent">TimeUnit unit)
+Get the timeout of a single operation in a scan.
+
+
+
+long
 getWriteRpcTimeout(http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/TimeUnit.html?is-external=true";
 title="class or interface in 
java.util.concurrent">TimeUnit unit)
 Get timeout of each rpc write request in this Table 
instance.
 
 
-
+
 http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/CompletableFuture.html?is-external=true";
 title="class or interface in java.util.concurrent">CompletableFuture
 increment(Increment increment)
 Increments one or more columns within a single row.
 
 
-
+
 private static  http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/CompletableFuture.html?is-external=true";
 title="class or interface in 
java.util.concurrent">CompletableFuture
 mutate(HBaseRpcController controller,
   HRegionLocation loc,
@@ -338,7 +348,7 @@ implements AsyncTableImpl.Converter reqConvert,
   AsyncTableImpl.Converter respConverter) 
 
-
+
 private static  http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/CompletableFuture.html?is-external=true";
 title="class or interface in 
java.util.concurrent">CompletableFuture
 mutateRow(HBaseRpcController controller,
  HRegionLocation loc,
@@ -347,23 +357,23 @@ implements AsyncTableImpl.Converter reqConvert,
  http://docs.oracle.com/javase/8/docs/api/java/util/function/Function.html?is-external=true";
 title="class or interface in java.util.function">Function respConverter) 
 
-
+
 http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/CompletableFuture.html?is-external=true";
 title="class or interface in java.util.concurrent">CompletableFutureVoid>
 mutateRow(RowMutations mutation)
 Performs multiple mutations atomically on a single 
row.
 
 
-
+
 private  AsyncRpcRetryingCallerFactory.SingleRequestCallerBuilder
 newCaller(byte[] row,
  long rpcTimeoutNs) 
 
-
+
 private  AsyncRpcRetryingCallerFactory.SingleRequestCallerBuilder
 newCaller(Row row,
  long rpcTimeoutNs) 
 
-
+
 private  http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/CompletableFuture.html?is-external=true";
 title="class or interface in 
java.util.concurrent">CompletableFuture
 noncedMutate(HBaseRpcController controller,
 HRegionLocation loc,
@@ -372,17 +382,24 @@ implements AsyncTableImpl.NoncedConverter

[49/52] [partial] hbase-site git commit: Published site at 8a6d6aa23944bbfd5047cf0c09fb4d8045735dab.

2016-11-11 Thread stack

http://git-wip-us.apache.org/repos/asf/hbase-site/blob/74ea7fbd/apidocs/org/apache/hadoop/hbase/HConstants.html
--
diff --git a/apidocs/org/apache/hadoop/hbase/HConstants.html 
b/apidocs/org/apache/hadoop/hbase/HConstants.html
index 0454504..b34d5f6 100644
--- a/apidocs/org/apache/hadoop/hbase/HConstants.html
+++ b/apidocs/org/apache/hadoop/hbase/HConstants.html
@@ -1496,14 +1496,26 @@ extends http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?
 
 
 static byte[]
+REPLICATION_META_FAMILY
+The replication meta family
+
+
+
+static http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
 title="class or interface in java.lang">String
+REPLICATION_META_FAMILY_STR
+The replication meta family as a string
+
+
+
+static byte[]
 REPLICATION_POSITION_FAMILY
-The replication barrier family
+The replication position family
 
 
 
 static http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
 title="class or interface in java.lang">String
 REPLICATION_POSITION_FAMILY_STR
-The replication barrier family as a string
+The replication position family as a string
 
 
 
@@ -3278,7 +3290,7 @@ public static final byte[] 
 REPLICATION_POSITION_FAMILY_STR
 public static final http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
 title="class or interface in java.lang">String REPLICATION_POSITION_FAMILY_STR
-The replication barrier family as a string
+The replication position family as a string
 
 See Also:
 Constant
 Field Values
@@ -3292,7 +3304,31 @@ public static final byte[] 
 REPLICATION_POSITION_FAMILY
 public static final byte[] REPLICATION_POSITION_FAMILY
-The replication barrier family
+The replication position family
+
+
+
+
+
+
+
+REPLICATION_META_FAMILY_STR
+public static final http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
 title="class or interface in java.lang">String REPLICATION_META_FAMILY_STR
+The replication meta family as a string
+
+See Also:
+Constant
 Field Values
+
+
+
+
+
+
+
+
+REPLICATION_META_FAMILY
+public static final byte[] REPLICATION_META_FAMILY
+The replication meta family
 
 
 
@@ -3301,7 +3337,7 @@ public static final byte[] 
 
 REGIONINFO_QUALIFIER_STR
-public static final http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
 title="class or interface in java.lang">String REGIONINFO_QUALIFIER_STR
+public static final http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
 title="class or interface in java.lang">String REGIONINFO_QUALIFIER_STR
 The RegionInfo qualifier as a string
 
 See Also:
@@ -3315,7 +3351,7 @@ public static final byte[] 
 
 REGIONINFO_QUALIFIER
-public static final byte[] REGIONINFO_QUALIFIER
+public static final byte[] REGIONINFO_QUALIFIER
 The regioninfo column qualifier
 
 
@@ -3325,7 +3361,7 @@ public static final byte[] 
 
 SERVER_QUALIFIER_STR
-public static final http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
 title="class or interface in java.lang">String SERVER_QUALIFIER_STR
+public static final http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
 title="class or interface in java.lang">String SERVER_QUALIFIER_STR
 The server column qualifier
 
 See Also:
@@ -3339,7 +3375,7 @@ public static final byte[] 
 
 SERVER_QUALIFIER
-public static final byte[] SERVER_QUALIFIER
+public static final byte[] SERVER_QUALIFIER
 The server column qualifier
 
 
@@ -3349,7 +3385,7 @@ public static final byte[] 
 
 STARTCODE_QUALIFIER_STR
-public static final http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
 title="class or interface in java.lang">String STARTCODE_QUALIFIER_STR
+public static final http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
 title="class or interface in java.lang">String STARTCODE_QUALIFIER_STR
 The startcode column qualifier
 
 See Also:
@@ -3363,7 +3399,7 @@ public static final byte[] 
 
 STARTCODE_QUALIFIER
-public static final byte[] STARTCODE_QUALIFIER
+public static final byte[] STARTCODE_QUALIFIER
 The startcode column qualifier
 
 
@@ -3373,7 +3409,7 @@ public static final byte[] 
 
 SEQNUM_QUALIFIER_STR
-public static final http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
 title="class or interface in java.lang">String SEQNUM_QUALIFIER_STR
+public static final http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
 title="class or interface in java.lang">String SEQNUM_QUALIFIER_STR
 The open seqnum column qualifier
 
 See Also:
@@ -3387,7 +3423,7 @@ public static final byte[] 
 
 SEQNUM_QUALIFIER
-public static final byte[] SEQNUM_QUALIFIER
+public static final byte[] SEQNUM_QUALIFIER
 The open seqnum column qualifier
 
 
@@ -3397,7 +3433,7 @@ public static final byte[] 
 
 STATE_QUALIFIER_STR
-public static fina

[16/52] [partial] hbase-site git commit: Published site at 8a6d6aa23944bbfd5047cf0c09fb4d8045735dab.

2016-11-11 Thread stack

http://git-wip-us.apache.org/repos/asf/hbase-site/blob/74ea7fbd/devapidocs/org/apache/hadoop/hbase/coprocessor/class-use/ObserverContext.html
--
diff --git 
a/devapidocs/org/apache/hadoop/hbase/coprocessor/class-use/ObserverContext.html 
b/devapidocs/org/apache/hadoop/hbase/coprocessor/class-use/ObserverContext.html
index e86f066..27b8978 100644
--- 
a/devapidocs/org/apache/hadoop/hbase/coprocessor/class-use/ObserverContext.html
+++ 
b/devapidocs/org/apache/hadoop/hbase/coprocessor/class-use/ObserverContext.html
@@ -2737,8 +2737,8 @@
  InternalScanner s)
 Deprecated. 
 Use
- RegionObserver.preCompactScannerOpen(ObserverContext,
 Store, List, ScanType, long,
- InternalScanner, CompactionRequest) 
instead.
+ RegionObserver.preCompactScannerOpen(ObserverContext,
 Store, List, ScanType, long,
+ InternalScanner, CompactionRequest, long) 
instead.
 
 
 
@@ -2760,8 +2760,10 @@
  long earliestPutTs,
  InternalScanner s,
  CompactionRequest request)
-Called prior to writing the StoreFiles selected for 
compaction into a new
- StoreFile and prior to creating the scanner used to read the 
input files.
+Deprecated. 
+Use RegionObserver.preCompactScannerOpen(ObserverContext,
 Store, List, ScanType, long,
+ InternalScanner, CompactionRequest, long) 
instead.
+
 
 
 
@@ -2775,6 +2777,31 @@
  CompactionRequest request) 
 
 
+InternalScanner
+RegionObserver.preCompactScannerOpen(ObserverContext c,
+ Store store,
+ http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true";
 title="class or interface in java.util">List scanners,
+ ScanType scanType,
+ long earliestPutTs,
+ InternalScanner s,
+ CompactionRequest request,
+ long readPoint)
+Called prior to writing the StoreFiles selected for 
compaction into a new
+ StoreFile and prior to creating the scanner used to read the 
input files.
+
+
+
+InternalScanner
+BaseRegionObserver.preCompactScannerOpen(ObserverContext c,
+ Store store,
+ http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true";
 title="class or interface in java.util">List scanners,
+ ScanType scanType,
+ long earliestPutTs,
+ InternalScanner s,
+ CompactionRequest request,
+ long readPoint) 
+
+
 void
 RegionObserver.preCompactSelection(ObserverContext c,
Store store,
@@ -3322,8 +3349,10 @@
Store store,
KeyValueScanner memstoreScanner,
InternalScanner s)
-Called before a memstore is flushed to disk and prior to 
creating the scanner to read from
- the memstore.
+Deprecated. 
+Use RegionObserver.preFlushScannerOpen(ObserverContext,
 Store, KeyValueScanner,
+ InternalScanner, long)
+
 
 
 
@@ -3334,6 +3363,25 @@
InternalScanner s) 
 
 
+InternalScanner
+RegionObserver.preFlushScannerOpen(ObserverContext c,
+   Store store,
+   KeyValueScanner memstoreScanner,
+   InternalScanner s,
+   long readPoint)
+Called before a memstore is flushed to disk and prior to 
creating the scanner to read from
+ the memstore.
+
+
+
+InternalScanner
+BaseRegionObserver.preFlushScannerOpen(ObserverContext c,
+   Store store,
+   KeyValueScanner memstoreScanner,
+   InternalScanner s,
+   long readPoint) 
+
+
 void
 MasterObserver.preGetNamespaceDescriptor(ObserverContext ctx,
  http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
 title="class or interface in java.lang">String namespace)

http://git-wip-us.apache.org/repos/asf/hbase-site/blob/74ea7fbd/devapidocs/org/apache/hadoop/hbase/coprocessor/class-use/RegionCoprocessorEnvironment.html
--
diff --git 
a/devapidocs/org/apache/hadoop/hbase/coprocessor/class-use/RegionCoprocessorEnvironment.html
 
b/devapidocs/org/apache/hadoop/hbase/coprocessor/class-use/RegionCoprocessorEnvironment.html
index e094646..d2b6c52 100644
--- 
a/devapidocs/org/apache/hadoop/hbase/coprocessor/class-use/RegionCoprocessorEnvironment.html
+++ 
b/devapidocs/org/apache/hadoop/hbase/coprocessor/class-use/RegionCoprocessorEnvironment.html
@@ -980,8 +980,8 @@
  Int

[09/52] [partial] hbase-site git commit: Published site at 8a6d6aa23944bbfd5047cf0c09fb4d8045735dab.

2016-11-11 Thread stack

http://git-wip-us.apache.org/repos/asf/hbase-site/blob/74ea7fbd/devapidocs/org/apache/hadoop/hbase/master/balancer/SimpleLoadBalancer.html
--
diff --git 
a/devapidocs/org/apache/hadoop/hbase/master/balancer/SimpleLoadBalancer.html 
b/devapidocs/org/apache/hadoop/hbase/master/balancer/SimpleLoadBalancer.html
index cf2d525..9ec0b3d 100644
--- a/devapidocs/org/apache/hadoop/hbase/master/balancer/SimpleLoadBalancer.html
+++ b/devapidocs/org/apache/hadoop/hbase/master/balancer/SimpleLoadBalancer.html
@@ -270,7 +270,7 @@ extends BaseLoadBalancer
-areSomeRegionReplicasColocated,
 assignMasterRegions,
 balanceMasterRegions,
 createCluster,
 getConf,
 getRegionAssignmentsByServer, getTablesOnMaster,
 initialize,
 isStopped,
 needsBalance,
 onConfigurationChange,
 randomAssignment,
 regionOffline,
 regionOnline,
 retainAssignment,
 roundRobinAssignment,
 setClusterStatus,
 setConf,
 setMasterServices,
 setRackManager,
 setSlop,
 shouldBeOnMaster,
 stop,
 tablesOnMaster,
 userTablesOnMaster
+areSomeRegionReplicasColocated,
 assignMasterRegions,
 balanceMasterRegions,
 createCluster,
 getConf,
 getRegionAssignmentsBy
 Server, getTablesOnMaster,
 initialize,
 isStopped,
 needsBalance,
 onConfigurationChange,
 randomAssignment,
 regionOffline,
 regionOnline,
 retainAssignment,
 roundRobinAssignment,
 setClusterStatus,
 setConf,
 setMasterServices,
 setRackManager,
 setSlop,
 shouldBeOnMaster,
 stop,
 tablesOnMaster,
 userTablesOnMaster
 
 
 
@@ -455,7 +455,7 @@ extends 
 
 addRegionPlan
-private void addRegionPlan(com.google.common.collect.MinMaxPriorityQueue regionsToMove,
+private void addRegionPlan(com.google.common.collect.MinMaxPriorityQueue regionsToMove,
boolean fetchFromTail,
ServerName sn,
http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true";
 title="class or interface in java.util">List regionsToReturn)
@@ -468,7 +468,7 @@ extends 
 
 balanceCluster
-public http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true";
 title="class or interface in java.util">List balanceCluster(TableName tableName,
+public http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true";
 title="class or interface in java.util">List balanceCluster(TableName tableName,
http://docs.oracle.com/javase/8/docs/api/java/util/Map.html?is-external=true";
 title="class or interface in java.util">MapList> clusterState)
 throws HBaseIOException
 Description copied from 
interface: LoadBalancer

http://git-wip-us.apache.org/repos/asf/hbase-site/blob/74ea7fbd/devapidocs/org/apache/hadoop/hbase/master/balancer/StochasticLoadBalancer.html
--
diff --git 
a/devapidocs/org/apache/hadoop/hbase/master/balancer/StochasticLoadBalancer.html
 
b/devapidocs/org/apache/hadoop/hbase/master/balancer/StochasticLoadBalancer.html
index da26cee..67302a8 100644
--- 
a/devapidocs/org/apache/hadoop/hbase/master/balancer/StochasticLoadBalancer.html
+++ 
b/devapidocs/org/apache/hadoop/hbase/master/balancer/StochasticLoadBalancer.html
@@ -590,7 +590,7 @@ extends BaseLoadBalancer
-assignMasterRegions,
 balanceMasterRegions,
 createCluster,
 getConf,
 getRegionAssignmentsByServer,
 getTablesOnMaster,
 initialize, isStopped,
 randomAssignment,
 regionOffline,
 regionOnline,
 retainAssignment,
 roundRobinAssignment, setRackManager,
 shouldBeOnMaster,
 stop,
 tablesOnMaster,
 userTablesOnMaster
+assignMasterRegions,
 balanceMasterRegions,
 createCluster,
 getConf,
 getRegionAssignmentsByServer,
 getTablesOnMaster,
 initialize, 
isStopped,
 randomAssignment,
 regionOffline,
 regionOnline,
 retainAssignment,
 roundRobinAssignment, setRackManager,
 shouldBeOnMaster,
 stop,
 tablesOnMaster,
 userTablesOnMaster
 
 
 

http://git-wip-us.apache.org/repos/asf/hbase-site/blob/74ea7fbd/devapidocs/org/apache/hadoop/hbase/master/balancer/class-use/BaseLoadBalancer.Cluster.html
--
diff --git 
a/devapidocs/org/apache/hadoop/hbase/master/balancer/class-use/BaseLoadBalancer.Cluster.html
 
b/devapidocs/org/apache/hadoop/hbase/master/balancer/class-use/BaseLoadBalancer.Cluster.html
index a3c8b24..06dfd38 100644
--- 
a/devapidocs/org/apache/hadoop/hbase/master/balancer/class-use/BaseLoadBalancer.Cluster.html
+++ 
b/devapidocs/org/apache/hadoop/hbase/master/balancer/class-use/BaseLoadBalancer.Cluster.html
@@ -117,8 +117,9 @@
 
 
 protected BaseLoadBalancer.Cluster
-BaseLoadBalancer.createCluster(http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true";
 ti

hbase git commit: HBASE-17062 RegionSplitter throws ClassCastException (Jeongdae Kim)

2016-11-11 Thread tedyu

Repository: hbase
Updated Branches:
  refs/heads/branch-1 44ab659b9 -> 469462c85


HBASE-17062 RegionSplitter throws ClassCastException (Jeongdae Kim)


Project: http://git-wip-us.apache.org/repos/asf/hbase/repo
Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/469462c8
Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/469462c8
Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/469462c8

Branch: refs/heads/branch-1
Commit: 469462c850daa30b13780774c92d5c1180cd83ed
Parents: 44ab659
Author: tedyu 
Authored: Fri Nov 11 07:18:22 2016 -0800
Committer: tedyu 
Committed: Fri Nov 11 07:18:22 2016 -0800

--
 .../hadoop/hbase/util/RegionSplitter.java   | 25 +++-
 1 file changed, 9 insertions(+), 16 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/hbase/blob/469462c8/hbase-server/src/main/java/org/apache/hadoop/hbase/util/RegionSplitter.java
--
diff --git 
a/hbase-server/src/main/java/org/apache/hadoop/hbase/util/RegionSplitter.java 
b/hbase-server/src/main/java/org/apache/hadoop/hbase/util/RegionSplitter.java
index ea704f8..a5dcaa5 100644
--- 
a/hbase-server/src/main/java/org/apache/hadoop/hbase/util/RegionSplitter.java
+++ 
b/hbase-server/src/main/java/org/apache/hadoop/hbase/util/RegionSplitter.java
@@ -20,15 +20,14 @@ package org.apache.hadoop.hbase.util;
 
 import java.io.IOException;
 import java.math.BigInteger;
+
 import java.util.Arrays;
 import java.util.Collection;
-import java.util.Collections;
-import java.util.Comparator;
 import java.util.LinkedList;
 import java.util.List;
+import java.util.Map;
 import java.util.Set;
 import java.util.TreeMap;
-
 import org.apache.commons.cli.CommandLine;
 import org.apache.commons.cli.GnuParser;
 import org.apache.commons.cli.HelpFormatter;
@@ -458,12 +457,12 @@ public class RegionSplitter {
   // requests to the same RS can stall the outstanding split queue.
   // To fix, group the regions into an RS pool and round-robin through it
   LOG.debug("Bucketing regions by regionserver...");
-  TreeMap>> daughterRegions =
+  TreeMap>> daughterRegions =
   Maps.newTreeMap();
   // Get a regionLocator.  Need it in below.
   try (RegionLocator regionLocator = 
connection.getRegionLocator(tableName)) {
 for (Pair dr : tmpRegionSet) {
-  String rsLocation = 
regionLocator.getRegionLocation(dr.getSecond()).getHostnamePort();
+  ServerName rsLocation = 
regionLocator.getRegionLocation(dr.getSecond()).getServerName();
   if (!daughterRegions.containsKey(rsLocation)) {
 LinkedList> entry = Lists.newLinkedList();
 daughterRegions.put(rsLocation, entry);
@@ -497,22 +496,16 @@ public class RegionSplitter {
 }
   }
 
-  // Sort the ServerNames by the number of regions they have
-  List serversLeft = Lists.newArrayList(daughterRegions 
.keySet());
-  Collections.sort(serversLeft, new Comparator() {
-public int compare(String o1, String o2) {
-  return rsSizes.get(o1).compareTo(rsSizes.get(o2));
-}
-  });
-
   // Round-robin through the ServerName list. Choose the 
lightest-loaded servers
   // first to keep the master from load-balancing regions as we 
split.
-  for (String rsLoc : serversLeft) {
+  for (Map.Entry>> 
daughterRegion :
+  daughterRegions.entrySet()) {
 Pair dr = null;
+ServerName rsLoc = daughterRegion.getKey();
+LinkedList> regionList = 
daughterRegion.getValue();
 
 // Find a region in the ServerName list that hasn't been moved
 LOG.debug("Finding a region on " + rsLoc);
-LinkedList> regionList = 
daughterRegions.get(rsLoc);
 while (!regionList.isEmpty()) {
   dr = regionList.pop();
 
@@ -521,7 +514,7 @@ public class RegionSplitter {
   HRegionLocation regionLoc = 
regionLocator.getRegionLocation(split);
 
   // if this region moved locations
-  String newRs = regionLoc.getHostnamePort();
+  ServerName newRs = regionLoc.getServerName();
   if (newRs.compareTo(rsLoc) != 0) {
 LOG.debug("Region with " + splitAlgo.rowToStr(split)
 + " moved to " + newRs + ". Relocating...");

hbase git commit: HBASE-17062 RegionSplitter throws ClassCastException (Jeongdae Kim)

2016-11-11 Thread tedyu

Repository: hbase
Updated Branches:
  refs/heads/master 81623a353 -> 5e91b45b1


HBASE-17062 RegionSplitter throws ClassCastException (Jeongdae Kim)


Project: http://git-wip-us.apache.org/repos/asf/hbase/repo
Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/5e91b45b
Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/5e91b45b
Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/5e91b45b

Branch: refs/heads/master
Commit: 5e91b45b166cd5a68457234f0a62ca1c2b5d9211
Parents: 81623a3
Author: tedyu 
Authored: Fri Nov 11 07:15:03 2016 -0800
Committer: tedyu 
Committed: Fri Nov 11 07:15:03 2016 -0800

--
 .../hadoop/hbase/util/RegionSplitter.java   | 25 +++-
 1 file changed, 9 insertions(+), 16 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/hbase/blob/5e91b45b/hbase-server/src/main/java/org/apache/hadoop/hbase/util/RegionSplitter.java
--
diff --git 
a/hbase-server/src/main/java/org/apache/hadoop/hbase/util/RegionSplitter.java 
b/hbase-server/src/main/java/org/apache/hadoop/hbase/util/RegionSplitter.java
index a6f70c3..ce1b441 100644
--- 
a/hbase-server/src/main/java/org/apache/hadoop/hbase/util/RegionSplitter.java
+++ 
b/hbase-server/src/main/java/org/apache/hadoop/hbase/util/RegionSplitter.java
@@ -20,15 +20,14 @@ package org.apache.hadoop.hbase.util;
 
 import java.io.IOException;
 import java.math.BigInteger;
+
 import java.util.Arrays;
 import java.util.Collection;
-import java.util.Collections;
-import java.util.Comparator;
 import java.util.LinkedList;
 import java.util.List;
+import java.util.Map;
 import java.util.Set;
 import java.util.TreeMap;
-
 import org.apache.commons.cli.CommandLine;
 import org.apache.commons.cli.GnuParser;
 import org.apache.commons.cli.HelpFormatter;
@@ -458,12 +457,12 @@ public class RegionSplitter {
   // requests to the same RS can stall the outstanding split queue.
   // To fix, group the regions into an RS pool and round-robin through it
   LOG.debug("Bucketing regions by regionserver...");
-  TreeMap>> daughterRegions =
+  TreeMap>> daughterRegions =
   Maps.newTreeMap();
   // Get a regionLocator.  Need it in below.
   try (RegionLocator regionLocator = 
connection.getRegionLocator(tableName)) {
 for (Pair dr : tmpRegionSet) {
-  String rsLocation = 
regionLocator.getRegionLocation(dr.getSecond()).getHostnamePort();
+  ServerName rsLocation = 
regionLocator.getRegionLocation(dr.getSecond()).getServerName();
   if (!daughterRegions.containsKey(rsLocation)) {
 LinkedList> entry = Lists.newLinkedList();
 daughterRegions.put(rsLocation, entry);
@@ -497,22 +496,16 @@ public class RegionSplitter {
 }
   }
 
-  // Sort the ServerNames by the number of regions they have
-  List serversLeft = Lists.newArrayList(daughterRegions 
.keySet());
-  Collections.sort(serversLeft, new Comparator() {
-public int compare(String o1, String o2) {
-  return rsSizes.get(o1).compareTo(rsSizes.get(o2));
-}
-  });
-
   // Round-robin through the ServerName list. Choose the 
lightest-loaded servers
   // first to keep the master from load-balancing regions as we 
split.
-  for (String rsLoc : serversLeft) {
+  for (Map.Entry>> 
daughterRegion :
+  daughterRegions.entrySet()) {
 Pair dr = null;
+ServerName rsLoc = daughterRegion.getKey();
+LinkedList> regionList = 
daughterRegion.getValue();
 
 // Find a region in the ServerName list that hasn't been moved
 LOG.debug("Finding a region on " + rsLoc);
-LinkedList> regionList = 
daughterRegions.get(rsLoc);
 while (!regionList.isEmpty()) {
   dr = regionList.pop();
 
@@ -521,7 +514,7 @@ public class RegionSplitter {
   HRegionLocation regionLoc = 
regionLocator.getRegionLocation(split);
 
   // if this region moved locations
-  String newRs = regionLoc.getHostnamePort();
+  ServerName newRs = regionLoc.getServerName();
   if (newRs.compareTo(rsLoc) != 0) {
 LOG.debug("Region with " + splitAlgo.rowToStr(split)
 + " moved to " + newRs + ". Relocating...");

hbase git commit: HBASE-17047 Add an API to get HBase connection cache statistics (Weiqing Yang)

2016-11-11 Thread tedyu

Repository: hbase
Updated Branches:
  refs/heads/master 8a6d6aa23 -> 81623a353


HBASE-17047 Add an API to get HBase connection cache statistics (Weiqing Yang)


Project: http://git-wip-us.apache.org/repos/asf/hbase/repo
Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/81623a35
Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/81623a35
Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/81623a35

Branch: refs/heads/master
Commit: 81623a353cdfbeef231f36d60aaa3419267f22d4
Parents: 8a6d6aa
Author: tedyu 
Authored: Fri Nov 11 06:50:01 2016 -0800
Committer: tedyu 
Committed: Fri Nov 11 06:50:01 2016 -0800

--
 .../hbase/spark/HBaseConnectionCache.scala  | 38 ++
 .../hbase/spark/HBaseConnectionCacheSuite.scala | 41 +++-
 2 files changed, 69 insertions(+), 10 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/hbase/blob/81623a35/hbase-spark/src/main/scala/org/apache/hadoop/hbase/spark/HBaseConnectionCache.scala
--
diff --git 
a/hbase-spark/src/main/scala/org/apache/hadoop/hbase/spark/HBaseConnectionCache.scala
 
b/hbase-spark/src/main/scala/org/apache/hadoop/hbase/spark/HBaseConnectionCache.scala
index 678e769..fb5833e 100644
--- 
a/hbase-spark/src/main/scala/org/apache/hadoop/hbase/spark/HBaseConnectionCache.scala
+++ 
b/hbase-spark/src/main/scala/org/apache/hadoop/hbase/spark/HBaseConnectionCache.scala
@@ -34,6 +34,8 @@ private[spark] object HBaseConnectionCache extends Logging {
   // A hashmap of Spark-HBase connections. Key is HBaseConnectionKey.
   val connectionMap = new mutable.HashMap[HBaseConnectionKey, 
SmartConnection]()
 
+  val cacheStat = HBaseConnectionCacheStat(0, 0, 0)
+
   // in milliseconds
   private final val DEFAULT_TIME_OUT: Long = 
HBaseSparkConf.connectionCloseDelay
   private var timeout = DEFAULT_TIME_OUT
@@ -58,6 +60,13 @@ private[spark] object HBaseConnectionCache extends Logging {
   housekeepingThread.setDaemon(true)
   housekeepingThread.start()
 
+  def getStat: HBaseConnectionCacheStat = {
+connectionMap.synchronized {
+  cacheStat.numActiveConnections = connectionMap.size
+  cacheStat.copy()
+}
+  }
+
   def close(): Unit = {
 try {
   connectionMap.synchronized {
@@ -100,7 +109,9 @@ private[spark] object HBaseConnectionCache extends Logging {
 connectionMap.synchronized {
   if (closed)
 return null
-  val sc = connectionMap.getOrElseUpdate(key, new SmartConnection(conn))
+  cacheStat.numTotalRequests += 1
+  val sc = connectionMap.getOrElseUpdate(key, 
{cacheStat.numActualConnectionsCreated += 1
+new SmartConnection(conn)})
   sc.refCount += 1
   sc
 }
@@ -136,13 +147,13 @@ private[hbase] case class SmartConnection (
 }
 
 /**
-  * Denotes a unique key to an HBase Connection instance.
-  * Please refer to 'org.apache.hadoop.hbase.client.HConnectionKey'.
-  *
-  * In essence, this class captures the properties in Configuration
-  * that may be used in the process of establishing a connection.
-  *
-  */
+ * Denotes a unique key to an HBase Connection instance.
+ * Please refer to 'org.apache.hadoop.hbase.client.HConnectionKey'.
+ *
+ * In essence, this class captures the properties in Configuration
+ * that may be used in the process of establishing a connection.
+ *
+ */
 class HBaseConnectionKey(c: Configuration) extends Logging {
   val conf: Configuration = c
   val CONNECTION_PROPERTIES: Array[String] = Array[String](
@@ -240,4 +251,15 @@ class HBaseConnectionKey(c: Configuration) extends Logging 
{
   }
 }
 
+/**
+ * To log the state of 'HBaseConnectionCache'
+ *
+ * @param numTotalRequests number of total connection requests to the cache
+ * @param numActualConnectionsCreated number of actual HBase connections the 
cache ever created
+ * @param numActiveConnections number of current alive HBase connections the 
cache is holding
+ */
+case class HBaseConnectionCacheStat(var numTotalRequests: Long,
+var numActualConnectionsCreated: Long,
+var numActiveConnections: Long)
+
 

http://git-wip-us.apache.org/repos/asf/hbase/blob/81623a35/hbase-spark/src/test/scala/org/apache/hadoop/hbase/spark/HBaseConnectionCacheSuite.scala
--
diff --git 
a/hbase-spark/src/test/scala/org/apache/hadoop/hbase/spark/HBaseConnectionCacheSuite.scala
 
b/hbase-spark/src/test/scala/org/apache/hadoop/hbase/spark/HBaseConnectionCacheSuite.scala
index c9edcc4..6ebf044 100644
--- 
a/hbase-spark/src/test/scala/org/apache/hadoop/hbase/spark/HBaseConnectionCacheSuite.scala
+++ 
b/hbase-spark/src/test/scala/org/apache/hadoop/hbase/spark/HBaseConnectionCacheSuite.scala
@@ -76,11 +76,18 @@ class HBaseConnectionCacheSuite extends FunSuite w

[2/2] hbase git commit: HBASE-16838 Implement basic scan

2016-11-11 Thread zhangduo

HBASE-16838 Implement basic scan


Project: http://git-wip-us.apache.org/repos/asf/hbase/repo
Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/8a6d6aa2
Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/8a6d6aa2
Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/8a6d6aa2

Branch: refs/heads/master
Commit: 8a6d6aa23944bbfd5047cf0c09fb4d8045735dab
Parents: fa838b0
Author: zhangduo 
Authored: Fri Nov 11 16:47:42 2016 +0800
Committer: zhangduo 
Committed: Fri Nov 11 21:01:16 2016 +0800

--
 .../client/AllowPartialScanResultCache.java |  98 ++
 .../hadoop/hbase/client/AsyncClientScanner.java | 151 
 .../client/AsyncConnectionConfiguration.java|  12 +-
 .../hbase/client/AsyncConnectionImpl.java   |   2 +-
 .../hbase/client/AsyncRegistryFactory.java  |  43 +++
 .../client/AsyncRpcRetryingCallerFactory.java   |  86 +
 .../AsyncScanSingleRegionRpcRetryingCaller.java | 351 +++
 .../AsyncSingleRequestRpcRetryingCaller.java|  39 +--
 .../apache/hadoop/hbase/client/AsyncTable.java  |  37 ++
 .../hadoop/hbase/client/AsyncTableImpl.java |  28 ++
 .../hadoop/hbase/client/ClientScanner.java  |   1 +
 .../hbase/client/ClusterRegistryFactory.java|  43 ---
 .../hbase/client/CompleteScanResultCache.java   |  97 +
 .../hadoop/hbase/client/ConnectionUtils.java|  26 ++
 .../hadoop/hbase/client/ScanResultCache.java|  53 +++
 .../hadoop/hbase/client/ScanResultConsumer.java |  63 
 .../client/AbstractTestAsyncTableScan.java  | 155 
 .../client/TestAllowPartialScanResultCache.java |  92 +
 .../hadoop/hbase/client/TestAsyncTableScan.java | 147 
 .../hbase/client/TestAsyncTableSmallScan.java   | 164 +
 .../TestCompleteResultScanResultCache.java  | 159 +
 21 files changed, 1614 insertions(+), 233 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/hbase/blob/8a6d6aa2/hbase-client/src/main/java/org/apache/hadoop/hbase/client/AllowPartialScanResultCache.java
--
diff --git 
a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/AllowPartialScanResultCache.java
 
b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/AllowPartialScanResultCache.java
new file mode 100644
index 000..bc6e44e
--- /dev/null
+++ 
b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/AllowPartialScanResultCache.java
@@ -0,0 +1,98 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.hadoop.hbase.client;
+
+import java.io.IOException;
+import java.util.Arrays;
+
+import org.apache.hadoop.hbase.Cell;
+import org.apache.hadoop.hbase.CellComparator;
+import org.apache.hadoop.hbase.CellUtil;
+import org.apache.hadoop.hbase.classification.InterfaceAudience;
+
+/**
+ * A ScanResultCache that may return partial result.
+ * 
+ * As we can only scan from the starting of a row when error, so here we also 
implement the logic
+ * that skips the cells that have already been returned.
+ */
+@InterfaceAudience.Private
+class AllowPartialScanResultCache implements ScanResultCache {
+
+  // used to filter out the cells that already returned to user as we always 
start from the
+  // beginning of a row when retry.
+  private Cell lastCell;
+
+  private Result filterCells(Result result) {
+if (lastCell == null) {
+  return result;
+}
+
+// not the same row
+if (!CellUtil.matchingRow(lastCell, result.getRow(), 0, 
result.getRow().length)) {
+  return result;
+}
+Cell[] rawCells = result.rawCells();
+int index = Arrays.binarySearch(rawCells, lastCell, 
CellComparator::compareWithoutRow);
+if (index < 0) {
+  index = -index - 1;
+} else {
+  index++;
+}
+if (index == 0) {
+  return result;
+}
+if (index == rawCells.length) {
+  return null;
+}
+return Result.create(Arrays.copyOfRange(rawCells, index, rawCells.length), 
null,
+  result.isStale(), true);
+  }
+
+  private void updateLastCell(Result result) {
+lastCell = result.isPartial() ? result.rawCe

[1/2] hbase git commit: HBASE-16838 Implement basic scan

2016-11-11 Thread zhangduo

Repository: hbase
Updated Branches:
  refs/heads/master fa838b020 -> 8a6d6aa23


http://git-wip-us.apache.org/repos/asf/hbase/blob/8a6d6aa2/hbase-server/src/test/java/org/apache/hadoop/hbase/client/TestCompleteResultScanResultCache.java
--
diff --git 
a/hbase-server/src/test/java/org/apache/hadoop/hbase/client/TestCompleteResultScanResultCache.java
 
b/hbase-server/src/test/java/org/apache/hadoop/hbase/client/TestCompleteResultScanResultCache.java
new file mode 100644
index 000..d688d0a
--- /dev/null
+++ 
b/hbase-server/src/test/java/org/apache/hadoop/hbase/client/TestCompleteResultScanResultCache.java
@@ -0,0 +1,159 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.hadoop.hbase.client;
+
+import static org.junit.Assert.assertEquals;
+import static org.junit.Assert.assertSame;
+
+import java.io.IOException;
+import java.util.Arrays;
+import java.util.stream.IntStream;
+
+import org.apache.hadoop.hbase.Cell;
+import org.apache.hadoop.hbase.KeyValue;
+import org.apache.hadoop.hbase.testclassification.ClientTests;
+import org.apache.hadoop.hbase.testclassification.SmallTests;
+import org.apache.hadoop.hbase.util.Bytes;
+import org.junit.After;
+import org.junit.Before;
+import org.junit.Test;
+import org.junit.experimental.categories.Category;
+
+@Category({ SmallTests.class, ClientTests.class })
+public class TestCompleteResultScanResultCache {
+
+  private static byte[] CF = Bytes.toBytes("cf");
+
+  private static byte[] CQ1 = Bytes.toBytes("cq1");
+
+  private static byte[] CQ2 = Bytes.toBytes("cq2");
+
+  private static byte[] CQ3 = Bytes.toBytes("cq3");
+
+  private CompleteScanResultCache resultCache;
+
+  @Before
+  public void setUp() {
+resultCache = new CompleteScanResultCache();
+  }
+
+  @After
+  public void tearDown() {
+resultCache.clear();
+resultCache = null;
+  }
+
+  private static Cell createCell(int key, byte[] cq) {
+return new KeyValue(Bytes.toBytes(key), CF, cq, Bytes.toBytes(key));
+  }
+
+  @Test
+  public void testNoPartial() throws IOException {
+assertSame(ScanResultCache.EMPTY_RESULT_ARRAY,
+  resultCache.addAndGet(ScanResultCache.EMPTY_RESULT_ARRAY, false));
+assertSame(ScanResultCache.EMPTY_RESULT_ARRAY,
+  resultCache.addAndGet(ScanResultCache.EMPTY_RESULT_ARRAY, true));
+int count = 10;
+Result[] results = new Result[count];
+IntStream.range(0, count).forEach(i -> {
+  results[i] = Result.create(Arrays.asList(createCell(i, CQ1)));
+});
+assertSame(results, resultCache.addAndGet(results, false));
+  }
+
+  @Test
+  public void testCombine1() throws IOException {
+Result previousResult = Result.create(Arrays.asList(createCell(0, CQ1)), 
null, false, true);
+Result result1 = Result.create(Arrays.asList(createCell(1, CQ1)), null, 
false, true);
+Result result2 = Result.create(Arrays.asList(createCell(1, CQ2)), null, 
false, true);
+Result result3 = Result.create(Arrays.asList(createCell(1, CQ3)), null, 
false, true);
+Result[] results = resultCache.addAndGet(new Result[] { previousResult, 
result1 }, false);
+assertEquals(1, results.length);
+assertSame(previousResult, results[0]);
+
+assertEquals(0, resultCache.addAndGet(new Result[] { result2 }, 
false).length);
+assertEquals(0, resultCache.addAndGet(new Result[] { result3 }, 
false).length);
+assertEquals(0, resultCache.addAndGet(new Result[0], true).length);
+
+results = resultCache.addAndGet(new Result[0], false);
+assertEquals(1, results.length);
+assertEquals(1, Bytes.toInt(results[0].getRow()));
+assertEquals(3, results[0].rawCells().length);
+assertEquals(1, Bytes.toInt(results[0].getValue(CF, CQ1)));
+assertEquals(1, Bytes.toInt(results[0].getValue(CF, CQ2)));
+assertEquals(1, Bytes.toInt(results[0].getValue(CF, CQ3)));
+  }
+
+  @Test
+  public void testCombine2() throws IOException {
+Result result1 = Result.create(Arrays.asList(createCell(1, CQ1)), null, 
false, true);
+Result result2 = Result.create(Arrays.asList(createCell(1, CQ2)), null, 
false, true);
+Result result3 = Result.create(Arrays.asList(createCell(1, CQ3)), null, 
fa

hbase git commit: HBASE-17071 Do not initialize MemstoreChunkPool when use mslab option is turned off.

2016-11-11 Thread anoopsamjohn

Repository: hbase
Updated Branches:
  refs/heads/master f9c6b66b9 -> fa838b020


HBASE-17071 Do not initialize MemstoreChunkPool when use mslab option is turned 
off.


Project: http://git-wip-us.apache.org/repos/asf/hbase/repo
Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/fa838b02
Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/fa838b02
Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/fa838b02

Branch: refs/heads/master
Commit: fa838b020df0235e9bea448730b3bd034e9bfb65
Parents: f9c6b66
Author: anoopsamjohn 
Authored: Fri Nov 11 16:44:34 2016 +0530
Committer: anoopsamjohn 
Committed: Fri Nov 11 16:44:34 2016 +0530

--
 .../org/apache/hadoop/hbase/regionserver/MemStoreChunkPool.java | 5 +
 .../java/org/apache/hadoop/hbase/regionserver/MemStoreLAB.java  | 4 
 .../org/apache/hadoop/hbase/regionserver/SegmentFactory.java| 4 +---
 .../org/apache/hadoop/hbase/regionserver/TestCellFlatSet.java   | 2 +-
 .../hadoop/hbase/regionserver/TestCompactingMemStore.java   | 2 +-
 .../apache/hadoop/hbase/regionserver/TestMemStoreChunkPool.java | 2 +-
 6 files changed, 13 insertions(+), 6 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/hbase/blob/fa838b02/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/MemStoreChunkPool.java
--
diff --git 
a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/MemStoreChunkPool.java
 
b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/MemStoreChunkPool.java
index 582eeba..db2cd18 100644
--- 
a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/MemStoreChunkPool.java
+++ 
b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/MemStoreChunkPool.java
@@ -202,6 +202,11 @@ public class MemStoreChunkPool implements 
HeapMemoryTuneObserver {
 synchronized (MemStoreChunkPool.class) {
   if (chunkPoolDisabled) return null;
   if (GLOBAL_INSTANCE != null) return GLOBAL_INSTANCE;
+  // When MSLAB is turned OFF no need to init chunk pool at all.
+  if (!conf.getBoolean(MemStoreLAB.USEMSLAB_KEY, 
MemStoreLAB.USEMSLAB_DEFAULT)) {
+chunkPoolDisabled = true;
+return null;
+  }
   float poolSizePercentage = conf.getFloat(CHUNK_POOL_MAXSIZE_KEY, 
POOL_MAX_SIZE_DEFAULT);
   if (poolSizePercentage <= 0) {
 chunkPoolDisabled = true;

http://git-wip-us.apache.org/repos/asf/hbase/blob/fa838b02/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/MemStoreLAB.java
--
diff --git 
a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/MemStoreLAB.java
 
b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/MemStoreLAB.java
index 0dcafe6..706e243 100644
--- 
a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/MemStoreLAB.java
+++ 
b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/MemStoreLAB.java
@@ -44,6 +44,9 @@ import 
org.apache.hadoop.hbase.classification.InterfaceAudience;
 @InterfaceAudience.Private
 public interface MemStoreLAB {
 
+  String USEMSLAB_KEY = "hbase.hregion.memstore.mslab.enabled";
+  boolean USEMSLAB_DEFAULT = true;
+
   /**
* Allocates slice in this LAB and copy the passed Cell into this area. 
Returns new Cell instance
* over the copied the data. When this MemStoreLAB can not copy this Cell, 
it returns null.
@@ -64,4 +67,5 @@ public interface MemStoreLAB {
* Called when closing a scanner on the data of this MemStoreLAB
*/
   void decScannerCount();
+
 }

http://git-wip-us.apache.org/repos/asf/hbase/blob/fa838b02/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/SegmentFactory.java
--
diff --git 
a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/SegmentFactory.java
 
b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/SegmentFactory.java
index 4f60976..fa8860a 100644
--- 
a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/SegmentFactory.java
+++ 
b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/SegmentFactory.java
@@ -35,8 +35,6 @@ import java.util.List;
 @InterfaceAudience.Private
 public final class SegmentFactory {
 
-  static final String USEMSLAB_KEY = "hbase.hregion.memstore.mslab.enabled";
-  static final boolean USEMSLAB_DEFAULT = true;
   static final String MSLAB_CLASS_NAME = "hbase.regionserver.mslab.class";
 
   private SegmentFactory() {}
@@ -107,7 +105,7 @@ public final class SegmentFactory {
 
   private MemStoreLAB getMemStoreLAB(Configuration conf) {
 MemStoreLAB memStoreLAB = null;
-if (conf.getBoolean(USEMSLAB_KEY, USEMSLAB_DEFAULT)) {
+if (conf.getBoolean(MemStoreLAB.USEMSLAB_KEY, 
MemStoreLAB.USEMSLAB_DE

60 matches

Mail list logo