[18/18] hbase-site git commit: Published site at 02f5f171f51b7ed801355c8acdcfc4ad47c23a3e.

2018-10-30 Thread git-site-role
Published site at 02f5f171f51b7ed801355c8acdcfc4ad47c23a3e.


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

Branch: refs/heads/asf-site
Commit: 2752c92441d0242a51157b1861ae30a1486333e8
Parents: 51db083
Author: jenkins 
Authored: Tue Oct 30 14:54:09 2018 +
Committer: jenkins 
Committed: Tue Oct 30 14:54:09 2018 +

--
 acid-semantics.html |4 +-
 apache_hbase_reference_guide.pdf|4 +-
 book.html   |2 +-
 bulk-loads.html |4 +-
 checkstyle-aggregate.html   |   48 +-
 checkstyle.rss  |   16 +-
 coc.html|4 +-
 dependencies.html   |4 +-
 dependency-convergence.html |4 +-
 dependency-info.html|4 +-
 dependency-management.html  |4 +-
 devapidocs/allclasses-frame.html|1 +
 devapidocs/allclasses-noframe.html  |1 +
 devapidocs/constant-values.html |4 +-
 devapidocs/index-all.html   |   37 +-
 .../hadoop/hbase/backup/package-tree.html   |2 +-
 .../hadoop/hbase/class-use/ServerName.html  |  108 +-
 .../apache/hadoop/hbase/client/HBaseHbck.html   |   56 +-
 .../org/apache/hadoop/hbase/client/Hbck.html|   40 +-
 .../hadoop/hbase/client/package-tree.html   |   24 +-
 .../hadoop/hbase/coprocessor/package-tree.html  |2 +-
 .../hadoop/hbase/filter/package-tree.html   |   10 +-
 .../hadoop/hbase/io/hfile/package-tree.html |4 +-
 .../apache/hadoop/hbase/ipc/package-tree.html   |2 +-
 .../hadoop/hbase/mapreduce/package-tree.html|4 +-
 .../MasterRpcServices.BalanceSwitchMode.html|6 +-
 .../hadoop/hbase/master/MasterRpcServices.html  |  469 +-
 .../master/assignment/AssignmentManager.html|   82 +-
 .../hbase/master/balancer/package-tree.html |2 +-
 .../hadoop/hbase/master/package-tree.html   |4 +-
 .../procedure/PeerProcedureInterface.html   |2 +-
 .../procedure/class-use/MasterProcedureEnv.html |8 +-
 .../class-use/PeerProcedureInterface.html   |   29 +-
 .../hbase/master/procedure/package-tree.html|2 +-
 .../AbstractPeerNoLockProcedure.html|  596 +++
 .../replication/AbstractPeerProcedure.html  |  274 +-
 .../master/replication/AddPeerProcedure.html|   34 +-
 .../replication/DisablePeerProcedure.html   |   34 +-
 .../master/replication/EnablePeerProcedure.html |   34 +-
 .../master/replication/ModifyPeerProcedure.html |   25 +-
 .../replication/RecoverStandbyProcedure.html|   22 +-
 .../master/replication/RemovePeerProcedure.html |   34 +-
 .../SyncReplicationReplayWALProcedure.html  |   24 +-
 ...ransitPeerSyncReplicationStateProcedure.html |   34 +-
 .../replication/UpdatePeerConfigProcedure.html  |   34 +-
 .../class-use/AbstractPeerNoLockProcedure.html  |  218 +
 .../class-use/AbstractPeerProcedure.html|8 -
 .../hbase/master/replication/package-frame.html |1 +
 .../master/replication/package-summary.html |   35 +-
 .../hbase/master/replication/package-tree.html  |6 +-
 .../hbase/master/replication/package-use.html   |   14 +-
 .../hadoop/hbase/monitoring/package-tree.html   |2 +-
 .../org/apache/hadoop/hbase/package-tree.html   |   16 +-
 .../hbase/procedure2/StateMachineProcedure.html |2 +-
 .../hbase/procedure2/class-use/Procedure.html   |   29 +-
 .../class-use/ProcedureStateSerializer.html |4 +-
 .../class-use/ProcedureSuspendedException.html  |4 +-
 .../class-use/StateMachineProcedure.html|   25 +-
 .../hadoop/hbase/procedure2/package-tree.html   |4 +-
 .../hadoop/hbase/quotas/package-tree.html   |8 +-
 .../hadoop/hbase/regionserver/package-tree.html |   16 +-
 .../hbase/regionserver/wal/package-tree.html|2 +-
 .../hadoop/hbase/rest/model/package-tree.html   |2 +-
 .../hbase/security/access/package-tree.html |2 +-
 .../hadoop/hbase/security/package-tree.html |4 +-
 .../hadoop/hbase/thrift/package-tree.html   |2 +-
 .../apache/hadoop/hbase/util/package-tree.html  |   12 +-
 devapidocs/overview-tree.html   |6 +-
 .../org/apache/hadoop/hbase/Version.html|4 +-
 .../apache/hadoop/hbase/client/HBaseHbck.html   |  274 +-
 .../org/apache/hadoop/hbase/client/Hbck.html|  159 +-
 .../MasterRpcServices.BalanceSwitchMode.html| 4866 +-
 .../hadoop/hbase/master/MasterRpcServices.html  | 4866 +-
 ...signmentManager.RegionInTransitio

[07/18] hbase-site git commit: Published site at 02f5f171f51b7ed801355c8acdcfc4ad47c23a3e.

2018-10-30 Thread git-site-role
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/2752c924/devapidocs/src-html/org/apache/hadoop/hbase/master/MasterRpcServices.html
--
diff --git 
a/devapidocs/src-html/org/apache/hadoop/hbase/master/MasterRpcServices.html 
b/devapidocs/src-html/org/apache/hadoop/hbase/master/MasterRpcServices.html
index 4365cc5..2cdee19 100644
--- a/devapidocs/src-html/org/apache/hadoop/hbase/master/MasterRpcServices.html
+++ b/devapidocs/src-html/org/apache/hadoop/hbase/master/MasterRpcServices.html
@@ -26,2436 +26,2490 @@
 018 */
 019package org.apache.hadoop.hbase.master;
 020
-021import java.io.IOException;
-022import java.net.BindException;
-023import java.net.InetAddress;
-024import java.net.InetSocketAddress;
-025import java.util.ArrayList;
-026import java.util.HashMap;
-027import java.util.HashSet;
-028import java.util.List;
-029import java.util.Map;
-030import java.util.Map.Entry;
-031import java.util.Set;
-032import java.util.stream.Collectors;
-033import 
org.apache.hadoop.conf.Configuration;
-034import 
org.apache.hadoop.hbase.ClusterMetricsBuilder;
-035import 
org.apache.hadoop.hbase.DoNotRetryIOException;
-036import 
org.apache.hadoop.hbase.HConstants;
-037import 
org.apache.hadoop.hbase.MetaTableAccessor;
-038import 
org.apache.hadoop.hbase.NamespaceDescriptor;
-039import org.apache.hadoop.hbase.Server;
-040import 
org.apache.hadoop.hbase.ServerMetrics;
-041import 
org.apache.hadoop.hbase.ServerMetricsBuilder;
-042import 
org.apache.hadoop.hbase.ServerName;
-043import 
org.apache.hadoop.hbase.TableName;
-044import 
org.apache.hadoop.hbase.UnknownRegionException;
-045import 
org.apache.hadoop.hbase.client.ColumnFamilyDescriptor;
-046import 
org.apache.hadoop.hbase.client.MasterSwitchType;
-047import 
org.apache.hadoop.hbase.client.RegionInfo;
-048import 
org.apache.hadoop.hbase.client.RegionInfoBuilder;
-049import 
org.apache.hadoop.hbase.client.TableDescriptor;
-050import 
org.apache.hadoop.hbase.client.TableState;
-051import 
org.apache.hadoop.hbase.client.VersionInfoUtil;
-052import 
org.apache.hadoop.hbase.client.replication.ReplicationPeerConfigUtil;
-053import 
org.apache.hadoop.hbase.coprocessor.MasterCoprocessor;
-054import 
org.apache.hadoop.hbase.errorhandling.ForeignException;
-055import 
org.apache.hadoop.hbase.exceptions.UnknownProtocolException;
-056import 
org.apache.hadoop.hbase.io.hfile.HFile;
-057import 
org.apache.hadoop.hbase.ipc.CoprocessorRpcUtils;
-058import 
org.apache.hadoop.hbase.ipc.PriorityFunction;
-059import 
org.apache.hadoop.hbase.ipc.QosPriority;
-060import 
org.apache.hadoop.hbase.ipc.RpcServer;
-061import 
org.apache.hadoop.hbase.ipc.RpcServer.BlockingServiceAndInterface;
-062import 
org.apache.hadoop.hbase.ipc.RpcServerFactory;
-063import 
org.apache.hadoop.hbase.ipc.RpcServerInterface;
-064import 
org.apache.hadoop.hbase.ipc.ServerRpcController;
-065import 
org.apache.hadoop.hbase.master.assignment.RegionStates;
-066import 
org.apache.hadoop.hbase.master.locking.LockProcedure;
-067import 
org.apache.hadoop.hbase.master.procedure.MasterProcedureUtil;
-068import 
org.apache.hadoop.hbase.master.procedure.MasterProcedureUtil.NonceProcedureRunnable;
-069import 
org.apache.hadoop.hbase.mob.MobUtils;
-070import 
org.apache.hadoop.hbase.procedure.MasterProcedureManager;
-071import 
org.apache.hadoop.hbase.procedure2.LockType;
-072import 
org.apache.hadoop.hbase.procedure2.LockedResource;
-073import 
org.apache.hadoop.hbase.procedure2.Procedure;
-074import 
org.apache.hadoop.hbase.procedure2.ProcedureExecutor;
-075import 
org.apache.hadoop.hbase.procedure2.ProcedureUtil;
-076import 
org.apache.hadoop.hbase.procedure2.RemoteProcedureException;
-077import 
org.apache.hadoop.hbase.protobuf.generated.AccessControlProtos.AccessControlService;
-078import 
org.apache.hadoop.hbase.protobuf.generated.VisibilityLabelsProtos.VisibilityLabelsService;
-079import 
org.apache.hadoop.hbase.quotas.MasterQuotaManager;
-080import 
org.apache.hadoop.hbase.quotas.QuotaObserverChore;
-081import 
org.apache.hadoop.hbase.quotas.QuotaUtil;
-082import 
org.apache.hadoop.hbase.quotas.SpaceQuotaSnapshot;
-083import 
org.apache.hadoop.hbase.regionserver.RSRpcServices;
-084import 
org.apache.hadoop.hbase.regionserver.RpcSchedulerFactory;
-085import 
org.apache.hadoop.hbase.replication.ReplicationException;
-086import 
org.apache.hadoop.hbase.replication.ReplicationPeerConfig;
-087import 
org.apache.hadoop.hbase.replication.ReplicationPeerDescription;
-088import 
org.apache.hadoop.hbase.security.User;
-089import 
org.apache.hadoop.hbase.security.access.AccessChecker;
-090import 
org.apache.hadoop.hbase.security.access.AccessController;
-091import 
org.apache.hadoop.hbase.security.access.Permission;
-092import 
org.apache.hadoop.hbase.security.visibility.VisibilityController;
-093import 
org.apache.hadoop.hbase.snapshot.ClientSnapshotDescriptionUtils;
-094import 
org.apache.hadoop.hbase.snapshot.SnapshotDescriptionUtils;
-095import 
org.ap

[17/18] hbase-site git commit: Published site at 02f5f171f51b7ed801355c8acdcfc4ad47c23a3e.

2018-10-30 Thread git-site-role
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/2752c924/devapidocs/org/apache/hadoop/hbase/class-use/ServerName.html
--
diff --git a/devapidocs/org/apache/hadoop/hbase/class-use/ServerName.html 
b/devapidocs/org/apache/hadoop/hbase/class-use/ServerName.html
index 721a8e0..e4de51f 100644
--- a/devapidocs/org/apache/hadoop/hbase/class-use/ServerName.html
+++ b/devapidocs/org/apache/hadoop/hbase/class-use/ServerName.html
@@ -3590,189 +3590,193 @@ Input/OutputFormats, a table indexing MapReduce job, 
and utility methods.
  ServerName right) 
 
 
+private boolean
+MasterRpcServices.containMetaWals(ServerName serverName) 
+
+
 boolean
 ServerManager.expireServer(ServerName serverName)
 Expire the passed server.
 
 
-
+
 private ServerName
 ServerManager.findServerWithSameHostnamePortWithLock(ServerName serverName)
 Assumes onlineServers is locked.
 
 
-
+
 void
 DeadServer.finish(ServerName sn)
 Complete processing for this dead server.
 
 
-
+
 int
 ServerManager.getInfoPort(ServerName serverName) 
 
-
+
 ServerMetrics
 ServerManager.getLoad(ServerName serverName) 
 
-
+
 https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
 title="class or interface in java.lang">String
 RackManager.getRack(ServerName server)
 Get the name of the rack containing a server, according to 
the DNS to
  switch mapping.
 
 
-
+
 int
 HMaster.getRegionServerInfoPort(ServerName sn) 
 
-
+
 https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
 title="class or interface in java.lang">String
 MasterServices.getRegionServerVersion(ServerName sn) 
 
-
+
 https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
 title="class or interface in java.lang">String
 HMaster.getRegionServerVersion(ServerName sn) 
 
-
+
 https://docs.oracle.com/javase/8/docs/api/java/util/HashMap.html?is-external=true";
 title="class or interface in java.util">HashMapString,https://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true";
 title="class or interface in java.util">List>>
 HMaster.getReplicationLoad(ServerName[] serverNames) 
 
-
+
 org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.AdminService.BlockingInterface
 ServerManager.getRsAdmin(ServerName sn) 
 
-
+
 https://docs.oracle.com/javase/8/docs/api/java/util/Date.html?is-external=true";
 title="class or interface in java.util">Date
 DeadServer.getTimeOfDeath(ServerName deadServerName)
 Get the time when a server died
 
 
-
+
 https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
 title="class or interface in java.lang">String
 ServerManager.getVersion(ServerName serverName)
 May return "0.0.0" when server is not online
 
 
-
+
 int
 ServerManager.getVersionNumber(ServerName serverName)
 May return 0 when server is not online.
 
 
-
+
 (package private) void
 SplitLogManager.handleDeadWorker(ServerName workerName) 
 
-
+
 void
 SplitLogManager.Task.heartbeat(long time,
  int version,
  ServerName worker) 
 
-
+
 boolean
 RegionState.isClosingOrClosedOnServer(ServerName sn) 
 
-
+
 boolean
 DeadServer.isDeadServer(ServerName serverName) 
 
-
+
 boolean
 RegionState.isMergingNewOnServer(ServerName sn) 
 
-
+
 boolean
 RegionState.isMergingNewOrOfflineOnServer(ServerName sn) 
 
-
+
 boolean
 RegionState.isMergingNewOrOpenedOnServer(ServerName sn) 
 
-
+
 boolean
 RegionState.isMergingOnServer(ServerName sn) 
 
-
+
 boolean
 RegionState.isOnServer(ServerName sn) 
 
-
+
 boolean
 RegionState.isOpenedOnServer(ServerName sn) 
 
-
+
 boolean
 RegionState.isOpeningOrFailedOpenOnServer(ServerName sn) 
 
-
+
 boolean
 RegionState.isOpeningOrOpenedOnServer(ServerName sn) 
 
-
+
 boolean
 DeadServer.isProcessingServer(ServerName serverName) 
 
-
+
 boolean
 ServerManager.isServerDead(ServerName serverName)
 Check if a server is known to be dead.
 
 
-
+
 boolean
 ServerManager.isServerOnline(ServerName serverName) 
 
-
+
 boolean
 RegionState.isSplittingNewOnServer(ServerName sn) 
 
-
+
 boolean
 RegionState.isSplittingOnServer(ServerName sn) 
 
-
+
 boolean
 RegionState.isSplittingOrOpenedOnServer(ServerName sn) 
 
-
+
 boolean
 RegionState.isSplittingOrSplitOnServer(ServerName sn) 
 
-
+
 void
 ServerManager.moveFromOnlineToDeadServers(ServerName sn) 
 
-
+
 void
 DeadServer.notifyServer(ServerName sn)
 Notify that we started processing this dead server.
 
 
-
+
 void
 MasterCoprocessorHost.postMove(RegionInfo region,
 ServerName srcServer,
 ServerName destServer) 
 
-
+
 void
 MasterCoprocessorHost.postRecommissionRegionServer(ServerName server,
 https://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true";
 title="class or interface in 
java

[10/18] hbase-site git commit: Published site at 02f5f171f51b7ed801355c8acdcfc4ad47c23a3e.

2018-10-30 Thread git-site-role
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/2752c924/devapidocs/org/apache/hadoop/hbase/master/replication/TransitPeerSyncReplicationStateProcedure.html
--
diff --git 
a/devapidocs/org/apache/hadoop/hbase/master/replication/TransitPeerSyncReplicationStateProcedure.html
 
b/devapidocs/org/apache/hadoop/hbase/master/replication/TransitPeerSyncReplicationStateProcedure.html
index d4161a3..5ca2906 100644
--- 
a/devapidocs/org/apache/hadoop/hbase/master/replication/TransitPeerSyncReplicationStateProcedure.html
+++ 
b/devapidocs/org/apache/hadoop/hbase/master/replication/TransitPeerSyncReplicationStateProcedure.html
@@ -106,6 +106,9 @@ var activeTableTab = "activeTableTab";
 org.apache.hadoop.hbase.procedure2.StateMachineProcedure
 
 
+org.apache.hadoop.hbase.master.replication.AbstractPeerNoLockProcedure
+
+
 org.apache.hadoop.hbase.master.replication.AbstractPeerProcedure
 
 
@@ -119,6 +122,8 @@ var activeTableTab = "activeTableTab";
 
 
 
+
+
 
 
 
@@ -201,7 +206,14 @@ extends AbstractPeerProcedure
-attempts,
 latch,
 peerId
+latch
+
+
+
+
+
+Fields inherited from 
class org.apache.hadoop.hbase.master.replication.AbstractPeerNoLockProcedure
+attempts,
 peerId
 
 
 
@@ -341,7 +353,14 @@ extends AbstractPeerProcedure
-acquireLock,
 enablePeer,
 getLatch,
 getPeerId,
 holdLock,
 refreshPeer,
 releaseLock,
 rollbackState,
 setTimeoutFailure,
 suspend,
 waitInitialized<
 /li>
+acquireLock,
 enablePeer,
 getLatch,
 holdLock,
 refreshPeer,
 releaseLock
+
+
+
+
+
+Methods inherited from 
class org.apache.hadoop.hbase.master.replication.AbstractPeerNoLockProcedure
+getPeerId,
 rollbackState,
 setTimeoutFailure,
 suspend,
 waitInitialized
 
 
 
@@ -364,6 +383,13 @@ extends https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true";
 title="class or interface in java.lang">Object
 https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true#clone--";
 title="class or interface in java.lang">clone, https://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, https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true#finalize--";
 title="class or interface in java.lang">finalize, https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true#getClass--";
 title="class or interface in java.lang">getClass, https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true#hashCode--";
 title="class or interface in java.lang">hashCode, https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true#notify--";
 title="class or interface in java.lang">notify, https://docs.oracle.com/javase/8/docs/api/ja
 va/lang/Object.html?is-external=true#notifyAll--" title="class or interface in 
java.lang">notifyAll, https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true#wait--";
 title="class or interface in java.lang">wait, https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true#wait-long-";
 title="class or interface in java.lang">wait, https://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.hbase.master.procedure.PeerProcedureInterface
+getPeerId
+
 
 
 
@@ -472,7 +498,7 @@ extends Overrides:
-serializeStateData in
 class AbstractPeerProcedure
+serializeStateData in
 class AbstractPeerNoLockProcedure
 Parameters:
 serializer - stores the serializable state
 Throws:
@@ -493,7 +519,7 @@ extends Overrides:
-deserializeStateData in
 class AbstractPeerProcedure
+deserializeStateData in
 class AbstractPeerNoLockProcedure
 Parameters:
 serializer - contains the serialized state
 Throws:

http://git-wip-us.apache.org/repos/asf/hbase-site/blob/2752c924/devapidocs/org/apache/hadoop/hbase/master/replication/UpdatePeerConfigProcedure.html
--
diff --git 
a/devapidocs/org/apache/hadoop/hbase/master/replication/UpdatePeerConfigProcedure.html
 
b/devapidocs/org/apache/hadoop/hbase/master/replication/UpdatePeerConfigProcedure.html
index 5526c87..d4c4a41 100644
--- 
a/devapidocs/org/apache/hadoop/hbase/master/replica

[05/18] hbase-site git commit: Published site at 02f5f171f51b7ed801355c8acdcfc4ad47c23a3e.

2018-10-30 Thread git-site-role
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/2752c924/devapidocs/src-html/org/apache/hadoop/hbase/master/assignment/AssignmentManager.RegionInTransitionStat.html
--
diff --git 
a/devapidocs/src-html/org/apache/hadoop/hbase/master/assignment/AssignmentManager.RegionInTransitionStat.html
 
b/devapidocs/src-html/org/apache/hadoop/hbase/master/assignment/AssignmentManager.RegionInTransitionStat.html
index 801dc55..5d3c5eb 100644
--- 
a/devapidocs/src-html/org/apache/hadoop/hbase/master/assignment/AssignmentManager.RegionInTransitionStat.html
+++ 
b/devapidocs/src-html/org/apache/hadoop/hbase/master/assignment/AssignmentManager.RegionInTransitionStat.html
@@ -1369,556 +1369,557 @@
 1361return 0;
 1362  }
 1363
-1364  public void submitServerCrash(final 
ServerName serverName, final boolean shouldSplitWal) {
+1364  public long submitServerCrash(final 
ServerName serverName, final boolean shouldSplitWal) {
 1365boolean carryingMeta = 
isCarryingMeta(serverName);
 1366
ProcedureExecutor procExec = 
this.master.getMasterProcedureExecutor();
-1367procExec.submitProcedure(new 
ServerCrashProcedure(procExec.getEnvironment(), serverName,
-1368  shouldSplitWal, carryingMeta));
-1369LOG.debug("Added=" + serverName +
-1370  " to dead servers, submitted 
shutdown handler to be executed meta=" + carryingMeta);
-1371  }
-1372
-1373  public void offlineRegion(final 
RegionInfo regionInfo) {
-1374// TODO used by MasterRpcServices
-1375RegionStateNode node = 
regionStates.getRegionStateNode(regionInfo);
-1376if (node != null) {
-1377  node.offline();
-1378}
-1379  }
-1380
-1381  public void onlineRegion(final 
RegionInfo regionInfo, final ServerName serverName) {
-1382// TODO used by 
TestSplitTransactionOnCluster.java
-1383  }
-1384
-1385  public Map> getSnapShotOfAssignment(
-1386  final Collection 
regions) {
-1387return 
regionStates.getSnapShotOfAssignment(regions);
-1388  }
-1389
-1390  // 

-1391  //  TODO: UTILS/HELPERS?
-1392  // 

-1393  /**
-1394   * Used by the client (via master) to 
identify if all regions have the schema updates
-1395   *
-1396   * @param tableName
-1397   * @return Pair indicating the status 
of the alter command (pending/total)
-1398   * @throws IOException
-1399   */
-1400  public Pair 
getReopenStatus(TableName tableName) {
-1401if (isTableDisabled(tableName)) 
return new Pair(0, 0);
-1402
-1403final List states 
= regionStates.getTableRegionStates(tableName);
-1404int ritCount = 0;
-1405for (RegionState regionState: 
states) {
-1406  if (!regionState.isOpened()) 
ritCount++;
-1407}
-1408return new Pair(ritCount, states.size());
-1409  }
-1410
-1411  // 

-1412  //  TODO: Region State In Transition
-1413  // 

-1414  public boolean 
hasRegionsInTransition() {
-1415return 
regionStates.hasRegionsInTransition();
-1416  }
-1417
-1418  public List 
getRegionsInTransition() {
-1419return 
regionStates.getRegionsInTransition();
-1420  }
-1421
-1422  public List 
getAssignedRegions() {
-1423return 
regionStates.getAssignedRegions();
-1424  }
-1425
-1426  public RegionInfo getRegionInfo(final 
byte[] regionName) {
-1427final RegionStateNode regionState = 
regionStates.getRegionStateNodeFromName(regionName);
-1428return regionState != null ? 
regionState.getRegionInfo() : null;
-1429  }
-1430
-1431  // 

-1432  //  Expected states on region state 
transition.
-1433  //  Notice that there is expected 
states for transiting to OPENING state, this is because SCP.
-1434  //  See the comments in regionOpening 
method for more details.
-1435  // 

-1436  private static final State[] 
STATES_EXPECTED_ON_OPEN = {
-1437State.OPENING, // Normal case
-1438State.OPEN // Retrying
-1439  };
-1440
-1441  private static final State[] 
STATES_EXPECTED_ON_CLOSING = {
-1442State.OPEN, // Normal case
-1443State.CLOSING, // Retrying
-1444State.SPLITTING, // Offline the 
split parent
-1445State.MERGING // Offline the merge 
parents
-1446  };
-1447
-1448  private static final State[] 
STATES_EXPECTED_ON_CLOSED = {
-1449State.CLOSING, // Normal case
-1450State.CLOSED // Retrying
-1451  };
-1452
-1453  // This is f

[15/18] hbase-site git commit: Published site at 02f5f171f51b7ed801355c8acdcfc4ad47c23a3e.

2018-10-30 Thread git-site-role
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/2752c924/devapidocs/org/apache/hadoop/hbase/master/MasterRpcServices.html
--
diff --git a/devapidocs/org/apache/hadoop/hbase/master/MasterRpcServices.html 
b/devapidocs/org/apache/hadoop/hbase/master/MasterRpcServices.html
index 3ff4ce2..6c0477a 100644
--- a/devapidocs/org/apache/hadoop/hbase/master/MasterRpcServices.html
+++ b/devapidocs/org/apache/hadoop/hbase/master/MasterRpcServices.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":10,"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,"i82":10,"i83":10,"i84":10,"i85":10,"i86":10,"i87":10,"i88":10,"i89":10,"i90":10,"i91":10,"i92":10,"i93":10,"i94":10,"i95":10,"i96":10,"i97":10,"i98":10,"i99":10,"i100":10,"i101":10,"i102":10,"i103":10,"i104":10,"i105":10,"i106":10,"i107":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":10,"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,"i82":10,"i83":10,"i84":10,"i85":10,"i86":10,"i87":10,"i88":10,"i89":10,"i90":10,"i91":10,"i92":10,"i93":10,"i94":10,"i95":10,"i96":10,"i97":10,"i98":10,"i99":10,"i100":10,"i101":10,"i102":10,"i103":10,"i104":10,"i105":10,"i106":10,"i107":10,"i108":10,"i
 109":10,"i110":10};
 var tabs = {65535:["t0","All Methods"],2:["t2","Instance 
Methods"],8:["t4","Concrete Methods"]};
 var altColor = "altColor";
 var rowColor = "rowColor";
@@ -119,7 +119,7 @@ var activeTableTab = "activeTableTab";
 
 
 @InterfaceAudience.Private
-public class MasterRpcServices
+public class MasterRpcServices
 extends RSRpcServices
 implements 
org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.MasterService.BlockingInterface,
 
org.apache.hadoop.hbase.shaded.protobuf.generated.RegionServerStatusProtos.RegionServerStatusService.BlockingInterface,
 
org.apache.hadoop.hbase.shaded.protobuf.generated.LockServiceProtos.LockService.BlockingInterface,
 
org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.HbckService.BlockingInterface
 Implements the master RPC services.
@@ -286,23 +286,27 @@ implements 
org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.Master
 
 
 
+private boolean
+containMetaWals(ServerName serverName) 
+
+
 private MasterSwitchType
 convert(org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.MasterSwitchType switchType) 
 
-
+
 private 
org.apache.hadoop.hbase.shaded.protobuf.generated.RegionServerStatusProtos.RegionServerStartupResponse.Builder
 createConfigurationSubset() 
 
-
+
 org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.CreateNamespaceResponse
 createNamespace(org.apache.hbase.thirdparty.com.google.protobuf.RpcController controller,

org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.CreateNamespaceRequest request) 
 
-
+
 protected PriorityFunction
 createPriority() 
 
-
+
 protected RpcServerInterface
 createRpcServer(Server server,
org.apache.hadoop.conf.Configuration conf,
@@ -310,76 +314,76 @@ implements 
org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.Master
https://docs.oracle.com/javase/8/docs/api/java/net/InetSocketAddress.html?is-external=true";
 title="class or interface in java.net">InetSocketAddress bindAddress,
https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
 title="class or interface in java.lang">String name) 
 
-
+
 org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.CreateTableResponse
 createTable(org.apache.hbase.thirdparty.com.google.protobuf.RpcController controller,

org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProto

[03/18] hbase-site git commit: Published site at 02f5f171f51b7ed801355c8acdcfc4ad47c23a3e.

2018-10-30 Thread git-site-role
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/2752c924/devapidocs/src-html/org/apache/hadoop/hbase/master/procedure/PeerQueue.html
--
diff --git 
a/devapidocs/src-html/org/apache/hadoop/hbase/master/procedure/PeerQueue.html 
b/devapidocs/src-html/org/apache/hadoop/hbase/master/procedure/PeerQueue.html
index 77eb79e..cf46fb3 100644
--- 
a/devapidocs/src-html/org/apache/hadoop/hbase/master/procedure/PeerQueue.html
+++ 
b/devapidocs/src-html/org/apache/hadoop/hbase/master/procedure/PeerQueue.html
@@ -43,11 +43,14 @@
 035  }
 036
 037  private static boolean 
requirePeerExclusiveLock(PeerProcedureInterface proc) {
-038return proc.getPeerOperationType() != 
PeerOperationType.REFRESH
-039&& 
proc.getPeerOperationType() != PeerOperationType.SYNC_REPLICATION_REPLAY_WAL
-040&& 
proc.getPeerOperationType() != 
PeerOperationType.SYNC_REPLICATION_REPLAY_WAL_REMOTE;
-041  }
-042}
+038// These procedures will only be used 
as sub procedures, and if they are scheduled, it always
+039// means that the root procedure 
holds the xlock, so we do not need to hold any locks.
+040return proc.getPeerOperationType() != 
PeerOperationType.REFRESH &&
+041  proc.getPeerOperationType() != 
PeerOperationType.RECOVER_STANDBY &&
+042  proc.getPeerOperationType() != 
PeerOperationType.SYNC_REPLICATION_REPLAY_WAL &&
+043  proc.getPeerOperationType() != 
PeerOperationType.SYNC_REPLICATION_REPLAY_WAL_REMOTE;
+044  }
+045}
 
 
 

http://git-wip-us.apache.org/repos/asf/hbase-site/blob/2752c924/devapidocs/src-html/org/apache/hadoop/hbase/master/replication/AbstractPeerNoLockProcedure.html
--
diff --git 
a/devapidocs/src-html/org/apache/hadoop/hbase/master/replication/AbstractPeerNoLockProcedure.html
 
b/devapidocs/src-html/org/apache/hadoop/hbase/master/replication/AbstractPeerNoLockProcedure.html
new file mode 100644
index 000..eac3e9d
--- /dev/null
+++ 
b/devapidocs/src-html/org/apache/hadoop/hbase/master/replication/AbstractPeerNoLockProcedure.html
@@ -0,0 +1,170 @@
+http://www.w3.org/TR/html4/loose.dtd";>
+
+
+Source code
+
+
+
+
+001/**
+002 * Licensed to the Apache Software 
Foundation (ASF) under one
+003 * or more contributor license 
agreements.  See the NOTICE file
+004 * distributed with this work for 
additional information
+005 * regarding copyright ownership.  The 
ASF licenses this file
+006 * to you under the Apache License, 
Version 2.0 (the
+007 * "License"); you may not use this file 
except in compliance
+008 * with the License.  You may obtain a 
copy of the License at
+009 *
+010 * 
http://www.apache.org/licenses/LICENSE-2.0
+011 *
+012 * Unless required by applicable law or 
agreed to in writing, software
+013 * distributed under the License is 
distributed on an "AS IS" BASIS,
+014 * WITHOUT WARRANTIES OR CONDITIONS OF 
ANY KIND, either express or implied.
+015 * See the License for the specific 
language governing permissions and
+016 * limitations under the License.
+017 */
+018package 
org.apache.hadoop.hbase.master.replication;
+019
+020import java.io.IOException;
+021import 
org.apache.hadoop.hbase.master.procedure.MasterProcedureEnv;
+022import 
org.apache.hadoop.hbase.master.procedure.PeerProcedureInterface;
+023import 
org.apache.hadoop.hbase.procedure2.ProcedureStateSerializer;
+024import 
org.apache.hadoop.hbase.procedure2.ProcedureSuspendedException;
+025import 
org.apache.hadoop.hbase.procedure2.StateMachineProcedure;
+026import 
org.apache.yetus.audience.InterfaceAudience;
+027
+028import 
org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.PeerProcedureStateData;
+029import 
org.apache.hadoop.hbase.shaded.protobuf.generated.ProcedureProtos;
+030
+031/**
+032 * Base class for replication peer 
related procedures which do not need to hold locks(for most of
+033 * the sub procedures).
+034 */
+035@InterfaceAudience.Private
+036public abstract class 
AbstractPeerNoLockProcedure
+037extends 
StateMachineProcedure implements 
PeerProcedureInterface {
+038
+039  protected String peerId;
+040
+041  protected int attempts;
+042
+043  protected AbstractPeerNoLockProcedure() 
{
+044  }
+045
+046  protected 
AbstractPeerNoLockProcedure(String peerId) {
+047this.peerId = peerId;
+048  }
+049
+050  @Override
+051  public String getPeerId() {
+052return peerId;
+053  }
+054
+055  @Override
+056  protected boolean 
waitInitialized(MasterProcedureEnv env) {
+057return env.waitInitialized(this);
+058  }
+059
+060  @Override
+061  protected void 
rollbackState(MasterProcedureEnv env, TState state)
+062  throws IOException, 
InterruptedException {
+063if (state == getInitialState()) {
+064  // actually the peer related 
operations has no rollback, but if we haven't done any
+065  // modifications on the peer 
storage yet, we can just return.
+066

[14/18] hbase-site git commit: Published site at 02f5f171f51b7ed801355c8acdcfc4ad47c23a3e.

2018-10-30 Thread git-site-role
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/2752c924/devapidocs/org/apache/hadoop/hbase/master/assignment/AssignmentManager.html
--
diff --git 
a/devapidocs/org/apache/hadoop/hbase/master/assignment/AssignmentManager.html 
b/devapidocs/org/apache/hadoop/hbase/master/assignment/AssignmentManager.html
index 44ab859..6f98af1 100644
--- 
a/devapidocs/org/apache/hadoop/hbase/master/assignment/AssignmentManager.html
+++ 
b/devapidocs/org/apache/hadoop/hbase/master/assignment/AssignmentManager.html
@@ -781,7 +781,7 @@ implements stopAssignmentThread() 
 
 
-void
+long
 submitServerCrash(ServerName serverName,
  boolean shouldSplitWal) 
 
@@ -1175,7 +1175,7 @@ implements 
 
 STATES_EXPECTED_ON_OPEN
-private static final RegionState.State[] STATES_EXPECTED_ON_OPEN
+private static final RegionState.State[] STATES_EXPECTED_ON_OPEN
 
 
 
@@ -1184,7 +1184,7 @@ implements 
 
 STATES_EXPECTED_ON_CLOSING
-private static final RegionState.State[] STATES_EXPECTED_ON_CLOSING
+private static final RegionState.State[] STATES_EXPECTED_ON_CLOSING
 
 
 
@@ -1193,7 +1193,7 @@ implements 
 
 STATES_EXPECTED_ON_CLOSED
-private static final RegionState.State[] STATES_EXPECTED_ON_CLOSED
+private static final RegionState.State[] STATES_EXPECTED_ON_CLOSED
 
 
 
@@ -1202,7 +1202,7 @@ implements 
 
 STATES_EXPECTED_ON_ASSIGN
-private static final RegionState.State[] STATES_EXPECTED_ON_ASSIGN
+private static final RegionState.State[] STATES_EXPECTED_ON_ASSIGN
 
 
 
@@ -1211,7 +1211,7 @@ implements 
 
 STATES_EXPECTED_ON_UNASSIGN_OR_MOVE
-private static final RegionState.State[] STATES_EXPECTED_ON_UNASSIGN_OR_MOVE
+private static final RegionState.State[] STATES_EXPECTED_ON_UNASSIGN_OR_MOVE
 
 
 
@@ -1220,7 +1220,7 @@ implements 
 
 pendingAssignQueue
-private final https://docs.oracle.com/javase/8/docs/api/java/util/ArrayList.html?is-external=true";
 title="class or interface in java.util">ArrayList pendingAssignQueue
+private final https://docs.oracle.com/javase/8/docs/api/java/util/ArrayList.html?is-external=true";
 title="class or interface in java.util">ArrayList pendingAssignQueue
 
 
 
@@ -1229,7 +1229,7 @@ implements 
 
 assignQueueLock
-private final https://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 assignQueueLock
+private final https://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 assignQueueLock
 
 
 
@@ -1238,7 +1238,7 @@ implements 
 
 assignQueueFullCond
-private final https://docs.oracle.com/javase/8/docs/api/java/util/concurrent/locks/Condition.html?is-external=true";
 title="class or interface in java.util.concurrent.locks">Condition assignQueueFullCond
+private final https://docs.oracle.com/javase/8/docs/api/java/util/concurrent/locks/Condition.html?is-external=true";
 title="class or interface in java.util.concurrent.locks">Condition assignQueueFullCond
 
 
 
@@ -2143,7 +2143,7 @@ implements 
 
 submitServerCrash
-public void submitServerCrash(ServerName serverName,
+public long submitServerCrash(ServerName serverName,
   boolean shouldSplitWal)
 
 
@@ -2153,7 +2153,7 @@ implements 
 
 offlineRegion
-public void offlineRegion(RegionInfo regionInfo)
+public void offlineRegion(RegionInfo regionInfo)
 
 
 
@@ -2162,7 +2162,7 @@ implements 
 
 onlineRegion
-public void onlineRegion(RegionInfo regionInfo,
+public void onlineRegion(RegionInfo regionInfo,
  ServerName serverName)
 
 
@@ -2172,7 +2172,7 @@ implements 
 
 getSnapShotOfAssignment
-public https://docs.oracle.com/javase/8/docs/api/java/util/Map.html?is-external=true";
 title="class or interface in java.util">MapList> getSnapShotOfAssignment(https://docs.oracle.com/javase/8/docs/api/java/util/Collection.html?is-external=true";
 title="class or interface in java.util">Collection regions)
+public https://docs.oracle.com/javase/8/docs/api/java/util/Map.html?is-external=true";
 title="class or interface in java.util">MapList> getSnapShotOfAssignment(https://docs.oracle.com/javase/8/docs/api/java/util/Collection.html?is-external=true";
 title="class or interface in java.util">Collection regions)
 
 
 
@@ -2181,7 +2181,7 @@ implements 
 
 getReopenStatus
-public PairInteger,https://docs.oracle.com/javase/8/do

[13/18] hbase-site git commit: Published site at 02f5f171f51b7ed801355c8acdcfc4ad47c23a3e.

2018-10-30 Thread git-site-role
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/2752c924/devapidocs/org/apache/hadoop/hbase/master/replication/AbstractPeerNoLockProcedure.html
--
diff --git 
a/devapidocs/org/apache/hadoop/hbase/master/replication/AbstractPeerNoLockProcedure.html
 
b/devapidocs/org/apache/hadoop/hbase/master/replication/AbstractPeerNoLockProcedure.html
new file mode 100644
index 000..5566e0a
--- /dev/null
+++ 
b/devapidocs/org/apache/hadoop/hbase/master/replication/AbstractPeerNoLockProcedure.html
@@ -0,0 +1,596 @@
+http://www.w3.org/TR/html4/loose.dtd";>
+
+
+
+
+
+AbstractPeerNoLockProcedure (Apache HBase 3.0.0-SNAPSHOT API)
+
+
+
+
+
+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";
+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.master.replication
+Class 
AbstractPeerNoLockProcedure
+
+
+
+https://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.procedure2.Procedure
+
+
+org.apache.hadoop.hbase.procedure2.StateMachineProcedure
+
+
+org.apache.hadoop.hbase.master.replication.AbstractPeerNoLockProcedure
+
+
+
+
+
+
+
+
+
+
+
+All Implemented Interfaces:
+https://docs.oracle.com/javase/8/docs/api/java/lang/Comparable.html?is-external=true";
 title="class or interface in java.lang">Comparable>, PeerProcedureInterface
+
+
+Direct Known Subclasses:
+AbstractPeerProcedure, RecoverStandbyProcedure, SyncReplicationReplayWALProcedure
+
+
+
+@InterfaceAudience.Private
+public abstract class AbstractPeerNoLockProcedure
+extends StateMachineProcedure
+implements PeerProcedureInterface
+Base class for replication peer related procedures which do 
not need to hold locks(for most of
+ the sub procedures).
+
+
+
+
+
+
+
+
+
+
+
+Nested Class Summary
+
+
+
+
+Nested classes/interfaces inherited from 
class org.apache.hadoop.hbase.procedure2.StateMachineProcedure
+StateMachineProcedure.Flow
+
+
+
+
+
+Nested classes/interfaces inherited from 
class org.apache.hadoop.hbase.procedure2.Procedure
+Procedure.LockState
+
+
+
+
+
+Nested classes/interfaces inherited from 
interface org.apache.hadoop.hbase.master.procedure.PeerProcedureInterface
+PeerProcedureInterface.PeerOperationType
+
+
+
+
+
+
+
+
+Field Summary
+
+Fields 
+
+Modifier and Type
+Field and Description
+
+
+protected int
+attempts 
+
+
+protected https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
 title="class or interface in java.lang">String
+peerId 
+
+
+
+
+
+
+Fields inherited from class org.apache.hadoop.hbase.procedure2.StateMachineProcedure
+stateCount
+
+
+
+
+
+Fields inherited from class org.apache.hadoop.hbase.procedure2.Procedure
+NO_PROC_ID,
 NO_TIMEOUT
+
+
+
+
+
+
+
+
+Constructor Summary
+
+Constructors 
+
+Modifier
+Constructor and Description
+
+
+protected 
+AbstractPeerNoLockProcedure() 
+
+
+protected 
+AbstractPeerNoLockProcedure(https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
 title="class or interface in 
java.lang">String peerId) 
+
+
+
+
+
+
+
+
+
+Method Summary
+
+All Methods Instance Methods Concrete Methods 
+
+Modifier and Type
+Method and Description
+
+
+protected void
+deserializeStateData(ProcedureStateSerializer serializer)
+Called on store load to allow the user to decode the 
previously serialized
+ state.
+
+
+
+https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
 title="class or interface in java.lang">String
+getPeerId() 
+
+
+protected void
+rollbackState(MasterProcedureEnv env,
+ TState state)
+called to perform the rollback of the specified state
+
+
+
+protected void
+serializeStateData(ProcedureStateSerializer serializer)
+The user-level code of the procedure may have some state to
+ persist (e.g.
+
+
+
+protected boolean
+

[09/18] hbase-site git commit: Published site at 02f5f171f51b7ed801355c8acdcfc4ad47c23a3e.

2018-10-30 Thread git-site-role
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/2752c924/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 1de9f1b..79f4077 100644
--- a/devapidocs/org/apache/hadoop/hbase/quotas/package-tree.html
+++ b/devapidocs/org/apache/hadoop/hbase/quotas/package-tree.html
@@ -229,13 +229,13 @@
 
 java.lang.https://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.https://docs.oracle.com/javase/8/docs/api/java/lang/Comparable.html?is-external=true";
 title="class or interface in java.lang">Comparable, java.io.https://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.QuotaType
-org.apache.hadoop.hbase.quotas.ThrottleType
-org.apache.hadoop.hbase.quotas.OperationQuota.OperationType
 org.apache.hadoop.hbase.quotas.ThrottlingException.Type
-org.apache.hadoop.hbase.quotas.QuotaScope
 org.apache.hadoop.hbase.quotas.RpcThrottlingException.Type
+org.apache.hadoop.hbase.quotas.OperationQuota.OperationType
+org.apache.hadoop.hbase.quotas.ThrottleType
+org.apache.hadoop.hbase.quotas.QuotaScope
 org.apache.hadoop.hbase.quotas.SpaceViolationPolicy
+org.apache.hadoop.hbase.quotas.QuotaType
 
 
 

http://git-wip-us.apache.org/repos/asf/hbase-site/blob/2752c924/devapidocs/org/apache/hadoop/hbase/regionserver/package-tree.html
--
diff --git a/devapidocs/org/apache/hadoop/hbase/regionserver/package-tree.html 
b/devapidocs/org/apache/hadoop/hbase/regionserver/package-tree.html
index 93ae722..bc94426 100644
--- a/devapidocs/org/apache/hadoop/hbase/regionserver/package-tree.html
+++ b/devapidocs/org/apache/hadoop/hbase/regionserver/package-tree.html
@@ -717,19 +717,19 @@
 java.lang.https://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.https://docs.oracle.com/javase/8/docs/api/java/lang/Comparable.html?is-external=true";
 title="class or interface in java.lang">Comparable, java.io.https://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.regionserver.HRegion.FlushResult.Result
-org.apache.hadoop.hbase.regionserver.FlushType
-org.apache.hadoop.hbase.regionserver.CompactingMemStore.IndexType
-org.apache.hadoop.hbase.regionserver.ScannerContext.NextState
 org.apache.hadoop.hbase.regionserver.ScannerContext.LimitScope
-org.apache.hadoop.hbase.regionserver.TimeRangeTracker.Type
+org.apache.hadoop.hbase.regionserver.CompactingMemStore.IndexType
+org.apache.hadoop.hbase.regionserver.FlushType
 org.apache.hadoop.hbase.regionserver.Region.Operation
+org.apache.hadoop.hbase.regionserver.MemStoreCompactionStrategy.Action
+org.apache.hadoop.hbase.regionserver.TimeRangeTracker.Type
 org.apache.hadoop.hbase.regionserver.SplitLogWorker.TaskExecutor.Status
-org.apache.hadoop.hbase.regionserver.ChunkCreator.ChunkType
-org.apache.hadoop.hbase.regionserver.BloomType
+org.apache.hadoop.hbase.regionserver.ScannerContext.NextState
 org.apache.hadoop.hbase.regionserver.MetricsRegionServerSourceFactoryImpl.FactoryStorage
-org.apache.hadoop.hbase.regionserver.MemStoreCompactionStrategy.Action
-org.apache.hadoop.hbase.regionserver.DefaultHeapMemoryTuner.StepDirection
 org.apache.hadoop.hbase.regionserver.ScanType
+org.apache.hadoop.hbase.regionserver.DefaultHeapMemoryTuner.StepDirection
+org.apache.hadoop.hbase.regionserver.BloomType
+org.apache.hadoop.hbase.regionserver.ChunkCreator.ChunkType
 
 
 

http://git-wip-us.apache.org/repos/asf/hbase-site/blob/2752c924/devapidocs/org/apache/hadoop/hbase/regionserver/wal/package-tree.html
--
diff --git 
a/devapidocs/org/apache/hadoop/hbase/regionserver/wal/package-tree.html 
b/devapidocs/org/apache/hadoop/hbase/regionserver/wal/package-tree.html
index f0c55c8..feee307 100644
--- a/devapidocs/org/apache/hadoop/hbase/regionserver/wal/package-tree.html
+++ b/devapidocs/org/apache/hadoop/hbase/regionserver/wal/package-tree.html
@@ -248,8 +248,8 @@
 java.lang.https://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.https://docs.oracle.com/javase/8/docs/api/java/lang/Comparable.html?is-external=true";
 title="class or interface in java.lang">Comparable, java.io.https://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.regionserver.wal.RingBufferTruck

[01/18] hbase-site git commit: Published site at 02f5f171f51b7ed801355c8acdcfc4ad47c23a3e.

2018-10-30 Thread git-site-role
Repository: hbase-site
Updated Branches:
  refs/heads/asf-site 51db083d7 -> 2752c9244


http://git-wip-us.apache.org/repos/asf/hbase-site/blob/2752c924/testdevapidocs/src-html/org/apache/hadoop/hbase/client/TestHbck.html
--
diff --git 
a/testdevapidocs/src-html/org/apache/hadoop/hbase/client/TestHbck.html 
b/testdevapidocs/src-html/org/apache/hadoop/hbase/client/TestHbck.html
index f032370..6138b0c 100644
--- a/testdevapidocs/src-html/org/apache/hadoop/hbase/client/TestHbck.html
+++ b/testdevapidocs/src-html/org/apache/hadoop/hbase/client/TestHbck.html
@@ -36,160 +36,181 @@
 028
 029import 
org.apache.hadoop.hbase.HBaseClassTestRule;
 030import 
org.apache.hadoop.hbase.HBaseTestingUtility;
-031import 
org.apache.hadoop.hbase.TableName;
-032import 
org.apache.hadoop.hbase.master.RegionState;
-033import 
org.apache.hadoop.hbase.master.procedure.MasterProcedureEnv;
-034import 
org.apache.hadoop.hbase.master.procedure.TableProcedureInterface;
-035import 
org.apache.hadoop.hbase.procedure2.Procedure;
-036import 
org.apache.hadoop.hbase.procedure2.ProcedureExecutor;
-037import 
org.apache.hadoop.hbase.procedure2.ProcedureSuspendedException;
-038import 
org.apache.hadoop.hbase.procedure2.ProcedureTestingUtility;
-039import 
org.apache.hadoop.hbase.testclassification.ClientTests;
-040import 
org.apache.hadoop.hbase.testclassification.LargeTests;
-041import 
org.apache.hadoop.hbase.util.Bytes;
-042import 
org.apache.hadoop.hbase.util.Threads;
-043import org.junit.AfterClass;
-044import org.junit.BeforeClass;
-045import org.junit.ClassRule;
-046import org.junit.Rule;
-047import org.junit.Test;
-048import 
org.junit.experimental.categories.Category;
-049import org.junit.rules.TestName;
-050import org.slf4j.Logger;
-051import org.slf4j.LoggerFactory;
-052
-053/**
-054 * Class to test HBaseHbck.
-055 * Spins up the minicluster once at test 
start and then takes it down afterward.
-056 * Add any testing of HBaseHbck 
functionality here.
-057 */
-058@Category({LargeTests.class, 
ClientTests.class})
-059public class TestHbck {
-060  @ClassRule
-061  public static final HBaseClassTestRule 
CLASS_RULE =
-062  
HBaseClassTestRule.forClass(TestHbck.class);
-063
-064  private static final Logger LOG = 
LoggerFactory.getLogger(TestHbck.class);
-065  private final static 
HBaseTestingUtility TEST_UTIL = new HBaseTestingUtility();
-066
-067  @Rule
-068  public TestName name = new 
TestName();
-069
-070  private static final TableName 
TABLE_NAME = TableName.valueOf(TestHbck.class.getSimpleName());
-071
-072  private static 
ProcedureExecutor procExec;
+031import 
org.apache.hadoop.hbase.ServerName;
+032import 
org.apache.hadoop.hbase.TableName;
+033import 
org.apache.hadoop.hbase.master.RegionState;
+034import 
org.apache.hadoop.hbase.master.procedure.MasterProcedureEnv;
+035import 
org.apache.hadoop.hbase.master.procedure.TableProcedureInterface;
+036import 
org.apache.hadoop.hbase.procedure2.Procedure;
+037import 
org.apache.hadoop.hbase.procedure2.ProcedureExecutor;
+038import 
org.apache.hadoop.hbase.procedure2.ProcedureSuspendedException;
+039import 
org.apache.hadoop.hbase.procedure2.ProcedureTestingUtility;
+040import 
org.apache.hadoop.hbase.regionserver.HRegionServer;
+041import 
org.apache.hadoop.hbase.testclassification.ClientTests;
+042import 
org.apache.hadoop.hbase.testclassification.LargeTests;
+043import 
org.apache.hadoop.hbase.util.Bytes;
+044import 
org.apache.hadoop.hbase.util.Threads;
+045import org.junit.AfterClass;
+046import org.junit.BeforeClass;
+047import org.junit.ClassRule;
+048import org.junit.Rule;
+049import org.junit.Test;
+050import 
org.junit.experimental.categories.Category;
+051import org.junit.rules.TestName;
+052import org.slf4j.Logger;
+053import org.slf4j.LoggerFactory;
+054
+055import 
org.apache.hadoop.hbase.shaded.protobuf.ProtobufUtil;
+056
+057/**
+058 * Class to test HBaseHbck.
+059 * Spins up the minicluster once at test 
start and then takes it down afterward.
+060 * Add any testing of HBaseHbck 
functionality here.
+061 */
+062@Category({LargeTests.class, 
ClientTests.class})
+063public class TestHbck {
+064  @ClassRule
+065  public static final HBaseClassTestRule 
CLASS_RULE =
+066  
HBaseClassTestRule.forClass(TestHbck.class);
+067
+068  private static final Logger LOG = 
LoggerFactory.getLogger(TestHbck.class);
+069  private final static 
HBaseTestingUtility TEST_UTIL = new HBaseTestingUtility();
+070
+071  @Rule
+072  public TestName name = new 
TestName();
 073
-074  @BeforeClass
-075  public static void setUpBeforeClass() 
throws Exception {
-076TEST_UTIL.startMiniCluster(3);
-077
TEST_UTIL.createMultiRegionTable(TABLE_NAME, Bytes.toBytes("family1"), 5);
-078procExec = 
TEST_UTIL.getMiniHBaseCluster().getMaster().getMasterProcedureExecutor();
-079  }
-080
-081  @AfterClass
-082  public static void tearDownAfterClass() 
throws Exception {
-083TEST_UTIL.shutdownMiniC

hbase-site git commit: INFRA-10751 Empty commit

2018-10-30 Thread git-site-role
Repository: hbase-site
Updated Branches:
  refs/heads/asf-site 2752c9244 -> e4594033d


INFRA-10751 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/e4594033
Tree: http://git-wip-us.apache.org/repos/asf/hbase-site/tree/e4594033
Diff: http://git-wip-us.apache.org/repos/asf/hbase-site/diff/e4594033

Branch: refs/heads/asf-site
Commit: e4594033ddd3bf5f76b578ab2d1c27cfbc659f83
Parents: 2752c92
Author: jenkins 
Authored: Tue Oct 30 14:54:31 2018 +
Committer: jenkins 
Committed: Tue Oct 30 14:54:31 2018 +

--

--




[11/18] hbase-site git commit: Published site at 02f5f171f51b7ed801355c8acdcfc4ad47c23a3e.

2018-10-30 Thread git-site-role
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/2752c924/devapidocs/org/apache/hadoop/hbase/master/replication/ModifyPeerProcedure.html
--
diff --git 
a/devapidocs/org/apache/hadoop/hbase/master/replication/ModifyPeerProcedure.html
 
b/devapidocs/org/apache/hadoop/hbase/master/replication/ModifyPeerProcedure.html
index e64b85b..fccb3b5 100644
--- 
a/devapidocs/org/apache/hadoop/hbase/master/replication/ModifyPeerProcedure.html
+++ 
b/devapidocs/org/apache/hadoop/hbase/master/replication/ModifyPeerProcedure.html
@@ -106,6 +106,9 @@ var activeTableTab = "activeTableTab";
 org.apache.hadoop.hbase.procedure2.StateMachineProcedure
 
 
+org.apache.hadoop.hbase.master.replication.AbstractPeerNoLockProcedure
+
+
 org.apache.hadoop.hbase.master.replication.AbstractPeerProcedure
 
 
@@ -119,6 +122,8 @@ var activeTableTab = "activeTableTab";
 
 
 
+
+
 
 
 
@@ -202,7 +207,14 @@ extends AbstractPeerProcedure
-attempts,
 latch,
 peerId
+latch
+
+
+
+
+
+Fields inherited from 
class org.apache.hadoop.hbase.master.replication.AbstractPeerNoLockProcedure
+attempts,
 peerId
 
 
 
@@ -363,7 +375,14 @@ extends AbstractPeerProcedure
-acquireLock,
 deserializeStateData,
 enablePeer,
 getLatch,
 getPeerId,
 holdLock, refreshPeer,
 releaseLock,
 rollbackState,
 serializeStateData,
 setTimeoutFailure,
 suspend,
 waitInitialized
+acquireLock,
 enablePeer,
 getLatch,
 holdLock,
 refreshPeer,
 releaseLock
+
+
+
+
+
+Methods inherited from 
class org.apache.hadoop.hbase.master.replication.AbstractPeerNoLockProcedure
+deserializeStateData,
 getPeerId,
 rollbackState,
 serializeStateData,
 setTimeoutFailure,
 suspend,
 waitInitialized
 
 
 
@@ -391,7 +410,7 @@ extends PeerProcedureInterface
-getPeerOperationType
+getPeerId,
 getPeerOperationType
 
 
 

http://git-wip-us.apache.org/repos/asf/hbase-site/blob/2752c924/devapidocs/org/apache/hadoop/hbase/master/replication/RecoverStandbyProcedure.html
--
diff --git 
a/devapidocs/org/apache/hadoop/hbase/master/replication/RecoverStandbyProcedure.html
 
b/devapidocs/org/apache/hadoop/hbase/master/replication/RecoverStandbyProcedure.html
index 2059b16..3aa6730 100644
--- 
a/devapidocs/org/apache/hadoop/hbase/master/replication/RecoverStandbyProcedure.html
+++ 
b/devapidocs/org/apache/hadoop/hbase/master/replication/RecoverStandbyProcedure.html
@@ -106,7 +106,7 @@ var activeTableTab = "activeTableTab";
 org.apache.hadoop.hbase.procedure2.StateMachineProcedure
 
 
-org.apache.hadoop.hbase.master.replication.AbstractPeerProcedure
+org.apache.hadoop.hbase.master.replication.AbstractPeerNoLockProcedure
 
 
 org.apache.hadoop.hbase.master.replication.RecoverStandbyProcedure
@@ -130,7 +130,7 @@ var activeTableTab = "activeTableTab";
 
 @InterfaceAudience.Private
 public class RecoverStandbyProcedure
-extends AbstractPeerProcedure
+extends AbstractPeerNoLockProcedure
 
 
 
@@ -188,11 +188,11 @@ extends 
-
+
 
 
-Fields inherited from 
class org.apache.hadoop.hbase.master.replication.AbstractPeerProcedure
-attempts,
 latch,
 peerId
+Fields inherited from 
class org.apache.hadoop.hbase.master.replication.AbstractPeerNoLockProcedure
+attempts,
 peerId
 
 
 
@@ -292,11 +292,11 @@ extends 
-
+
 
 
-Methods inherited from 
class org.apache.hadoop.hbase.master.replication.AbstractPeerProcedure
-acquireLock,
 enablePeer,
 getLatch,
 getPeerId,
 holdLock,
 refreshPeer,
 releaseLock,
 rollbackState,
 setTimeoutFailure,
 suspend,
 waitInitialized<
 /li>
+Methods inherited from 
class org.apache.hadoop.hbase.master.replication.AbstractPeerNoLockProcedure
+getPeerId,
 rollbackState,
 setTimeoutFailure,
 suspend,
 waitInitialized
 
 
 
@@ -310,7 +310,7 @@ extends Procedure
-addStackIndex,
 afterReplay,
 beforeReplay,
 bypass,
 compareTo,
 completionCleanup,
 doExecute,
 doRollback,
 elapsedTime,
 getChildrenLatch,
 getException,
 getLastUpdate,
 getNonceKey,
 getOwner,
 getParentProcId,
 getProcedureMetrics,
 getProcId, getProcIdHashCode,
 getProcName,
 getResult,
 getRootProcedureId,
 getRootProcId,
 getStackIndexes,
 getState,
 getSubmittedTime,
 <
 a 
href="../../../../../../org/apache/hadoop/hbase/procedure2/Procedure.html#getTimeout--">getTimeout,
 getTimeoutTimestamp,
 hasChildren,
 hasException,
 hasLock,
 hasOwner,
 hasParent,
 hasTimeout,
 haveSameParent, incChildrenLatch,
 isBypass,
 isFailed,
 isFinished,
 isInitializing,
 isLockedWhenLoading,
 

[04/18] hbase-site git commit: Published site at 02f5f171f51b7ed801355c8acdcfc4ad47c23a3e.

2018-10-30 Thread git-site-role
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/2752c924/devapidocs/src-html/org/apache/hadoop/hbase/master/assignment/AssignmentManager.html
--
diff --git 
a/devapidocs/src-html/org/apache/hadoop/hbase/master/assignment/AssignmentManager.html
 
b/devapidocs/src-html/org/apache/hadoop/hbase/master/assignment/AssignmentManager.html
index 801dc55..5d3c5eb 100644
--- 
a/devapidocs/src-html/org/apache/hadoop/hbase/master/assignment/AssignmentManager.html
+++ 
b/devapidocs/src-html/org/apache/hadoop/hbase/master/assignment/AssignmentManager.html
@@ -1369,556 +1369,557 @@
 1361return 0;
 1362  }
 1363
-1364  public void submitServerCrash(final 
ServerName serverName, final boolean shouldSplitWal) {
+1364  public long submitServerCrash(final 
ServerName serverName, final boolean shouldSplitWal) {
 1365boolean carryingMeta = 
isCarryingMeta(serverName);
 1366
ProcedureExecutor procExec = 
this.master.getMasterProcedureExecutor();
-1367procExec.submitProcedure(new 
ServerCrashProcedure(procExec.getEnvironment(), serverName,
-1368  shouldSplitWal, carryingMeta));
-1369LOG.debug("Added=" + serverName +
-1370  " to dead servers, submitted 
shutdown handler to be executed meta=" + carryingMeta);
-1371  }
-1372
-1373  public void offlineRegion(final 
RegionInfo regionInfo) {
-1374// TODO used by MasterRpcServices
-1375RegionStateNode node = 
regionStates.getRegionStateNode(regionInfo);
-1376if (node != null) {
-1377  node.offline();
-1378}
-1379  }
-1380
-1381  public void onlineRegion(final 
RegionInfo regionInfo, final ServerName serverName) {
-1382// TODO used by 
TestSplitTransactionOnCluster.java
-1383  }
-1384
-1385  public Map> getSnapShotOfAssignment(
-1386  final Collection 
regions) {
-1387return 
regionStates.getSnapShotOfAssignment(regions);
-1388  }
-1389
-1390  // 

-1391  //  TODO: UTILS/HELPERS?
-1392  // 

-1393  /**
-1394   * Used by the client (via master) to 
identify if all regions have the schema updates
-1395   *
-1396   * @param tableName
-1397   * @return Pair indicating the status 
of the alter command (pending/total)
-1398   * @throws IOException
-1399   */
-1400  public Pair 
getReopenStatus(TableName tableName) {
-1401if (isTableDisabled(tableName)) 
return new Pair(0, 0);
-1402
-1403final List states 
= regionStates.getTableRegionStates(tableName);
-1404int ritCount = 0;
-1405for (RegionState regionState: 
states) {
-1406  if (!regionState.isOpened()) 
ritCount++;
-1407}
-1408return new Pair(ritCount, states.size());
-1409  }
-1410
-1411  // 

-1412  //  TODO: Region State In Transition
-1413  // 

-1414  public boolean 
hasRegionsInTransition() {
-1415return 
regionStates.hasRegionsInTransition();
-1416  }
-1417
-1418  public List 
getRegionsInTransition() {
-1419return 
regionStates.getRegionsInTransition();
-1420  }
-1421
-1422  public List 
getAssignedRegions() {
-1423return 
regionStates.getAssignedRegions();
-1424  }
-1425
-1426  public RegionInfo getRegionInfo(final 
byte[] regionName) {
-1427final RegionStateNode regionState = 
regionStates.getRegionStateNodeFromName(regionName);
-1428return regionState != null ? 
regionState.getRegionInfo() : null;
-1429  }
-1430
-1431  // 

-1432  //  Expected states on region state 
transition.
-1433  //  Notice that there is expected 
states for transiting to OPENING state, this is because SCP.
-1434  //  See the comments in regionOpening 
method for more details.
-1435  // 

-1436  private static final State[] 
STATES_EXPECTED_ON_OPEN = {
-1437State.OPENING, // Normal case
-1438State.OPEN // Retrying
-1439  };
-1440
-1441  private static final State[] 
STATES_EXPECTED_ON_CLOSING = {
-1442State.OPEN, // Normal case
-1443State.CLOSING, // Retrying
-1444State.SPLITTING, // Offline the 
split parent
-1445State.MERGING // Offline the merge 
parents
-1446  };
-1447
-1448  private static final State[] 
STATES_EXPECTED_ON_CLOSED = {
-1449State.CLOSING, // Normal case
-1450State.CLOSED // Retrying
-1451  };
-1452
-1453  // This is for manually scheduled 
region assign, can add other states later if we find out other
-1454  // usages
-1455  priva

[08/18] hbase-site git commit: Published site at 02f5f171f51b7ed801355c8acdcfc4ad47c23a3e.

2018-10-30 Thread git-site-role
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/2752c924/devapidocs/src-html/org/apache/hadoop/hbase/master/MasterRpcServices.BalanceSwitchMode.html
--
diff --git 
a/devapidocs/src-html/org/apache/hadoop/hbase/master/MasterRpcServices.BalanceSwitchMode.html
 
b/devapidocs/src-html/org/apache/hadoop/hbase/master/MasterRpcServices.BalanceSwitchMode.html
index 4365cc5..2cdee19 100644
--- 
a/devapidocs/src-html/org/apache/hadoop/hbase/master/MasterRpcServices.BalanceSwitchMode.html
+++ 
b/devapidocs/src-html/org/apache/hadoop/hbase/master/MasterRpcServices.BalanceSwitchMode.html
@@ -26,2436 +26,2490 @@
 018 */
 019package org.apache.hadoop.hbase.master;
 020
-021import java.io.IOException;
-022import java.net.BindException;
-023import java.net.InetAddress;
-024import java.net.InetSocketAddress;
-025import java.util.ArrayList;
-026import java.util.HashMap;
-027import java.util.HashSet;
-028import java.util.List;
-029import java.util.Map;
-030import java.util.Map.Entry;
-031import java.util.Set;
-032import java.util.stream.Collectors;
-033import 
org.apache.hadoop.conf.Configuration;
-034import 
org.apache.hadoop.hbase.ClusterMetricsBuilder;
-035import 
org.apache.hadoop.hbase.DoNotRetryIOException;
-036import 
org.apache.hadoop.hbase.HConstants;
-037import 
org.apache.hadoop.hbase.MetaTableAccessor;
-038import 
org.apache.hadoop.hbase.NamespaceDescriptor;
-039import org.apache.hadoop.hbase.Server;
-040import 
org.apache.hadoop.hbase.ServerMetrics;
-041import 
org.apache.hadoop.hbase.ServerMetricsBuilder;
-042import 
org.apache.hadoop.hbase.ServerName;
-043import 
org.apache.hadoop.hbase.TableName;
-044import 
org.apache.hadoop.hbase.UnknownRegionException;
-045import 
org.apache.hadoop.hbase.client.ColumnFamilyDescriptor;
-046import 
org.apache.hadoop.hbase.client.MasterSwitchType;
-047import 
org.apache.hadoop.hbase.client.RegionInfo;
-048import 
org.apache.hadoop.hbase.client.RegionInfoBuilder;
-049import 
org.apache.hadoop.hbase.client.TableDescriptor;
-050import 
org.apache.hadoop.hbase.client.TableState;
-051import 
org.apache.hadoop.hbase.client.VersionInfoUtil;
-052import 
org.apache.hadoop.hbase.client.replication.ReplicationPeerConfigUtil;
-053import 
org.apache.hadoop.hbase.coprocessor.MasterCoprocessor;
-054import 
org.apache.hadoop.hbase.errorhandling.ForeignException;
-055import 
org.apache.hadoop.hbase.exceptions.UnknownProtocolException;
-056import 
org.apache.hadoop.hbase.io.hfile.HFile;
-057import 
org.apache.hadoop.hbase.ipc.CoprocessorRpcUtils;
-058import 
org.apache.hadoop.hbase.ipc.PriorityFunction;
-059import 
org.apache.hadoop.hbase.ipc.QosPriority;
-060import 
org.apache.hadoop.hbase.ipc.RpcServer;
-061import 
org.apache.hadoop.hbase.ipc.RpcServer.BlockingServiceAndInterface;
-062import 
org.apache.hadoop.hbase.ipc.RpcServerFactory;
-063import 
org.apache.hadoop.hbase.ipc.RpcServerInterface;
-064import 
org.apache.hadoop.hbase.ipc.ServerRpcController;
-065import 
org.apache.hadoop.hbase.master.assignment.RegionStates;
-066import 
org.apache.hadoop.hbase.master.locking.LockProcedure;
-067import 
org.apache.hadoop.hbase.master.procedure.MasterProcedureUtil;
-068import 
org.apache.hadoop.hbase.master.procedure.MasterProcedureUtil.NonceProcedureRunnable;
-069import 
org.apache.hadoop.hbase.mob.MobUtils;
-070import 
org.apache.hadoop.hbase.procedure.MasterProcedureManager;
-071import 
org.apache.hadoop.hbase.procedure2.LockType;
-072import 
org.apache.hadoop.hbase.procedure2.LockedResource;
-073import 
org.apache.hadoop.hbase.procedure2.Procedure;
-074import 
org.apache.hadoop.hbase.procedure2.ProcedureExecutor;
-075import 
org.apache.hadoop.hbase.procedure2.ProcedureUtil;
-076import 
org.apache.hadoop.hbase.procedure2.RemoteProcedureException;
-077import 
org.apache.hadoop.hbase.protobuf.generated.AccessControlProtos.AccessControlService;
-078import 
org.apache.hadoop.hbase.protobuf.generated.VisibilityLabelsProtos.VisibilityLabelsService;
-079import 
org.apache.hadoop.hbase.quotas.MasterQuotaManager;
-080import 
org.apache.hadoop.hbase.quotas.QuotaObserverChore;
-081import 
org.apache.hadoop.hbase.quotas.QuotaUtil;
-082import 
org.apache.hadoop.hbase.quotas.SpaceQuotaSnapshot;
-083import 
org.apache.hadoop.hbase.regionserver.RSRpcServices;
-084import 
org.apache.hadoop.hbase.regionserver.RpcSchedulerFactory;
-085import 
org.apache.hadoop.hbase.replication.ReplicationException;
-086import 
org.apache.hadoop.hbase.replication.ReplicationPeerConfig;
-087import 
org.apache.hadoop.hbase.replication.ReplicationPeerDescription;
-088import 
org.apache.hadoop.hbase.security.User;
-089import 
org.apache.hadoop.hbase.security.access.AccessChecker;
-090import 
org.apache.hadoop.hbase.security.access.AccessController;
-091import 
org.apache.hadoop.hbase.security.access.Permission;
-092import 
org.apache.hadoop.hbase.security.visibility.VisibilityController;
-093import 
org.apache.hadoop.hbase.snapshot.ClientSnapshotDescriptionUti

[06/18] hbase-site git commit: Published site at 02f5f171f51b7ed801355c8acdcfc4ad47c23a3e.

2018-10-30 Thread git-site-role
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/2752c924/devapidocs/src-html/org/apache/hadoop/hbase/master/assignment/AssignmentManager.RegionInTransitionChore.html
--
diff --git 
a/devapidocs/src-html/org/apache/hadoop/hbase/master/assignment/AssignmentManager.RegionInTransitionChore.html
 
b/devapidocs/src-html/org/apache/hadoop/hbase/master/assignment/AssignmentManager.RegionInTransitionChore.html
index 801dc55..5d3c5eb 100644
--- 
a/devapidocs/src-html/org/apache/hadoop/hbase/master/assignment/AssignmentManager.RegionInTransitionChore.html
+++ 
b/devapidocs/src-html/org/apache/hadoop/hbase/master/assignment/AssignmentManager.RegionInTransitionChore.html
@@ -1369,556 +1369,557 @@
 1361return 0;
 1362  }
 1363
-1364  public void submitServerCrash(final 
ServerName serverName, final boolean shouldSplitWal) {
+1364  public long submitServerCrash(final 
ServerName serverName, final boolean shouldSplitWal) {
 1365boolean carryingMeta = 
isCarryingMeta(serverName);
 1366
ProcedureExecutor procExec = 
this.master.getMasterProcedureExecutor();
-1367procExec.submitProcedure(new 
ServerCrashProcedure(procExec.getEnvironment(), serverName,
-1368  shouldSplitWal, carryingMeta));
-1369LOG.debug("Added=" + serverName +
-1370  " to dead servers, submitted 
shutdown handler to be executed meta=" + carryingMeta);
-1371  }
-1372
-1373  public void offlineRegion(final 
RegionInfo regionInfo) {
-1374// TODO used by MasterRpcServices
-1375RegionStateNode node = 
regionStates.getRegionStateNode(regionInfo);
-1376if (node != null) {
-1377  node.offline();
-1378}
-1379  }
-1380
-1381  public void onlineRegion(final 
RegionInfo regionInfo, final ServerName serverName) {
-1382// TODO used by 
TestSplitTransactionOnCluster.java
-1383  }
-1384
-1385  public Map> getSnapShotOfAssignment(
-1386  final Collection 
regions) {
-1387return 
regionStates.getSnapShotOfAssignment(regions);
-1388  }
-1389
-1390  // 

-1391  //  TODO: UTILS/HELPERS?
-1392  // 

-1393  /**
-1394   * Used by the client (via master) to 
identify if all regions have the schema updates
-1395   *
-1396   * @param tableName
-1397   * @return Pair indicating the status 
of the alter command (pending/total)
-1398   * @throws IOException
-1399   */
-1400  public Pair 
getReopenStatus(TableName tableName) {
-1401if (isTableDisabled(tableName)) 
return new Pair(0, 0);
-1402
-1403final List states 
= regionStates.getTableRegionStates(tableName);
-1404int ritCount = 0;
-1405for (RegionState regionState: 
states) {
-1406  if (!regionState.isOpened()) 
ritCount++;
-1407}
-1408return new Pair(ritCount, states.size());
-1409  }
-1410
-1411  // 

-1412  //  TODO: Region State In Transition
-1413  // 

-1414  public boolean 
hasRegionsInTransition() {
-1415return 
regionStates.hasRegionsInTransition();
-1416  }
-1417
-1418  public List 
getRegionsInTransition() {
-1419return 
regionStates.getRegionsInTransition();
-1420  }
-1421
-1422  public List 
getAssignedRegions() {
-1423return 
regionStates.getAssignedRegions();
-1424  }
-1425
-1426  public RegionInfo getRegionInfo(final 
byte[] regionName) {
-1427final RegionStateNode regionState = 
regionStates.getRegionStateNodeFromName(regionName);
-1428return regionState != null ? 
regionState.getRegionInfo() : null;
-1429  }
-1430
-1431  // 

-1432  //  Expected states on region state 
transition.
-1433  //  Notice that there is expected 
states for transiting to OPENING state, this is because SCP.
-1434  //  See the comments in regionOpening 
method for more details.
-1435  // 

-1436  private static final State[] 
STATES_EXPECTED_ON_OPEN = {
-1437State.OPENING, // Normal case
-1438State.OPEN // Retrying
-1439  };
-1440
-1441  private static final State[] 
STATES_EXPECTED_ON_CLOSING = {
-1442State.OPEN, // Normal case
-1443State.CLOSING, // Retrying
-1444State.SPLITTING, // Offline the 
split parent
-1445State.MERGING // Offline the merge 
parents
-1446  };
-1447
-1448  private static final State[] 
STATES_EXPECTED_ON_CLOSED = {
-1449State.CLOSING, // Normal case
-1450State.CLOSED // Retrying
-1451  };
-1452
-1453  // This

[16/18] hbase-site git commit: Published site at 02f5f171f51b7ed801355c8acdcfc4ad47c23a3e.

2018-10-30 Thread git-site-role
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/2752c924/devapidocs/org/apache/hadoop/hbase/io/hfile/package-tree.html
--
diff --git a/devapidocs/org/apache/hadoop/hbase/io/hfile/package-tree.html 
b/devapidocs/org/apache/hadoop/hbase/io/hfile/package-tree.html
index 9956ffd..008643d 100644
--- a/devapidocs/org/apache/hadoop/hbase/io/hfile/package-tree.html
+++ b/devapidocs/org/apache/hadoop/hbase/io/hfile/package-tree.html
@@ -274,12 +274,12 @@
 
 java.lang.https://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.https://docs.oracle.com/javase/8/docs/api/java/lang/Comparable.html?is-external=true";
 title="class or interface in java.lang">Comparable, java.io.https://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.io.hfile.HFileBlock.Writer.State
 org.apache.hadoop.hbase.io.hfile.BlockPriority
 org.apache.hadoop.hbase.io.hfile.CacheConfig.ExternalBlockCaches
-org.apache.hadoop.hbase.io.hfile.HFileBlock.Writer.State
+org.apache.hadoop.hbase.io.hfile.Cacheable.MemoryType
 org.apache.hadoop.hbase.io.hfile.BlockType
 org.apache.hadoop.hbase.io.hfile.BlockType.BlockCategory
-org.apache.hadoop.hbase.io.hfile.Cacheable.MemoryType
 
 
 

http://git-wip-us.apache.org/repos/asf/hbase-site/blob/2752c924/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 91a2ed4..427b9f5 100644
--- a/devapidocs/org/apache/hadoop/hbase/ipc/package-tree.html
+++ b/devapidocs/org/apache/hadoop/hbase/ipc/package-tree.html
@@ -354,8 +354,8 @@
 java.lang.https://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.https://docs.oracle.com/javase/8/docs/api/java/lang/Comparable.html?is-external=true";
 title="class or interface in java.lang">Comparable, java.io.https://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
 
 
 

http://git-wip-us.apache.org/repos/asf/hbase-site/blob/2752c924/devapidocs/org/apache/hadoop/hbase/mapreduce/package-tree.html
--
diff --git a/devapidocs/org/apache/hadoop/hbase/mapreduce/package-tree.html 
b/devapidocs/org/apache/hadoop/hbase/mapreduce/package-tree.html
index b8bf0a6..b11f6ad 100644
--- a/devapidocs/org/apache/hadoop/hbase/mapreduce/package-tree.html
+++ b/devapidocs/org/apache/hadoop/hbase/mapreduce/package-tree.html
@@ -293,10 +293,10 @@
 
 java.lang.https://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.https://docs.oracle.com/javase/8/docs/api/java/lang/Comparable.html?is-external=true";
 title="class or interface in java.lang">Comparable, java.io.https://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.mapreduce.CellCounter.CellCounterMapper.Counters
-org.apache.hadoop.hbase.mapreduce.SyncTable.SyncMapper.Counter
 org.apache.hadoop.hbase.mapreduce.TableSplit.Version
 org.apache.hadoop.hbase.mapreduce.RowCounter.RowCounterMapper.Counters
+org.apache.hadoop.hbase.mapreduce.CellCounter.CellCounterMapper.Counters
+org.apache.hadoop.hbase.mapreduce.SyncTable.SyncMapper.Counter
 
 
 

http://git-wip-us.apache.org/repos/asf/hbase-site/blob/2752c924/devapidocs/org/apache/hadoop/hbase/master/MasterRpcServices.BalanceSwitchMode.html
--
diff --git 
a/devapidocs/org/apache/hadoop/hbase/master/MasterRpcServices.BalanceSwitchMode.html
 
b/devapidocs/org/apache/hadoop/hbase/master/MasterRpcServices.BalanceSwitchMode.html
index 55b0b25..dcf1bc9 100644
--- 
a/devapidocs/org/apache/hadoop/hbase/master/MasterRpcServices.BalanceSwitchMode.html
+++ 
b/devapidocs/org/apache/hadoop/hbase/master/MasterRpcServices.BalanceSwitchMode.html
@@ -122,7 +122,7 @@ var activeTableTab = "activeTableTab";
 
 
 
-static enum MasterRpcServices.BalanceSwitchMode
+static enum MasterRpcServices.BalanceSwitchMode
 extends https://docs.oracle.com/javase/8/docs/api/java/lang/Enum.html?is-external=true";
 title="class or interface in java.lang">Enum

[02/18] hbase-site git commit: Published site at 02f5f171f51b7ed801355c8acdcfc4ad47c23a3e.

2018-10-30 Thread git-site-role
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/2752c924/testdevapidocs/org/apache/hadoop/hbase/master/replication/package-tree.html
--
diff --git 
a/testdevapidocs/org/apache/hadoop/hbase/master/replication/package-tree.html 
b/testdevapidocs/org/apache/hadoop/hbase/master/replication/package-tree.html
index 2ce5268..d3f86ce 100644
--- 
a/testdevapidocs/org/apache/hadoop/hbase/master/replication/package-tree.html
+++ 
b/testdevapidocs/org/apache/hadoop/hbase/master/replication/package-tree.html
@@ -85,6 +85,8 @@
 
 org.apache.hadoop.hbase.procedure2.StateMachineProcedure
 
+org.apache.hadoop.hbase.master.replication.AbstractPeerNoLockProcedure
 (implements org.apache.hadoop.hbase.master.procedure.PeerProcedureInterface)
+
 org.apache.hadoop.hbase.master.replication.AbstractPeerProcedure
 (implements org.apache.hadoop.hbase.master.procedure.PeerProcedureInterface)
 
 org.apache.hadoop.hbase.master.replication.ModifyPeerProcedure
@@ -103,6 +105,8 @@
 
 
 
+
+
 org.apache.hadoop.hbase.master.replication.TestModifyPeerProcedureRetryBackoff
 org.apache.hadoop.hbase.master.replication.TestTransitPeerSyncReplicationStateProcedureBackoff
 

http://git-wip-us.apache.org/repos/asf/hbase-site/blob/2752c924/testdevapidocs/org/apache/hadoop/hbase/package-tree.html
--
diff --git a/testdevapidocs/org/apache/hadoop/hbase/package-tree.html 
b/testdevapidocs/org/apache/hadoop/hbase/package-tree.html
index dadab29..3b3fbdd 100644
--- a/testdevapidocs/org/apache/hadoop/hbase/package-tree.html
+++ b/testdevapidocs/org/apache/hadoop/hbase/package-tree.html
@@ -579,15 +579,15 @@
 
 java.lang.https://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.https://docs.oracle.com/javase/8/docs/api/java/lang/Comparable.html?is-external=true";
 title="class or interface in java.lang">Comparable, java.io.https://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.ScanPerformanceEvaluation.ScanCounter
+org.apache.hadoop.hbase.IntegrationTestRegionReplicaPerf.Stat
 org.apache.hadoop.hbase.ClusterManager.ServiceType
-org.apache.hadoop.hbase.PerformanceEvaluation.Counter
-org.apache.hadoop.hbase.RESTApiClusterManager.Service
-org.apache.hadoop.hbase.RESTApiClusterManager.RoleCommand
 org.apache.hadoop.hbase.IntegrationTestDDLMasterFailover.ACTION
+org.apache.hadoop.hbase.RESTApiClusterManager.Service
 org.apache.hadoop.hbase.ResourceChecker.Phase
-org.apache.hadoop.hbase.IntegrationTestRegionReplicaPerf.Stat
+org.apache.hadoop.hbase.PerformanceEvaluation.Counter
+org.apache.hadoop.hbase.RESTApiClusterManager.RoleCommand
 org.apache.hadoop.hbase.HBaseClusterManager.CommandProvider.Operation
+org.apache.hadoop.hbase.ScanPerformanceEvaluation.ScanCounter
 
 
 

http://git-wip-us.apache.org/repos/asf/hbase-site/blob/2752c924/testdevapidocs/org/apache/hadoop/hbase/procedure2/package-tree.html
--
diff --git 
a/testdevapidocs/org/apache/hadoop/hbase/procedure2/package-tree.html 
b/testdevapidocs/org/apache/hadoop/hbase/procedure2/package-tree.html
index 55036db..9d4783d 100644
--- a/testdevapidocs/org/apache/hadoop/hbase/procedure2/package-tree.html
+++ b/testdevapidocs/org/apache/hadoop/hbase/procedure2/package-tree.html
@@ -228,9 +228,9 @@
 
 java.lang.https://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.https://docs.oracle.com/javase/8/docs/api/java/lang/Comparable.html?is-external=true";
 title="class or interface in java.lang">Comparable, java.io.https://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.TestYieldProcedures.TestStateMachineProcedure.State
 org.apache.hadoop.hbase.procedure2.TestProcedureBypass.StuckStateMachineState
 org.apache.hadoop.hbase.procedure2.TestProcedureRecovery.TestStateMachineProcedure.State
-org.apache.hadoop.hbase.procedure2.TestYieldProcedures.TestStateMachineProcedure.State
 org.apache.hadoop.hbase.procedure2.TestStateMachineProcedure.TestSMProcedureState
 
 

http://git-wip-us.apache.org/repos/asf/hbase-site/blob/2752c924/testdevapidocs/org/apache/hadoop/hbase/regionserver/TestRegionMergeTransactionOnCluster.MyMasterRpcServices.html
--
diff --git 
a/testdevapidocs/org/apache/hadoop/hbase/regionserver/TestRegionMergeTransactionOnCluster.MyMasterRpcServices.html
 
b/testdevapidocs/org/apache/hadoop/hbase/regionserver/TestRegionMergeTransactionOnCluster.MyMasterRpcServices.html
index 83

[12/18] hbase-site git commit: Published site at 02f5f171f51b7ed801355c8acdcfc4ad47c23a3e.

2018-10-30 Thread git-site-role
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/2752c924/devapidocs/org/apache/hadoop/hbase/master/replication/AbstractPeerProcedure.html
--
diff --git 
a/devapidocs/org/apache/hadoop/hbase/master/replication/AbstractPeerProcedure.html
 
b/devapidocs/org/apache/hadoop/hbase/master/replication/AbstractPeerProcedure.html
index 99dfeb1..34da502 100644
--- 
a/devapidocs/org/apache/hadoop/hbase/master/replication/AbstractPeerProcedure.html
+++ 
b/devapidocs/org/apache/hadoop/hbase/master/replication/AbstractPeerProcedure.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};
+var methods = {"i0":10,"i1":10,"i2":10,"i3":10,"i4":10,"i5":10};
 var tabs = {65535:["t0","All Methods"],2:["t2","Instance 
Methods"],8:["t4","Concrete Methods"]};
 var altColor = "altColor";
 var rowColor = "rowColor";
@@ -49,7 +49,7 @@ var activeTableTab = "activeTableTab";
 
 
 
-Prev Class
+Prev Class
 Next Class
 
 
@@ -106,6 +106,9 @@ var activeTableTab = "activeTableTab";
 org.apache.hadoop.hbase.procedure2.StateMachineProcedure
 
 
+org.apache.hadoop.hbase.master.replication.AbstractPeerNoLockProcedure
+
+
 
org.apache.hadoop.hbase.master.replication.AbstractPeerProcedure
 
 
@@ -114,6 +117,8 @@ var activeTableTab = "activeTableTab";
 
 
 
+
+
 
 
 
@@ -123,13 +128,13 @@ var activeTableTab = "activeTableTab";
 
 
 Direct Known Subclasses:
-ModifyPeerProcedure, RecoverStandbyProcedure, SyncReplicationReplayWALProcedure,
 TransitPeerSyncReplicationStateProcedure
+ModifyPeerProcedure, TransitPeerSyncReplicationStateProcedure
 
 
 
 @InterfaceAudience.Private
-public abstract class AbstractPeerProcedure
-extends StateMachineProcedure
+public abstract class AbstractPeerProcedure
+extends AbstractPeerNoLockProcedure
 implements PeerProcedureInterface
 The base class for all replication peer related 
procedure.
 
@@ -180,19 +185,18 @@ implements Field and Description
 
 
-protected int
-attempts 
-
-
 protected ProcedurePrepareLatch
 latch 
 
-
-protected https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
 title="class or interface in java.lang">String
-peerId 
-
 
 
+
+
+
+Fields inherited from 
class org.apache.hadoop.hbase.master.replication.AbstractPeerNoLockProcedure
+attempts,
 peerId
+
+
 
 
 
@@ -251,74 +255,38 @@ implements 
 protected void
-deserializeStateData(ProcedureStateSerializer serializer)
-Called on store load to allow the user to decode the 
previously serialized
- state.
-
-
-
-protected void
 enablePeer(MasterProcedureEnv env) 
 
-
+
 ProcedurePrepareLatch
 getLatch() 
 
-
-https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
 title="class or interface in java.lang">String
-getPeerId() 
-
-
+
 protected boolean
 holdLock(MasterProcedureEnv env)
 Used to keep the procedure lock even when the procedure is 
yielding or suspended.
 
 
-
+
 protected void
 refreshPeer(MasterProcedureEnv env,
PeerProcedureInterface.PeerOperationType type) 
 
-
+
 protected void
 releaseLock(MasterProcedureEnv env)
 The user should override this method, and release lock if 
necessary.
 
 
-
-protected void
-rollbackState(MasterProcedureEnv env,
- TState state)
-called to perform the rollback of the specified state
-
-
-
-protected void
-serializeStateData(ProcedureStateSerializer serializer)
-The user-level code of the procedure may have some state to
- persist (e.g.
-
-
-
-protected boolean
-setTimeoutFailure(MasterProcedureEnv env)
-Called by the ProcedureExecutor when the timeout set by 
setTimeout() is expired.
-
-
-
-protected ProcedureSuspendedException
-suspend(long backoff) 
-
-
-protected boolean
-waitInitialized(MasterProcedureEnv env)
-The Procedure.doAcquireLock(Object,
 ProcedureStore) will be split into two steps, first, it will
- call us to determine whether we need to wait for initialization, second, it 
will call
- Procedure.acquireLock(Object)
 to actually handle the lock for this procedure.
-
-
 
 
+
+
+
+Methods inherited from 
class org.apache.hadoop.hbase.master.replication.AbstractPeerNoLockProcedure
+deserializeStateData,
 getPeerId,
 rollbackState,
 serializeStateData,
 setTimeoutFailure,
 suspend,
 waitInitialized
+
+
 
 
 
@@ -344,7 +312,7 @@ implements PeerProcedureInterface
-getPeerOperationType
+getPeerId,
 getPeerOperationType
 
 
 
@@ -360,31 +328,13 @@ implements 
-
-
-
-
-peerId
-protected https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true";
 title="class or interface in java.lang">String peerId
-
-
 
 
 
-
-
-latch
-protected ProcedurePrepareLatch latch
-
-
-
-
-
 
 
-attempts
-protected int attempts
+latch
+protected ProcedurePrepareLatch latch
 
 
 
@@ -401,7 +351,7 @@ implements 
 
 AbstractPeerProce

hbase git commit: HBASE-21389 Revisit the procedure lock for sync replication

2018-10-30 Thread zhangduo
Repository: hbase
Updated Branches:
  refs/heads/master 116eee674 -> 02f5f171f


HBASE-21389 Revisit the procedure lock for sync replication


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

Branch: refs/heads/master
Commit: 02f5f171f51b7ed801355c8acdcfc4ad47c23a3e
Parents: 116eee6
Author: zhangduo 
Authored: Fri Oct 26 20:24:57 2018 +0800
Committer: Duo Zhang 
Committed: Tue Oct 30 18:11:20 2018 +0800

--
 .../hbase/master/procedure/PeerQueue.java   |  9 +-
 .../AbstractPeerNoLockProcedure.java| 98 
 .../replication/AbstractPeerProcedure.java  | 65 +
 .../replication/RecoverStandbyProcedure.java|  2 +-
 .../SyncReplicationReplayWALProcedure.java  |  2 +-
 5 files changed, 108 insertions(+), 68 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/hbase/blob/02f5f171/hbase-server/src/main/java/org/apache/hadoop/hbase/master/procedure/PeerQueue.java
--
diff --git 
a/hbase-server/src/main/java/org/apache/hadoop/hbase/master/procedure/PeerQueue.java
 
b/hbase-server/src/main/java/org/apache/hadoop/hbase/master/procedure/PeerQueue.java
index 0e80e2a..ba76514 100644
--- 
a/hbase-server/src/main/java/org/apache/hadoop/hbase/master/procedure/PeerQueue.java
+++ 
b/hbase-server/src/main/java/org/apache/hadoop/hbase/master/procedure/PeerQueue.java
@@ -35,8 +35,11 @@ class PeerQueue extends Queue {
   }
 
   private static boolean requirePeerExclusiveLock(PeerProcedureInterface proc) 
{
-return proc.getPeerOperationType() != PeerOperationType.REFRESH
-&& proc.getPeerOperationType() != 
PeerOperationType.SYNC_REPLICATION_REPLAY_WAL
-&& proc.getPeerOperationType() != 
PeerOperationType.SYNC_REPLICATION_REPLAY_WAL_REMOTE;
+// These procedures will only be used as sub procedures, and if they are 
scheduled, it always
+// means that the root procedure holds the xlock, so we do not need to 
hold any locks.
+return proc.getPeerOperationType() != PeerOperationType.REFRESH &&
+  proc.getPeerOperationType() != PeerOperationType.RECOVER_STANDBY &&
+  proc.getPeerOperationType() != 
PeerOperationType.SYNC_REPLICATION_REPLAY_WAL &&
+  proc.getPeerOperationType() != 
PeerOperationType.SYNC_REPLICATION_REPLAY_WAL_REMOTE;
   }
 }

http://git-wip-us.apache.org/repos/asf/hbase/blob/02f5f171/hbase-server/src/main/java/org/apache/hadoop/hbase/master/replication/AbstractPeerNoLockProcedure.java
--
diff --git 
a/hbase-server/src/main/java/org/apache/hadoop/hbase/master/replication/AbstractPeerNoLockProcedure.java
 
b/hbase-server/src/main/java/org/apache/hadoop/hbase/master/replication/AbstractPeerNoLockProcedure.java
new file mode 100644
index 000..8f8e1e1
--- /dev/null
+++ 
b/hbase-server/src/main/java/org/apache/hadoop/hbase/master/replication/AbstractPeerNoLockProcedure.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.master.replication;
+
+import java.io.IOException;
+import org.apache.hadoop.hbase.master.procedure.MasterProcedureEnv;
+import org.apache.hadoop.hbase.master.procedure.PeerProcedureInterface;
+import org.apache.hadoop.hbase.procedure2.ProcedureStateSerializer;
+import org.apache.hadoop.hbase.procedure2.ProcedureSuspendedException;
+import org.apache.hadoop.hbase.procedure2.StateMachineProcedure;
+import org.apache.yetus.audience.InterfaceAudience;
+
+import 
org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.PeerProcedureStateData;
+import org.apache.hadoop.hbase.shaded.protobuf.generated.ProcedureProtos;
+
+/**
+ * Base class for replication peer related procedures which do not need to 
hold locks(for most of
+ * the sub procedures).
+ */
+@InterfaceAudience.Private
+public abstract class AbstractPeerN

hbase git commit: HBASE-21237 Use CompatRemoteProcedureResolver to dispatch open/close region requests to RS

2018-10-30 Thread zhangduo
Repository: hbase
Updated Branches:
  refs/heads/branch-2.0 c1b406be6 -> ee608fedd


HBASE-21237 Use CompatRemoteProcedureResolver to dispatch open/close region 
requests to RS


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

Branch: refs/heads/branch-2.0
Commit: ee608fedd55285f1b0549d8f235a94d60d073b8d
Parents: c1b406b
Author: Duo Zhang 
Authored: Tue Oct 30 09:41:23 2018 +0800
Committer: Duo Zhang 
Committed: Tue Oct 30 17:37:09 2018 +0800

--
 .../master/procedure/RSProcedureDispatcher.java | 48 ++--
 .../assignment/TestAssignmentManager.java   | 20 +++-
 2 files changed, 23 insertions(+), 45 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/hbase/blob/ee608fed/hbase-server/src/main/java/org/apache/hadoop/hbase/master/procedure/RSProcedureDispatcher.java
--
diff --git 
a/hbase-server/src/main/java/org/apache/hadoop/hbase/master/procedure/RSProcedureDispatcher.java
 
b/hbase-server/src/main/java/org/apache/hadoop/hbase/master/procedure/RSProcedureDispatcher.java
index ad0451d..20b2ed6 100644
--- 
a/hbase-server/src/main/java/org/apache/hadoop/hbase/master/procedure/RSProcedureDispatcher.java
+++ 
b/hbase-server/src/main/java/org/apache/hadoop/hbase/master/procedure/RSProcedureDispatcher.java
@@ -111,10 +111,7 @@ public class RSProcedureDispatcher
 if (rsVersion == 0 && 
!master.getServerManager().isServerOnline(serverName)) {
   submitTask(new DeadRSRemoteCall(serverName, remoteProcedures));
 } else {
-  // See HBASE-21237, fallback to CompatRemoteProcedureResolver for now. 
Since
-  // ExecuteProceduresRemoteCall will group all the open/close requests. 
If one
-  // fails, master will regard all the requests as failure and then cause 
some trouble.
-  submitTask(new CompatRemoteProcedureResolver(serverName, 
remoteProcedures));
+  submitTask(new ExecuteProceduresRemoteCall(serverName, 
remoteProcedures));
 }
   }
 
@@ -279,7 +276,7 @@ public class RSProcedureDispatcher
   implements RemoteProcedureResolver {
 protected final Set remoteProcedures;
 
-private ExecuteProceduresRequest.Builder request = null;
+protected ExecuteProceduresRequest.Builder request = null;
 
 public ExecuteProceduresRemoteCall(final ServerName serverName,
 final Set remoteProcedures) {
@@ -312,14 +309,14 @@ public class RSProcedureDispatcher
 @Override
 public void dispatchOpenRequests(final MasterProcedureEnv env,
 final List operations) {
-  request.addOpenRegion(buildOpenRegionRequest(env, getServerName(), 
operations));
+  submitTask(new OpenRegionRemoteCall(getServerName(), operations));
 }
 
 @Override
 public void dispatchCloseRequests(final MasterProcedureEnv env,
 final List operations) {
   for (RegionCloseOperation op: operations) {
-request.addCloseRegion(op.buildCloseRegionRequest(getServerName()));
+submitTask(new CloseRegionRemoteCall(getServerName(), op));
   }
 }
 
@@ -348,7 +345,7 @@ public class RSProcedureDispatcher
 }
   }
 
-  private static OpenRegionRequest buildOpenRegionRequest(final 
MasterProcedureEnv env,
+  protected static OpenRegionRequest buildOpenRegionRequest(final 
MasterProcedureEnv env,
   final ServerName serverName, final List operations) 
{
 final OpenRegionRequest.Builder builder = OpenRegionRequest.newBuilder();
 builder.setServerStartCode(serverName.getStartcode());
@@ -472,41 +469,6 @@ public class RSProcedureDispatcher
 }
   }
 
-  /**
-   * Compatibility class to open and close regions using old endpoints 
(openRegion/closeRegion) in
-   * {@link AdminService}.
-   */
-  protected class CompatRemoteProcedureResolver implements Callable, 
RemoteProcedureResolver {
-private final Set operations;
-private final ServerName serverName;
-
-public CompatRemoteProcedureResolver(final ServerName serverName,
-final Set operations) {
-  this.serverName = serverName;
-  this.operations = operations;
-}
-
-@Override
-public Void call() {
-  splitAndResolveOperation(serverName, operations, this);
-  return null;
-}
-
-@Override
-public void dispatchOpenRequests(final MasterProcedureEnv env,
-final List operations) {
-  submitTask(new OpenRegionRemoteCall(serverName, operations));
-}
-
-@Override
-public void dispatchCloseRequests(final MasterProcedureEnv env,
-final List operations) {
-  for (RegionCloseOperation op: operations) {
-submitTask(new CloseRegionRemoteCall(serverName, op));
-  }
-}
-

hbase git commit: HBASE-21237 Use CompatRemoteProcedureResolver to dispatch open/close region requests to RS

2018-10-30 Thread zhangduo
Repository: hbase
Updated Branches:
  refs/heads/branch-2.1 422e98957 -> bddd488c3


HBASE-21237 Use CompatRemoteProcedureResolver to dispatch open/close region 
requests to RS


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

Branch: refs/heads/branch-2.1
Commit: bddd488c34557144c3692d88366511d3c301fbc7
Parents: 422e989
Author: Duo Zhang 
Authored: Tue Oct 30 09:41:23 2018 +0800
Committer: Duo Zhang 
Committed: Tue Oct 30 17:36:44 2018 +0800

--
 .../master/procedure/RSProcedureDispatcher.java | 59 ++--
 .../assignment/TestAssignmentManager.java   | 20 ++-
 2 files changed, 24 insertions(+), 55 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/hbase/blob/bddd488c/hbase-server/src/main/java/org/apache/hadoop/hbase/master/procedure/RSProcedureDispatcher.java
--
diff --git 
a/hbase-server/src/main/java/org/apache/hadoop/hbase/master/procedure/RSProcedureDispatcher.java
 
b/hbase-server/src/main/java/org/apache/hadoop/hbase/master/procedure/RSProcedureDispatcher.java
index 638f9d3..ba4737b 100644
--- 
a/hbase-server/src/main/java/org/apache/hadoop/hbase/master/procedure/RSProcedureDispatcher.java
+++ 
b/hbase-server/src/main/java/org/apache/hadoop/hbase/master/procedure/RSProcedureDispatcher.java
@@ -109,17 +109,10 @@ public class RSProcedureDispatcher
   protected void remoteDispatch(final ServerName serverName,
   final Set remoteProcedures) {
 final int rsVersion = 
master.getServerManager().getVersionNumber(serverName);
-if (rsVersion >= RS_VERSION_WITH_EXEC_PROCS) {
-  LOG.trace("Using procedure batch rpc execution for serverName={} 
version={}", serverName,
-rsVersion);
-  submitTask(new ExecuteProceduresRemoteCall(serverName, 
remoteProcedures));
-} else if (rsVersion == 0 && 
!master.getServerManager().isServerOnline(serverName)) {
+if (rsVersion == 0 && 
!master.getServerManager().isServerOnline(serverName)) {
   submitTask(new DeadRSRemoteCall(serverName, remoteProcedures));
 } else {
-  LOG.info(String.format(
-"Fallback to compat rpc execution for serverName=%s version=%s",
-serverName, rsVersion));
-  submitTask(new CompatRemoteProcedureResolver(serverName, 
remoteProcedures));
+  submitTask(new ExecuteProceduresRemoteCall(serverName, 
remoteProcedures));
 }
   }
 
@@ -293,7 +286,7 @@ public class RSProcedureDispatcher
   implements RemoteProcedureResolver {
 protected final Set remoteProcedures;
 
-private ExecuteProceduresRequest.Builder request = null;
+protected ExecuteProceduresRequest.Builder request = null;
 
 public ExecuteProceduresRemoteCall(final ServerName serverName,
 final Set remoteProcedures) {
@@ -325,14 +318,14 @@ public class RSProcedureDispatcher
 @Override
 public void dispatchOpenRequests(final MasterProcedureEnv env,
 final List operations) {
-  request.addOpenRegion(buildOpenRegionRequest(env, getServerName(), 
operations));
+  submitTask(new OpenRegionRemoteCall(getServerName(), operations));
 }
 
 @Override
 public void dispatchCloseRequests(final MasterProcedureEnv env,
 final List operations) {
   for (RegionCloseOperation op: operations) {
-request.addCloseRegion(op.buildCloseRegionRequest(getServerName()));
+submitTask(new CloseRegionRemoteCall(getServerName(), op));
   }
 }
 
@@ -357,7 +350,7 @@ public class RSProcedureDispatcher
 }
   }
 
-  private static OpenRegionRequest buildOpenRegionRequest(final 
MasterProcedureEnv env,
+  protected static OpenRegionRequest buildOpenRegionRequest(final 
MasterProcedureEnv env,
   final ServerName serverName, final List operations) 
{
 final OpenRegionRequest.Builder builder = OpenRegionRequest.newBuilder();
 builder.setServerStartCode(serverName.getStartcode());
@@ -469,46 +462,6 @@ public class RSProcedureDispatcher
 }
   }
 
-  /**
-   * Compatibility class to open and close regions using old endpoints 
(openRegion/closeRegion) in
-   * {@link AdminService}.
-   */
-  protected class CompatRemoteProcedureResolver implements Callable, 
RemoteProcedureResolver {
-private final Set operations;
-private final ServerName serverName;
-
-public CompatRemoteProcedureResolver(final ServerName serverName,
-final Set operations) {
-  this.serverName = serverName;
-  this.operations = operations;
-}
-
-@Override
-public Void call() {
-  splitAndResolveOperation(serverName, operations, this);
-  return null;
-}
-
-@Override
-public void dispatchOp