hbase git commit: HBASE-18651 Let ChaosMonkeyRunner expose the chaos monkey runner it creates
Repository: hbase Updated Branches: refs/heads/branch-2 c1f5122fa -> 3a02a2a80 HBASE-18651 Let ChaosMonkeyRunner expose the chaos monkey runner it creates Signed-off-by: Mike DrobSigned-off-by: Ted Yu Project: http://git-wip-us.apache.org/repos/asf/hbase/repo Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/3a02a2a8 Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/3a02a2a8 Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/3a02a2a8 Branch: refs/heads/branch-2 Commit: 3a02a2a80df859db996a98072a4c272a0c81c73d Parents: c1f5122 Author: Reid Chan Authored: Thu Sep 21 11:30:14 2017 +0800 Committer: Mike Drob Committed: Thu Sep 21 21:34:07 2017 -0500 -- .../hbase/chaos/util/ChaosMonkeyRunner.java | 19 +++- .../apache/hadoop/hbase/chaos/util/Monkeys.java | 96 .../hbase/test/IntegrationTestMonkeys.java | 67 ++ 3 files changed, 178 insertions(+), 4 deletions(-) -- http://git-wip-us.apache.org/repos/asf/hbase/blob/3a02a2a8/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/util/ChaosMonkeyRunner.java -- diff --git a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/util/ChaosMonkeyRunner.java b/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/util/ChaosMonkeyRunner.java index 5911085..d72111f 100644 --- a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/util/ChaosMonkeyRunner.java +++ b/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/util/ChaosMonkeyRunner.java @@ -52,7 +52,6 @@ public class ChaosMonkeyRunner extends AbstractHBaseTool { protected boolean noClusterCleanUp = false; private String tableName = "ChaosMonkeyRunner.tableName"; private String familyName = "ChaosMonkeyRunner.familyName"; - private volatile boolean stop = false; @Override public void addOptions() { @@ -93,14 +92,26 @@ public class ChaosMonkeyRunner extends AbstractHBaseTool { protected int doWork() throws Exception { setUpCluster(); getAndStartMonkey(); -while (!stop) {// loop here until got killed - Thread.sleep(1); +while (!monkey.isStopped()) { + // loop here until got killed + try { +// TODO: make sleep time configurable +Thread.sleep(5000); // 5 seconds + } catch (InterruptedException ite) { +// Chaos monkeys got interrupted. +// It is ok to stop monkeys and exit. +monkey.stop("Interruption occurred."); +break; + } } +monkey.waitForStop(); return 0; } public void stopRunner() { -stop = true; +if (monkey != null) { + monkey.stop("Program Control"); +} } public void setUpCluster() throws Exception { http://git-wip-us.apache.org/repos/asf/hbase/blob/3a02a2a8/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/util/Monkeys.java -- diff --git a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/util/Monkeys.java b/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/util/Monkeys.java new file mode 100644 index 000..1ce4356 --- /dev/null +++ b/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/util/Monkeys.java @@ -0,0 +1,96 @@ +/** + * 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.chaos.util; + +import java.io.Closeable; +import java.io.IOException; +import java.util.concurrent.ExecutorService; +import java.util.concurrent.Executors; +import java.util.concurrent.TimeUnit; + +import org.apache.commons.logging.Log; +import org.apache.commons.logging.LogFactory; +import org.apache.hadoop.conf.Configuration; +import org.apache.hadoop.hbase.HBaseConfiguration; +import org.apache.hadoop.hbase.IntegrationTestingUtility; +import org.apache.hadoop.hbase.shaded.com.google.common.base.Preconditions; +import org.apache.hadoop.hbase.shaded.com.google.common.util.concurrent.ThreadFactoryBuilder; + +/** + * This class can be used to control chaos
hbase git commit: HBASE-18651 Let ChaosMonkeyRunner expose the chaos monkey runner it creates
Repository: hbase Updated Branches: refs/heads/master e39359986 -> 5f238b3ef HBASE-18651 Let ChaosMonkeyRunner expose the chaos monkey runner it creates Signed-off-by: Mike DrobSigned-off-by: Ted Yu Project: http://git-wip-us.apache.org/repos/asf/hbase/repo Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/5f238b3e Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/5f238b3e Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/5f238b3e Branch: refs/heads/master Commit: 5f238b3ef46e7d5f31a9fb2dfff0111085af835d Parents: e393599 Author: Reid Chan Authored: Thu Sep 21 11:30:14 2017 +0800 Committer: Mike Drob Committed: Thu Sep 21 21:19:25 2017 -0500 -- .../hbase/chaos/util/ChaosMonkeyRunner.java | 19 +++- .../apache/hadoop/hbase/chaos/util/Monkeys.java | 96 .../hbase/test/IntegrationTestMonkeys.java | 67 ++ 3 files changed, 178 insertions(+), 4 deletions(-) -- http://git-wip-us.apache.org/repos/asf/hbase/blob/5f238b3e/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/util/ChaosMonkeyRunner.java -- diff --git a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/util/ChaosMonkeyRunner.java b/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/util/ChaosMonkeyRunner.java index 5911085..d72111f 100644 --- a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/util/ChaosMonkeyRunner.java +++ b/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/util/ChaosMonkeyRunner.java @@ -52,7 +52,6 @@ public class ChaosMonkeyRunner extends AbstractHBaseTool { protected boolean noClusterCleanUp = false; private String tableName = "ChaosMonkeyRunner.tableName"; private String familyName = "ChaosMonkeyRunner.familyName"; - private volatile boolean stop = false; @Override public void addOptions() { @@ -93,14 +92,26 @@ public class ChaosMonkeyRunner extends AbstractHBaseTool { protected int doWork() throws Exception { setUpCluster(); getAndStartMonkey(); -while (!stop) {// loop here until got killed - Thread.sleep(1); +while (!monkey.isStopped()) { + // loop here until got killed + try { +// TODO: make sleep time configurable +Thread.sleep(5000); // 5 seconds + } catch (InterruptedException ite) { +// Chaos monkeys got interrupted. +// It is ok to stop monkeys and exit. +monkey.stop("Interruption occurred."); +break; + } } +monkey.waitForStop(); return 0; } public void stopRunner() { -stop = true; +if (monkey != null) { + monkey.stop("Program Control"); +} } public void setUpCluster() throws Exception { http://git-wip-us.apache.org/repos/asf/hbase/blob/5f238b3e/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/util/Monkeys.java -- diff --git a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/util/Monkeys.java b/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/util/Monkeys.java new file mode 100644 index 000..1ce4356 --- /dev/null +++ b/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/util/Monkeys.java @@ -0,0 +1,96 @@ +/** + * 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.chaos.util; + +import java.io.Closeable; +import java.io.IOException; +import java.util.concurrent.ExecutorService; +import java.util.concurrent.Executors; +import java.util.concurrent.TimeUnit; + +import org.apache.commons.logging.Log; +import org.apache.commons.logging.LogFactory; +import org.apache.hadoop.conf.Configuration; +import org.apache.hadoop.hbase.HBaseConfiguration; +import org.apache.hadoop.hbase.IntegrationTestingUtility; +import org.apache.hadoop.hbase.shaded.com.google.common.base.Preconditions; +import org.apache.hadoop.hbase.shaded.com.google.common.util.concurrent.ThreadFactoryBuilder; + +/** + * This class can be used to control chaos
hbase git commit: HBASE-18731 [compat 1-2] Mark protected methods of QuotaSettings that touch Protobuf internals as IA.Private
Repository: hbase Updated Branches: refs/heads/branch-2 0eab16fde -> c1f5122fa HBASE-18731 [compat 1-2] Mark protected methods of QuotaSettings that touch Protobuf internals as IA.Private Signed-off-by: Michael StackProject: http://git-wip-us.apache.org/repos/asf/hbase/repo Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/c1f5122f Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/c1f5122f Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/c1f5122f Branch: refs/heads/branch-2 Commit: c1f5122fab9d5fec52a7346ef71e0776fc3180f6 Parents: 0eab16f Author: Sean Busbey Authored: Thu Sep 21 09:57:39 2017 -0500 Committer: Sean Busbey Committed: Thu Sep 21 14:01:02 2017 -0500 -- .../main/java/org/apache/hadoop/hbase/quotas/QuotaSettings.java| 2 ++ 1 file changed, 2 insertions(+) -- http://git-wip-us.apache.org/repos/asf/hbase/blob/c1f5122f/hbase-client/src/main/java/org/apache/hadoop/hbase/quotas/QuotaSettings.java -- diff --git a/hbase-client/src/main/java/org/apache/hadoop/hbase/quotas/QuotaSettings.java b/hbase-client/src/main/java/org/apache/hadoop/hbase/quotas/QuotaSettings.java index dbea5fb..cf04f92 100644 --- a/hbase-client/src/main/java/org/apache/hadoop/hbase/quotas/QuotaSettings.java +++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/quotas/QuotaSettings.java @@ -56,6 +56,7 @@ public abstract class QuotaSettings { * This is used internally by the Admin client to serialize the quota settings * and send them to the master. */ + @InterfaceAudience.Private public static SetQuotaRequest buildSetQuotaRequestProto(final QuotaSettings settings) { SetQuotaRequest.Builder builder = SetQuotaRequest.newBuilder(); if (settings.getUserName() != null) { @@ -76,6 +77,7 @@ public abstract class QuotaSettings { * the subclass should implement this method to set the specific SetQuotaRequest * properties. */ + @InterfaceAudience.Private protected abstract void setupSetQuotaRequest(SetQuotaRequest.Builder builder); protected String ownerToString() {
hbase git commit: HBASE-18731 [compat 1-2] Mark protected methods of QuotaSettings that touch Protobuf internals as IA.Private
Repository: hbase Updated Branches: refs/heads/master a6c3c645f -> e39359986 HBASE-18731 [compat 1-2] Mark protected methods of QuotaSettings that touch Protobuf internals as IA.Private Signed-off-by: Michael StackProject: http://git-wip-us.apache.org/repos/asf/hbase/repo Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/e3935998 Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/e3935998 Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/e3935998 Branch: refs/heads/master Commit: e39359986c4765946cde30da2957324cb7c9705c Parents: a6c3c64 Author: Sean Busbey Authored: Thu Sep 21 09:57:39 2017 -0500 Committer: Sean Busbey Committed: Thu Sep 21 14:00:10 2017 -0500 -- .../main/java/org/apache/hadoop/hbase/quotas/QuotaSettings.java| 2 ++ 1 file changed, 2 insertions(+) -- http://git-wip-us.apache.org/repos/asf/hbase/blob/e3935998/hbase-client/src/main/java/org/apache/hadoop/hbase/quotas/QuotaSettings.java -- diff --git a/hbase-client/src/main/java/org/apache/hadoop/hbase/quotas/QuotaSettings.java b/hbase-client/src/main/java/org/apache/hadoop/hbase/quotas/QuotaSettings.java index dbea5fb..cf04f92 100644 --- a/hbase-client/src/main/java/org/apache/hadoop/hbase/quotas/QuotaSettings.java +++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/quotas/QuotaSettings.java @@ -56,6 +56,7 @@ public abstract class QuotaSettings { * This is used internally by the Admin client to serialize the quota settings * and send them to the master. */ + @InterfaceAudience.Private public static SetQuotaRequest buildSetQuotaRequestProto(final QuotaSettings settings) { SetQuotaRequest.Builder builder = SetQuotaRequest.newBuilder(); if (settings.getUserName() != null) { @@ -76,6 +77,7 @@ public abstract class QuotaSettings { * the subclass should implement this method to set the specific SetQuotaRequest * properties. */ + @InterfaceAudience.Private protected abstract void setupSetQuotaRequest(SetQuotaRequest.Builder builder); protected String ownerToString() {
[29/51] [partial] hbase-site git commit: Published site at .
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/fa7d6c0c/devapidocs/org/apache/hadoop/hbase/rsgroup/RSGroupAdminEndpoint.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/rsgroup/RSGroupAdminEndpoint.html b/devapidocs/org/apache/hadoop/hbase/rsgroup/RSGroupAdminEndpoint.html index f432bb8..bc0cba8 100644 --- a/devapidocs/org/apache/hadoop/hbase/rsgroup/RSGroupAdminEndpoint.html +++ b/devapidocs/org/apache/hadoop/hbase/rsgroup/RSGroupAdminEndpoint.html @@ -114,7 +114,7 @@ var activeTableTab = "activeTableTab"; @InterfaceAudience.Private -public class RSGroupAdminEndpoint +public class RSGroupAdminEndpoint extends http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true; title="class or interface in java.lang">Object implements MasterObserver, CoprocessorService @@ -259,9 +259,9 @@ implements void -preCreateTable(ObserverContextMasterCoprocessorEnvironmentctx, +preCreateTable(ObserverContextMasterCoprocessorEnvironmentctx, TableDescriptordesc, - HRegionInfo[]regions) + RegionInfo[]regions) Called before a new table is created by HMaster. @@ -290,7 +290,7 @@ implements MasterObserver -postAbortProcedure, postAddColumnFamily, postAddReplicationPeer, postAddRSGroup, postAssign, postBalance, postBalanceRSGroup, postBalanceSwitch, postClearDeadServers, postCloneSnapshot, postCompletedAddColumnFamilyAction, postCompletedCreateTableAction, postCompletedDeleteColumnFamilyAction, postCompletedDeleteTableAction, postCompletedDisableTableAction, postCompletedEnableTableAction, postCompletedMergeRegionsAction, postCompletedModifyColumnFamilyAction, postCompletedModifyTableAction, postCompletedSplitRegionAction, postCompletedTruncateTableAction, postCreateNamespace, postCreateTable, postDeleteColumnFamily, postDeleteNamespace, postDeleteSnapshot, postDisableReplicationPeer, postDisableTable, postEnableReplicationPeer, postEnableTable, postGetLocks, postGetNamespaceDescriptor, postGetProcedures, postGetReplicationPeerConfig, postGetTableDescriptors, postGetTableNames, postListDeadServers, postListNamespaceDescriptors, postListReplicationPeers, postListSnapshot, postLockHeartbeat, postMergeRegions, postMergeRegionsCommitAction, postModifyColumnFamily, postModifyNamespace, postModifyTable, postMove, postMoveServers, postMoveServersAndTables, postMoveTables, postRegionOffline, postRemoveReplicationPeer , postRemoveRSGroup, postRequestLock, postRestoreSnapshot, postRollBackMergeRegionsAction, postRollBackSplitRegionAction, postSetNamespaceQuota, postSetSplitOrMergeEnabled, postSetTableQuota, postSetUserQuota, postSetUserQuota, postSetUserQuota, postSnapshot, postStartMaster, postTableFlush, postTruncateTable, postUnassign, postUpdateReplicationPeerConfig, preAbortProcedure, preAddColumnFamily, preAddColumnFamilyAction, preAddReplicationPeer, preAddRSGroup, preAssign, preBalance, preBalanceRSGroup, preBalanceSwitch, preClearDeadServers, preCreateTableAction, preDeleteColumnFamily, preDeleteColumnFamilyAction, preDeleteNamespace, preDeleteSnapshot, preDeleteTable, preDeleteTableAction , preDisableReplicationPeer, preDisableTable, preDisableTableAction, preEnableReplicationPeer, preEnableTable, preEnableTableAction, preGetLocks, preGetNamespaceDescriptor, preGetProcedures, preGetReplicati onPeerConfig, preGetTableDescriptors, preGetTableNames, preListDeadServers, preListNamespaceDescriptors, preListReplicationPeers, preListSnapshot, preLockHeartbeat, preMasterInitialization, preMergeRegions, preMergeRegionsAction, preMergeRegionsCommitAction, preModifyColumnFamily, preModifyColumnFamilyAction, preModifyTable, preModifyTableAction, preMove, preMoveServers, preMoveServersAndTables, preMoveTables, preRegionOffline, preRemoveReplicationPeer, preRemoveRSGroup, preRequestLock, preRestoreSnapshot, preSetNamespaceQuota, preSetSplitOrMergeEnabled, preSetTableQuota, preSetUserQuota, preSetUserQuota, preSetUserQuota, preShutdown, preSnapshot, preSplitRegion, preSplitRegionAction, preSplitRegionAfterPONRAction, preSplitRegionBeforePONRAction, preStopMaster, preTableFlush, preTruncateTable, preTruncateTableAction, preUnassign, preUpdateReplicationPeerConfig +postAbortProcedure, postAddColumnFamily, postAddReplicationPeer, postAddRSGroup, postAssign, postBalance, postBalanceRSGroup, postBalanceSwitch, postClearDeadServers, postCloneSnapshot, postCompletedAddColumnFamilyAction, postCompletedCreateTableAction, postCompletedDeleteColumnFamily Action, postCompletedDeleteTableAction, postCompletedDisableTableAction, postCompletedEnableTableAction, postCompletedMergeRegionsA ction, postCompletedModifyColumnFamilyAction, postCompletedModifyTableAction, postCompletedSplitRegionAction, postCompletedTruncateTableAction,
[24/51] [partial] hbase-site git commit: Published site at .
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/fa7d6c0c/devapidocs/org/apache/hadoop/hbase/security/visibility/VisibilityController.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/security/visibility/VisibilityController.html b/devapidocs/org/apache/hadoop/hbase/security/visibility/VisibilityController.html index 3058795..7eb0eea 100644 --- a/devapidocs/org/apache/hadoop/hbase/security/visibility/VisibilityController.html +++ b/devapidocs/org/apache/hadoop/hbase/security/visibility/VisibilityController.html @@ -572,14 +572,14 @@ implements MasterObserver -postAbortProcedure, postAddColumnFamily, postAddReplicationPeer, postAddRSGroup, postAssign, postBalance, postBalanceRSGroup, postBalanceSwitch, postClearDeadServers, postCloneSnapshot, postCompletedAddColumnFamilyAction, postCompletedCreateTableAction, post CompletedDeleteColumnFamilyAction, postCompletedDeleteTableAction, postCompletedDisableTableAction, postCompletedEnableTableAction, postCompletedMergeRegionsAction, href="../../../../../../org/apache/hadoop/hbase/coprocessor/MasterObserver.html#postCompletedModifyColumnFamilyAction-org.apache.hadoop.hbase.coprocessor.ObserverContext-org.apache.hadoop.hbase.TableName-org.apache.hadoop.hbase.client.ColumnFamilyDescriptor-">postCompletedModifyColumnFamilyAction, > href="../../../../../../org/apache/hadoop/hbase/coprocessor/MasterObserver.html#postCompletedModifyTableAction-org.apache.hadoop.hbase.coprocessor.ObserverContext-org.apache.hadoop.hbase.TableName-org.apache.hadoop.hbase.client.TableDescriptor-">postCompletedModifyTableAction, > href="../../../../../../org/apache/hadoop/hbase/coprocessor/MasterObserver.html#postCompletedSplitRegionAction-org.apache.hadoop.hbase.coprocessor.ObserverContext-org.apache.hadoop.hbase.HRegionInfo-org.apache.hadoop.hbase.HRegionInfo-">postCompletedSplitRegionAction, > href="../../../../../../org/apache/hadoop/hbase/coprocessor/MasterObserver.html#postCompl etedTruncateTableAction-org.apache.hadoop.hbase.coprocessor.ObserverContext-org.apache.hadoop.hbase.TableName-">postCompletedTruncateTableAction, postCreateNamespace, postCreateTable, postDeleteColumnFamily, postDeleteNamespace, postDeleteSnapshot, postDeleteTable, postDisableReplicationPeer, postDisableTable, postEnableReplicationPeer, postEnableTable, postGetLocks, postGetNamespaceDescriptor, postGetProcedures, href="../../../../../../org/apache/hadoop/hbase/coprocessor/MasterObserver.html#postGetReplicationPeerConfig-org.apache.hadoop.hbase.coprocessor.ObserverContext-java.lang.String-">postGetReplicationPeerConfig, > href="../../../../../../org/apache/hadoop/hbase/coprocessor/MasterObserver.html#postGetTableDescriptors-org.apache.hadoop.hbase.coprocessor.ObserverContext-java.util.List-java.util.List-java.lang.String-">postGetTableDescriptors, > href="../../../../../../org/apache/hadoop/hbase/coprocessor/MasterObserver.html#postGetTableNames-org.apache.hadoop.hbase.coprocessor.ObserverContext-java.util.List-java.lang.String-">postGetTableNames, > href="../../../../../../org/apache/hadoop/hbase/coprocessor/MasterObserver.html#postListDeadServers-org.apache.hadoop.hbase.coprocessor.ObserverContext-">postListDeadServers, > href="../../../../../../org/apache/hadoop/hbase/coprocessor/MasterObserver.html#postListNamespaceDescriptors-org.apache.hadoop.hbase.coprocessor. ObserverContext-java.util.List-">postListNamespaceDescriptors, postListReplicationPeers, postListSnapshot, postLockHeartbeat, postMergeRegions, postMergeRegionsCommitAction, postModifyColumnFamily, postModifyNamespace, postModifyTable, postMove, postMoveServers, postMoveServersAndTables, postMoveTables, postRegionOffline, postRemoveReplicationPeer, postRemoveRSGroup, postRequestLock, postRestoreSnapshot, postRollBackMergeRegionsAction, postRollBackSplitRegionAction, postSetNamespaceQuota, postSetTableQuota, postSetUserQuota, postSetUserQuota, postSetUserQuota, postSnapshot, postTableFlush, postTruncateTable, postUnassign, postUpdateReplicationPeerConfig, preAbortProcedure, preAddColumnFamilyAction, preAddReplicationPeer, preAddRSGroup, preAssign, preBalance, preBalanceRSGroup, preBalanceSwitch, preClearDeadServers, preCloneSnapshot, preCreateNamespace, preCreateTable, preCreateTableAction, preDeleteColumnFamilyAction, preDeleteNamespace, preDeleteSnapshot, preDeleteTable, preDeleteTableAction, preDisableReplicationPeer, preDisableTableAction, preEnableReplicationPeer, preEnableTable, preEnableTableAction, preGetLocks, preGetNamespaceDescriptor, preGetProcedures, preGetReplicationPeerConfig, preGetTableDescriptors, preGetTableNames, preListDeadServers, preListNamespaceDesc riptors, preListReplicationPeers, preListSnapshot, preLockHeartbeat, preMasterInitialization, preMergeRegions, preMergeRegionsAction, preMergeRegionsCommitAction, preModifyColumnFamilyAction,
[01/51] [partial] hbase-site git commit: Published site at .
Repository: hbase-site Updated Branches: refs/heads/asf-site 21bac6593 -> fa7d6c0c6 http://git-wip-us.apache.org/repos/asf/hbase-site/blob/fa7d6c0c/devapidocs/src-html/org/apache/hadoop/hbase/security/access/AccessController.OpType.html -- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/security/access/AccessController.OpType.html b/devapidocs/src-html/org/apache/hadoop/hbase/security/access/AccessController.OpType.html index 92c2266..ee54e1d 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/security/access/AccessController.OpType.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/security/access/AccessController.OpType.html @@ -26,2736 +26,2735 @@ 018 */ 019package org.apache.hadoop.hbase.security.access; 020 -021import com.google.protobuf.Message; -022import com.google.protobuf.RpcCallback; -023import com.google.protobuf.RpcController; -024import com.google.protobuf.Service; -025import org.apache.commons.logging.Log; -026import org.apache.commons.logging.LogFactory; -027import org.apache.hadoop.conf.Configuration; -028import org.apache.hadoop.hbase.ArrayBackedTag; -029import org.apache.hadoop.hbase.Cell; -030import org.apache.hadoop.hbase.CellScanner; -031import org.apache.hadoop.hbase.CellUtil; -032import org.apache.hadoop.hbase.CompareOperator; -033import org.apache.hadoop.hbase.CompoundConfiguration; -034import org.apache.hadoop.hbase.CoprocessorEnvironment; -035import org.apache.hadoop.hbase.DoNotRetryIOException; -036import org.apache.hadoop.hbase.HBaseInterfaceAudience; -037import org.apache.hadoop.hbase.HConstants; -038import org.apache.hadoop.hbase.HRegionInfo; -039import org.apache.hadoop.hbase.KeyValue; -040import org.apache.hadoop.hbase.KeyValue.Type; -041import org.apache.hadoop.hbase.MetaTableAccessor; -042import org.apache.hadoop.hbase.NamespaceDescriptor; -043import org.apache.hadoop.hbase.ServerName; -044import org.apache.hadoop.hbase.TableName; -045import org.apache.hadoop.hbase.Tag; -046import org.apache.yetus.audience.InterfaceAudience; -047import org.apache.hadoop.hbase.client.Append; -048import org.apache.hadoop.hbase.client.ColumnFamilyDescriptor; -049import org.apache.hadoop.hbase.client.Delete; -050import org.apache.hadoop.hbase.client.Durability; -051import org.apache.hadoop.hbase.client.Get; -052import org.apache.hadoop.hbase.client.Increment; -053import org.apache.hadoop.hbase.client.MasterSwitchType; -054import org.apache.hadoop.hbase.client.Mutation; -055import org.apache.hadoop.hbase.client.Put; -056import org.apache.hadoop.hbase.client.Query; -057import org.apache.hadoop.hbase.client.Result; -058import org.apache.hadoop.hbase.client.Scan; -059import org.apache.hadoop.hbase.client.Table; -060import org.apache.hadoop.hbase.client.TableDescriptor; -061import org.apache.hadoop.hbase.coprocessor.BulkLoadObserver; -062import org.apache.hadoop.hbase.coprocessor.CoprocessorException; -063import org.apache.hadoop.hbase.coprocessor.CoprocessorService; -064import org.apache.hadoop.hbase.coprocessor.EndpointObserver; -065import org.apache.hadoop.hbase.coprocessor.MasterCoprocessorEnvironment; -066import org.apache.hadoop.hbase.coprocessor.MasterObserver; -067import org.apache.hadoop.hbase.coprocessor.ObserverContext; -068import org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment; -069import org.apache.hadoop.hbase.coprocessor.RegionObserver; -070import org.apache.hadoop.hbase.coprocessor.RegionServerCoprocessorEnvironment; -071import org.apache.hadoop.hbase.coprocessor.RegionServerObserver; -072import org.apache.hadoop.hbase.filter.ByteArrayComparable; -073import org.apache.hadoop.hbase.filter.Filter; -074import org.apache.hadoop.hbase.filter.FilterList; -075import org.apache.hadoop.hbase.io.hfile.HFile; -076import org.apache.hadoop.hbase.ipc.CoprocessorRpcUtils; -077import org.apache.hadoop.hbase.ipc.RpcServer; -078import org.apache.hadoop.hbase.master.MasterServices; -079import org.apache.hadoop.hbase.master.locking.LockProcedure; -080import org.apache.hadoop.hbase.master.procedure.MasterProcedureEnv; -081import org.apache.hadoop.hbase.net.Address; -082import org.apache.hadoop.hbase.procedure2.LockType; -083import org.apache.hadoop.hbase.procedure2.Procedure; -084import org.apache.hadoop.hbase.procedure2.ProcedureExecutor; -085import org.apache.hadoop.hbase.protobuf.ProtobufUtil; -086import org.apache.hadoop.hbase.protobuf.generated.AccessControlProtos; -087import org.apache.hadoop.hbase.protobuf.generated.AccessControlProtos.AccessControlService; -088import org.apache.hadoop.hbase.regionserver.InternalScanner; -089import org.apache.hadoop.hbase.regionserver.MiniBatchOperationInProgress; -090import org.apache.hadoop.hbase.regionserver.Region; -091import org.apache.hadoop.hbase.regionserver.RegionScanner; -092import org.apache.hadoop.hbase.regionserver.ScanType; -093import
[05/51] [partial] hbase-site git commit: Published site at .
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/fa7d6c0c/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RegionCoprocessorHost.html -- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RegionCoprocessorHost.html b/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RegionCoprocessorHost.html index cf3f141..a4d46aa 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RegionCoprocessorHost.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RegionCoprocessorHost.html @@ -27,1612 +27,1609 @@ 019 020package org.apache.hadoop.hbase.regionserver; 021 -022import com.google.protobuf.Message; -023import com.google.protobuf.Service; -024 -025import java.io.IOException; -026import java.util.ArrayList; -027import java.util.List; -028import java.util.Map; -029import java.util.NavigableSet; -030import java.util.UUID; -031import java.util.concurrent.ConcurrentHashMap; -032import java.util.concurrent.ConcurrentMap; -033import java.util.regex.Matcher; -034 -035import org.apache.commons.collections4.map.AbstractReferenceMap; -036import org.apache.commons.collections4.map.ReferenceMap; -037import org.apache.commons.lang3.ClassUtils; -038import org.apache.commons.logging.Log; -039import org.apache.commons.logging.LogFactory; -040import org.apache.hadoop.conf.Configuration; -041import org.apache.hadoop.fs.FileSystem; -042import org.apache.hadoop.fs.Path; -043import org.apache.hadoop.hbase.Cell; -044import org.apache.hadoop.hbase.CompareOperator; -045import org.apache.hadoop.hbase.Coprocessor; -046import org.apache.hadoop.hbase.HBaseConfiguration; -047import org.apache.hadoop.hbase.HBaseInterfaceAudience; -048import org.apache.hadoop.hbase.HConstants; -049import org.apache.hadoop.hbase.HRegionInfo; -050import org.apache.yetus.audience.InterfaceAudience; -051import org.apache.yetus.audience.InterfaceStability; -052import org.apache.hadoop.hbase.client.Append; -053import org.apache.hadoop.hbase.client.Delete; -054import org.apache.hadoop.hbase.client.Durability; -055import org.apache.hadoop.hbase.client.Get; -056import org.apache.hadoop.hbase.client.Increment; -057import org.apache.hadoop.hbase.client.Mutation; -058import org.apache.hadoop.hbase.client.Put; -059import org.apache.hadoop.hbase.client.Result; -060import org.apache.hadoop.hbase.client.Scan; -061import org.apache.hadoop.hbase.client.TableDescriptor; -062import org.apache.hadoop.hbase.coprocessor.CoprocessorHost; -063import org.apache.hadoop.hbase.coprocessor.CoprocessorService; -064import org.apache.hadoop.hbase.coprocessor.EndpointObserver; -065import org.apache.hadoop.hbase.coprocessor.MetricsCoprocessor; -066import org.apache.hadoop.hbase.coprocessor.ObserverContext; -067import org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment; -068import org.apache.hadoop.hbase.coprocessor.RegionObserver; -069import org.apache.hadoop.hbase.coprocessor.RegionObserver.MutationType; -070import org.apache.hadoop.hbase.filter.ByteArrayComparable; -071import org.apache.hadoop.hbase.io.FSDataInputStreamWrapper; -072import org.apache.hadoop.hbase.io.Reference; -073import org.apache.hadoop.hbase.io.hfile.CacheConfig; -074import org.apache.hadoop.hbase.ipc.RpcServer; -075import org.apache.hadoop.hbase.metrics.MetricRegistry; -076import org.apache.hadoop.hbase.regionserver.Region.Operation; -077import org.apache.hadoop.hbase.regionserver.compactions.CompactionLifeCycleTracker; -078import org.apache.hadoop.hbase.regionserver.compactions.CompactionRequest; -079import org.apache.hadoop.hbase.regionserver.querymatcher.DeleteTracker; -080import org.apache.hadoop.hbase.security.User; -081import org.apache.hadoop.hbase.util.Bytes; -082import org.apache.hadoop.hbase.util.CoprocessorClassLoader; -083import org.apache.hadoop.hbase.util.Pair; -084import org.apache.hadoop.hbase.wal.WALEdit; -085import org.apache.hadoop.hbase.wal.WALKey; +022import java.io.IOException; +023import java.util.ArrayList; +024import java.util.List; +025import java.util.Map; +026import java.util.NavigableSet; +027import java.util.UUID; +028import java.util.concurrent.ConcurrentHashMap; +029import java.util.concurrent.ConcurrentMap; +030import java.util.regex.Matcher; +031 +032import com.google.protobuf.Message; +033import com.google.protobuf.Service; +034import org.apache.commons.collections4.map.AbstractReferenceMap; +035import org.apache.commons.collections4.map.ReferenceMap; +036import org.apache.commons.lang3.ClassUtils; +037import org.apache.commons.logging.Log; +038import org.apache.commons.logging.LogFactory; +039import org.apache.hadoop.conf.Configuration; +040import org.apache.hadoop.fs.FileSystem; +041import org.apache.hadoop.fs.Path; +042import org.apache.hadoop.hbase.Cell; +043import org.apache.hadoop.hbase.CompareOperator; +044import org.apache.hadoop.hbase.Coprocessor; +045import
hbase-site git commit: INFRA-10751 Empty commit
Repository: hbase-site Updated Branches: refs/heads/asf-site fa7d6c0c6 -> fed4a206f 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/fed4a206 Tree: http://git-wip-us.apache.org/repos/asf/hbase-site/tree/fed4a206 Diff: http://git-wip-us.apache.org/repos/asf/hbase-site/diff/fed4a206 Branch: refs/heads/asf-site Commit: fed4a206f3d4fa9d52e6ebfcced59e32a826ffce Parents: fa7d6c0 Author: jenkinsAuthored: Thu Sep 21 15:13:53 2017 + Committer: jenkins Committed: Thu Sep 21 15:13:53 2017 + -- --
[02/51] [partial] hbase-site git commit: Published site at .
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/fa7d6c0c/devapidocs/src-html/org/apache/hadoop/hbase/rsgroup/RSGroupAdminEndpoint.html -- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/rsgroup/RSGroupAdminEndpoint.html b/devapidocs/src-html/org/apache/hadoop/hbase/rsgroup/RSGroupAdminEndpoint.html index a47d486..89f4de2 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/rsgroup/RSGroupAdminEndpoint.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/rsgroup/RSGroupAdminEndpoint.html @@ -30,336 +30,335 @@ 022import java.util.HashSet; 023import java.util.Set; 024 -025import org.apache.hadoop.hbase.shaded.com.google.common.collect.Sets; -026import com.google.protobuf.RpcCallback; -027import com.google.protobuf.RpcController; -028import com.google.protobuf.Service; -029import org.apache.commons.logging.Log; -030import org.apache.commons.logging.LogFactory; -031import org.apache.hadoop.hbase.CoprocessorEnvironment; -032import org.apache.hadoop.hbase.HConstants; -033import org.apache.hadoop.hbase.HRegionInfo; -034import org.apache.hadoop.hbase.HTableDescriptor; -035import org.apache.hadoop.hbase.NamespaceDescriptor; -036import org.apache.hadoop.hbase.TableName; -037import org.apache.yetus.audience.InterfaceAudience; -038import org.apache.hadoop.hbase.client.TableDescriptor; -039import org.apache.hadoop.hbase.constraint.ConstraintException; -040import org.apache.hadoop.hbase.coprocessor.CoprocessorService; -041import org.apache.hadoop.hbase.coprocessor.MasterCoprocessorEnvironment; -042import org.apache.hadoop.hbase.coprocessor.MasterObserver; -043import org.apache.hadoop.hbase.coprocessor.ObserverContext; -044import org.apache.hadoop.hbase.ipc.CoprocessorRpcUtils; -045import org.apache.hadoop.hbase.master.MasterServices; -046import org.apache.hadoop.hbase.net.Address; -047import org.apache.hadoop.hbase.protobuf.ProtobufUtil; -048import org.apache.hadoop.hbase.protobuf.generated.HBaseProtos; -049import org.apache.hadoop.hbase.protobuf.generated.RSGroupAdminProtos; -050import org.apache.hadoop.hbase.protobuf.generated.RSGroupAdminProtos.AddRSGroupRequest; -051import org.apache.hadoop.hbase.protobuf.generated.RSGroupAdminProtos.AddRSGroupResponse; -052import org.apache.hadoop.hbase.protobuf.generated.RSGroupAdminProtos.BalanceRSGroupRequest; -053import org.apache.hadoop.hbase.protobuf.generated.RSGroupAdminProtos.BalanceRSGroupResponse; -054import org.apache.hadoop.hbase.protobuf.generated.RSGroupAdminProtos.GetRSGroupInfoOfServerRequest; -055import org.apache.hadoop.hbase.protobuf.generated.RSGroupAdminProtos.GetRSGroupInfoOfServerResponse; -056import org.apache.hadoop.hbase.protobuf.generated.RSGroupAdminProtos.GetRSGroupInfoOfTableRequest; -057import org.apache.hadoop.hbase.protobuf.generated.RSGroupAdminProtos.GetRSGroupInfoOfTableResponse; -058import org.apache.hadoop.hbase.protobuf.generated.RSGroupAdminProtos.GetRSGroupInfoRequest; -059import org.apache.hadoop.hbase.protobuf.generated.RSGroupAdminProtos.GetRSGroupInfoResponse; -060import org.apache.hadoop.hbase.protobuf.generated.RSGroupAdminProtos.ListRSGroupInfosRequest; -061import org.apache.hadoop.hbase.protobuf.generated.RSGroupAdminProtos.ListRSGroupInfosResponse; -062import org.apache.hadoop.hbase.protobuf.generated.RSGroupAdminProtos.MoveServersAndTablesRequest; -063import org.apache.hadoop.hbase.protobuf.generated.RSGroupAdminProtos.MoveServersAndTablesResponse; -064import org.apache.hadoop.hbase.protobuf.generated.RSGroupAdminProtos.MoveServersRequest; -065import org.apache.hadoop.hbase.protobuf.generated.RSGroupAdminProtos.MoveServersResponse; -066import org.apache.hadoop.hbase.protobuf.generated.RSGroupAdminProtos.MoveTablesRequest; -067import org.apache.hadoop.hbase.protobuf.generated.RSGroupAdminProtos.MoveTablesResponse; -068import org.apache.hadoop.hbase.protobuf.generated.RSGroupAdminProtos.RSGroupAdminService; -069import org.apache.hadoop.hbase.protobuf.generated.RSGroupAdminProtos.RemoveRSGroupRequest; -070import org.apache.hadoop.hbase.protobuf.generated.RSGroupAdminProtos.RemoveRSGroupResponse; -071import org.apache.hadoop.hbase.shaded.protobuf.generated.SnapshotProtos.SnapshotDescription; -072 -073@InterfaceAudience.Private -074public class RSGroupAdminEndpoint implements MasterObserver, CoprocessorService { -075 private static final Log LOG = LogFactory.getLog(RSGroupAdminEndpoint.class); -076 -077 private MasterServices master = null; -078 // Only instance of RSGroupInfoManager. RSGroup aware load balancers ask for this instance on -079 // their setup. -080 private RSGroupInfoManager groupInfoManager; -081 private RSGroupAdminServer groupAdminServer; -082 private final RSGroupAdminService groupAdminService = new RSGroupAdminServiceImpl(); -083 -084 @Override -085 public void start(CoprocessorEnvironment env) throws IOException { -086master =
[36/51] [partial] hbase-site git commit: Published site at .
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/fa7d6c0c/devapidocs/org/apache/hadoop/hbase/coprocessor/example/ExampleRegionObserverWithMetrics.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/coprocessor/example/ExampleRegionObserverWithMetrics.html b/devapidocs/org/apache/hadoop/hbase/coprocessor/example/ExampleRegionObserverWithMetrics.html index 696325b..e2fdfda 100644 --- a/devapidocs/org/apache/hadoop/hbase/coprocessor/example/ExampleRegionObserverWithMetrics.html +++ b/devapidocs/org/apache/hadoop/hbase/coprocessor/example/ExampleRegionObserverWithMetrics.html @@ -255,7 +255,7 @@ implements RegionObserver -postAppend, postBatchMutate, postBatchMutateIndispensably, postBulkLoadHFile, postCheckAndDelete, postCheckAndPut, postClose, postCloseRegionOperation, postCommitStoreFile, postCompact, postCompactS election, postDelete, postExists, postFlush, postFlush, postIncrement, postInstantiateDeleteTracker, postLogReplay, postMutationBeforeWAL, postOpen, postPut, postReplayWALs, postScannerClose, postScannerFilterRow, postScannerNext, postScannerOpen, postStartRegionOperation, postStoreFileReaderOpen, postWALRestore, preAppend, preAppendAfterRowLock, preBatchMutate, preBulkLoadHFile, preCheckAndDelete, preCheckAndDeleteAfterRowLock, preCheckAndPut, preCheckAndPutAfterRowLock, preC lose, preCommitStoreFile, preCompact, p reCompactScannerOpen, preCompactSelection, preDelete, preExists, preFlush, preFlush, preFlushScannerOpen, preIncrement, preIncrementAfterRowLock, preOpen, prePrepareTimeStampForDeleteVersion, prePut, preReplayWALs, preScannerClose, preScannerNext, preScannerOpen, preStoreFileReaderOpen, preStoreScannerOpen, preWALRestore +postAppend, postBatchMutate, postBatchMutateIndispensably, postBulkLoadHFile, postCheckAndDelete, postCheckAndPut, postClose, postCloseRegionOperation, postCommitStoreFile, postCompact, postCompactS election, postDelete, postExists, postFlush, postFlush, postIncrement, postInstantiateDeleteTracker, postLogReplay, postMutationBeforeWAL, postOpen, postPut, postReplayWALs, postScannerClose, postScannerFilterRow, postScannerNext, postScannerOpen, postStartRegionOperation, postStoreFileReaderOpen, postWALRestore, preAppend, preAppendAfterRowLock, preBatchMutate, preBulkLoadHFile, preCheckAndDelete, preCheckAndDeleteAfterRowLock, preCheckAndPut, preCheckAndPutAfterRowLock, preClose, preCommitStoreFile, preCompact, preCompactScannerOpen, preCompactSelection, preDelete, preExists, preFlush, preFlush, preFlushScannerOpen, preIncrement, preIncrementAfterRowLock, < a href="../../../../../../org/apache/hadoop/hbase/coprocessor/RegionObserver.html#preOpen-org.apache.hadoop.hbase.coprocessor.ObserverContext-">preOpen, prePrepareTimeStampForDeleteVersion, prePut, preReplayWALs, preScannerClose, preScannerNext, preScannerOpen, preStoreFileReaderOpen, preStoreScannerOpen, preWALRestore http://git-wip-us.apache.org/repos/asf/hbase-site/blob/fa7d6c0c/devapidocs/org/apache/hadoop/hbase/coprocessor/example/ZooKeeperScanPolicyObserver.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/coprocessor/example/ZooKeeperScanPolicyObserver.html b/devapidocs/org/apache/hadoop/hbase/coprocessor/example/ZooKeeperScanPolicyObserver.html index 7c65ba7..99a68be 100644 --- a/devapidocs/org/apache/hadoop/hbase/coprocessor/example/ZooKeeperScanPolicyObserver.html +++ b/devapidocs/org/apache/hadoop/hbase/coprocessor/example/ZooKeeperScanPolicyObserver.html @@ -293,7 +293,7 @@ implements RegionObserver -postAppend, postBatchMutate, postBatchMutateIndispensably, postBulkLoadHFile, postCheckAndDelete, postCheckAndPut, postClose, postCloseRegionOperation, postCommitStoreFile, postCompact, postCompactS election, postDelete, postExists, postFlush, postFlush, postGetOp, postIncrement, postInstantiateDeleteTracker, postLogReplay, postMutationBeforeWAL, postOpen, postPut, postReplayWALs, postScannerClose, postScannerFilterRow, postScannerNext, postScannerOpen, postStartRegionOperation, postStoreFileReaderOpen, postWALRestore, preAppend, preAppendAfterRowLock, preBatchMutate, preBulkLoadHFile, preCheckAn dDelete, preCheckAndDeleteAfterRowLock, preCheckAndPut, preCheckAndPutAfterRowLock, preClose, preCommitStoreFile, preCompact, preCompactSelection, preDelete, preExists, preFlush, preFlush, preGetOp, preIncrement, preIncrementAfterRowLock, preOpen, prePrepareTimeStampForDeleteVersion, prePut, preReplayWALs, preScannerClose, preScannerNext, preScannerOpen, preStoreFileReaderOpen, preWALRestore +postAppend, postBatchMutate, postBatchMutateIndispensably, postBulkLoadHFile, postCheckAndDelete, postCheckAndPut, postClose, postCloseRegionOperation, postCommitStoreFile, postCompact,
[06/51] [partial] hbase-site git commit: Published site at .
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/fa7d6c0c/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RegionCoprocessorHost.TableCoprocessorAttribute.html -- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RegionCoprocessorHost.TableCoprocessorAttribute.html b/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RegionCoprocessorHost.TableCoprocessorAttribute.html index cf3f141..a4d46aa 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RegionCoprocessorHost.TableCoprocessorAttribute.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RegionCoprocessorHost.TableCoprocessorAttribute.html @@ -27,1612 +27,1609 @@ 019 020package org.apache.hadoop.hbase.regionserver; 021 -022import com.google.protobuf.Message; -023import com.google.protobuf.Service; -024 -025import java.io.IOException; -026import java.util.ArrayList; -027import java.util.List; -028import java.util.Map; -029import java.util.NavigableSet; -030import java.util.UUID; -031import java.util.concurrent.ConcurrentHashMap; -032import java.util.concurrent.ConcurrentMap; -033import java.util.regex.Matcher; -034 -035import org.apache.commons.collections4.map.AbstractReferenceMap; -036import org.apache.commons.collections4.map.ReferenceMap; -037import org.apache.commons.lang3.ClassUtils; -038import org.apache.commons.logging.Log; -039import org.apache.commons.logging.LogFactory; -040import org.apache.hadoop.conf.Configuration; -041import org.apache.hadoop.fs.FileSystem; -042import org.apache.hadoop.fs.Path; -043import org.apache.hadoop.hbase.Cell; -044import org.apache.hadoop.hbase.CompareOperator; -045import org.apache.hadoop.hbase.Coprocessor; -046import org.apache.hadoop.hbase.HBaseConfiguration; -047import org.apache.hadoop.hbase.HBaseInterfaceAudience; -048import org.apache.hadoop.hbase.HConstants; -049import org.apache.hadoop.hbase.HRegionInfo; -050import org.apache.yetus.audience.InterfaceAudience; -051import org.apache.yetus.audience.InterfaceStability; -052import org.apache.hadoop.hbase.client.Append; -053import org.apache.hadoop.hbase.client.Delete; -054import org.apache.hadoop.hbase.client.Durability; -055import org.apache.hadoop.hbase.client.Get; -056import org.apache.hadoop.hbase.client.Increment; -057import org.apache.hadoop.hbase.client.Mutation; -058import org.apache.hadoop.hbase.client.Put; -059import org.apache.hadoop.hbase.client.Result; -060import org.apache.hadoop.hbase.client.Scan; -061import org.apache.hadoop.hbase.client.TableDescriptor; -062import org.apache.hadoop.hbase.coprocessor.CoprocessorHost; -063import org.apache.hadoop.hbase.coprocessor.CoprocessorService; -064import org.apache.hadoop.hbase.coprocessor.EndpointObserver; -065import org.apache.hadoop.hbase.coprocessor.MetricsCoprocessor; -066import org.apache.hadoop.hbase.coprocessor.ObserverContext; -067import org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment; -068import org.apache.hadoop.hbase.coprocessor.RegionObserver; -069import org.apache.hadoop.hbase.coprocessor.RegionObserver.MutationType; -070import org.apache.hadoop.hbase.filter.ByteArrayComparable; -071import org.apache.hadoop.hbase.io.FSDataInputStreamWrapper; -072import org.apache.hadoop.hbase.io.Reference; -073import org.apache.hadoop.hbase.io.hfile.CacheConfig; -074import org.apache.hadoop.hbase.ipc.RpcServer; -075import org.apache.hadoop.hbase.metrics.MetricRegistry; -076import org.apache.hadoop.hbase.regionserver.Region.Operation; -077import org.apache.hadoop.hbase.regionserver.compactions.CompactionLifeCycleTracker; -078import org.apache.hadoop.hbase.regionserver.compactions.CompactionRequest; -079import org.apache.hadoop.hbase.regionserver.querymatcher.DeleteTracker; -080import org.apache.hadoop.hbase.security.User; -081import org.apache.hadoop.hbase.util.Bytes; -082import org.apache.hadoop.hbase.util.CoprocessorClassLoader; -083import org.apache.hadoop.hbase.util.Pair; -084import org.apache.hadoop.hbase.wal.WALEdit; -085import org.apache.hadoop.hbase.wal.WALKey; +022import java.io.IOException; +023import java.util.ArrayList; +024import java.util.List; +025import java.util.Map; +026import java.util.NavigableSet; +027import java.util.UUID; +028import java.util.concurrent.ConcurrentHashMap; +029import java.util.concurrent.ConcurrentMap; +030import java.util.regex.Matcher; +031 +032import com.google.protobuf.Message; +033import com.google.protobuf.Service; +034import org.apache.commons.collections4.map.AbstractReferenceMap; +035import org.apache.commons.collections4.map.ReferenceMap; +036import org.apache.commons.lang3.ClassUtils; +037import org.apache.commons.logging.Log; +038import org.apache.commons.logging.LogFactory; +039import org.apache.hadoop.conf.Configuration; +040import org.apache.hadoop.fs.FileSystem; +041import org.apache.hadoop.fs.Path; +042import
[26/51] [partial] hbase-site git commit: Published site at .
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/fa7d6c0c/devapidocs/org/apache/hadoop/hbase/security/access/CoprocessorWhitelistMasterObserver.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/security/access/CoprocessorWhitelistMasterObserver.html b/devapidocs/org/apache/hadoop/hbase/security/access/CoprocessorWhitelistMasterObserver.html index dc29350..241708a 100644 --- a/devapidocs/org/apache/hadoop/hbase/security/access/CoprocessorWhitelistMasterObserver.html +++ b/devapidocs/org/apache/hadoop/hbase/security/access/CoprocessorWhitelistMasterObserver.html @@ -114,7 +114,7 @@ var activeTableTab = "activeTableTab"; @InterfaceAudience.LimitedPrivate(value="Configuration") -public class CoprocessorWhitelistMasterObserver +public class CoprocessorWhitelistMasterObserver extends http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true; title="class or interface in java.lang">Object implements MasterObserver Master observer for restricting coprocessor assignments. @@ -200,9 +200,9 @@ implements void -preCreateTable(ObserverContextMasterCoprocessorEnvironmentctx, +preCreateTable(ObserverContextMasterCoprocessorEnvironmentctx, TableDescriptorhtd, - HRegionInfo[]regions) + RegionInfo[]regions) Called before a new table is created by HMaster. @@ -244,7 +244,7 @@ implements MasterObserver -postAbortProcedure, postAddColumnFamily, postAddReplicationPeer, postAddRSGroup, postAssign, postBalance, postBalanceRSGroup, postBalanceSwitch, postClearDeadServers, postCloneSnapshot, postCompletedAddColumnFamilyAction, postCompletedCreateTableAction, post CompletedDeleteColumnFamilyAction, postCompletedDeleteTableAction, postCompletedDisableTableAction, postCompletedEnableTableAction, postCompletedMergeRegionsAction, href="../../../../../../org/apache/hadoop/hbase/coprocessor/MasterObserver.html#postCompletedModifyColumnFamilyAction-org.apache.hadoop.hbase.coprocessor.ObserverContext-org.apache.hadoop.hbase.TableName-org.apache.hadoop.hbase.client.ColumnFamilyDescriptor-">postCompletedModifyColumnFamilyAction, > href="../../../../../../org/apache/hadoop/hbase/coprocessor/MasterObserver.html#postCompletedModifyTableAction-org.apache.hadoop.hbase.coprocessor.ObserverContext-org.apache.hadoop.hbase.TableName-org.apache.hadoop.hbase.client.TableDescriptor-">postCompletedModifyTableAction, > href="../../../../../../org/apache/hadoop/hbase/coprocessor/MasterObserver.html#postCompletedSplitRegionAction-org.apache.hadoop.hbase.coprocessor.ObserverContext-org.apache.hadoop.hbase.HRegionInfo-org.apache.hadoop.hbase.HRegionInfo-">postCompletedSplitRegionAction, > href="../../../../../../org/apache/hadoop/hbase/coprocessor/MasterObserver.html#postCompl etedTruncateTableAction-org.apache.hadoop.hbase.coprocessor.ObserverContext-org.apache.hadoop.hbase.TableName-">postCompletedTruncateTableAction, postCreateNamespace, postCreateTable, postDeleteColumnFamily, postDeleteNamespace, postDeleteSnapshot, postDeleteTable, postDisableReplicationPeer, postDisableTable, postEnableReplicationPeer, postEnableTable, postGetLocks, postGetNamespaceDescriptor, postGetProcedures, href="../../../../../../org/apache/hadoop/hbase/coprocessor/MasterObserver.html#postGetReplicationPeerConfig-org.apache.hadoop.hbase.coprocessor.ObserverContext-java.lang.String-">postGetReplicationPeerConfig, > href="../../../../../../org/apache/hadoop/hbase/coprocessor/MasterObserver.html#postGetTableDescriptors-org.apache.hadoop.hbase.coprocessor.ObserverContext-java.util.List-java.util.List-java.lang.String-">postGetTableDescriptors, > href="../../../../../../org/apache/hadoop/hbase/coprocessor/MasterObserver.html#postGetTableNames-org.apache.hadoop.hbase.coprocessor.ObserverContext-java.util.List-java.lang.String-">postGetTableNames, > href="../../../../../../org/apache/hadoop/hbase/coprocessor/MasterObserver.html#postListDeadServers-org.apache.hadoop.hbase.coprocessor.ObserverContext-">postListDeadServers, > href="../../../../../../org/apache/hadoop/hbase/coprocessor/MasterObserver.html#postListNamespaceDescriptors-org.apache.hadoop.hbase.coprocessor. ObserverContext-java.util.List-">postListNamespaceDescriptors, postListReplicationPeers, postListSnapshot, postLockHeartbeat, postMergeRegions, postMergeRegionsCommitAction, postModifyColumnFamily, postModifyNamespace, postModifyTable, postMove, postMoveServers, postMoveServersAndTables, postMoveTables, postRegionOffline, postRemoveReplicationPeer, postRemoveRSGroup, postRequestLock, postRestoreSnapshot, postRollBackMergeRegionsAction, postRollBackSplitRegionAction, postSetNamespaceQuota, postSetSplitOrMergeEnabled, postSetTableQuota, postSetUserQuota, postSetUserQuota, postSetUserQuota, postSnapshot, postStartMaster, postTableFlush, postTruncateTable, postUnassign,
[17/51] [partial] hbase-site git commit: Published site at .
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/fa7d6c0c/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RSRpcServices.RegionScannerHolder.html -- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RSRpcServices.RegionScannerHolder.html b/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RSRpcServices.RegionScannerHolder.html index e0b1774..f3d4c5e 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RSRpcServices.RegionScannerHolder.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RSRpcServices.RegionScannerHolder.html @@ -605,13 +605,13 @@ 597 * @param row 598 * @param family 599 * @param qualifier -600 * @param op +600 * @param compareOp 601 * @param comparator @throws IOException 602 */ 603 private boolean checkAndRowMutate(final Region region, final ListClientProtos.Action actions, -604 final CellScanner cellScanner, byte[] row, byte[] family, byte[] qualifier, -605 CompareOperator op, ByteArrayComparable comparator, RegionActionResult.Builder builder, -606 ActivePolicyEnforcement spaceQuotaEnforcement) throws IOException { +604final CellScanner cellScanner, byte[] row, byte[] family, byte[] qualifier, +605 CompareOperator op, ByteArrayComparable comparator, RegionActionResult.Builder builder, +606 ActivePolicyEnforcement spaceQuotaEnforcement) throws IOException { 607if (!region.getRegionInfo().isMetaTable()) { 608 regionServer.cacheFlusher.reclaimMemStoreMemory(); 609} @@ -656,2842 +656,2846 @@ 648 649 /** 650 * Execute an append mutation. -651 * @return result to return to client if default operation should be -652 * bypassed as indicated by RegionObserver, null otherwise -653 * @throws IOException -654 */ -655 private Result append(final Region region, final OperationQuota quota, -656 final MutationProto mutation, final CellScanner cellScanner, long nonceGroup, -657 ActivePolicyEnforcement spaceQuota) -658 throws IOException { -659long before = EnvironmentEdgeManager.currentTime(); -660Append append = ProtobufUtil.toAppend(mutation, cellScanner); -661checkCellSizeLimit(region, append); -662 spaceQuota.getPolicyEnforcement(region).check(append); -663quota.addMutation(append); -664Result r = null; -665if (region.getCoprocessorHost() != null) { -666 r = region.getCoprocessorHost().preAppend(append); -667} -668if (r == null) { -669 boolean canProceed = startNonceOperation(mutation, nonceGroup); -670 boolean success = false; -671 try { -672long nonce = mutation.hasNonce() ? mutation.getNonce() : HConstants.NO_NONCE; -673if (canProceed) { -674 r = region.append(append, nonceGroup, nonce); -675} else { -676 // convert duplicate append to get -677 ListCell results = region.get(ProtobufUtil.toGet(mutation, cellScanner), false, -678nonceGroup, nonce); -679 r = Result.create(results); -680} -681success = true; -682 } finally { -683if (canProceed) { -684 endNonceOperation(mutation, nonceGroup, success); -685} -686 } -687 if (region.getCoprocessorHost() != null) { -688r = region.getCoprocessorHost().postAppend(append, r); -689 } -690} -691if (regionServer.metricsRegionServer != null) { -692 regionServer.metricsRegionServer.updateAppend( -693 EnvironmentEdgeManager.currentTime() - before); +651 * +652 * @param region +653 * @param m +654 * @param cellScanner +655 * @return result to return to client if default operation should be +656 * bypassed as indicated by RegionObserver, null otherwise +657 * @throws IOException +658 */ +659 private Result append(final Region region, final OperationQuota quota, +660 final MutationProto mutation, final CellScanner cellScanner, long nonceGroup, +661 ActivePolicyEnforcement spaceQuota) +662 throws IOException { +663long before = EnvironmentEdgeManager.currentTime(); +664Append append = ProtobufUtil.toAppend(mutation, cellScanner); +665checkCellSizeLimit(region, append); +666 spaceQuota.getPolicyEnforcement(region).check(append); +667quota.addMutation(append); +668Result r = null; +669if (region.getCoprocessorHost() != null) { +670 r = region.getCoprocessorHost().preAppend(append); +671} +672if (r == null) { +673 boolean canProceed = startNonceOperation(mutation, nonceGroup); +674 boolean success = false; +675 try { +676long nonce = mutation.hasNonce() ? mutation.getNonce() : HConstants.NO_NONCE; +677if (canProceed) { +678 r = region.append(append, nonceGroup, nonce); +679
[51/51] [partial] hbase-site git commit: Published site at .
Published site at . Project: http://git-wip-us.apache.org/repos/asf/hbase-site/repo Commit: http://git-wip-us.apache.org/repos/asf/hbase-site/commit/fa7d6c0c Tree: http://git-wip-us.apache.org/repos/asf/hbase-site/tree/fa7d6c0c Diff: http://git-wip-us.apache.org/repos/asf/hbase-site/diff/fa7d6c0c Branch: refs/heads/asf-site Commit: fa7d6c0c64dcaaa065ff24903d9f0b1dddc138e6 Parents: 21bac65 Author: jenkinsAuthored: Thu Sep 21 15:13:17 2017 + Committer: jenkins Committed: Thu Sep 21 15:13:17 2017 + -- acid-semantics.html | 4 +- apache_hbase_reference_guide.pdf| 6 +- book.html | 2 +- bulk-loads.html | 4 +- checkstyle-aggregate.html | 25208 - checkstyle.rss |28 +- coc.html| 4 +- cygwin.html | 4 +- dependencies.html | 4 +- dependency-convergence.html | 4 +- dependency-info.html| 4 +- dependency-management.html | 4 +- devapidocs/constant-values.html | 6 +- devapidocs/index-all.html | 136 +- .../hadoop/hbase/backup/BackupObserver.html | 2 +- .../hadoop/hbase/backup/package-tree.html | 2 +- .../hadoop/hbase/class-use/HRegionInfo.html | 602 +- .../hbase/class-use/MetaMutationAnnotation.html | 6 +- .../hadoop/hbase/class-use/ServerName.html |16 +- .../hadoop/hbase/class-use/TableName.html |24 +- .../hadoop/hbase/client/class-use/Mutation.html | 6 +- .../hbase/client/class-use/RegionInfo.html | 635 + .../hbase/client/class-use/TableDescriptor.html |56 +- .../hadoop/hbase/client/package-tree.html |24 +- .../apache/hadoop/hbase/client/package-use.html |70 +- .../hbase/constraint/ConstraintProcessor.html | 2 +- .../hbase/coprocessor/MasterObserver.html | 192 +- .../RegionCoprocessorEnvironment.html | 4 +- .../RegionObserver.MutationType.html| 4 +- .../hbase/coprocessor/RegionObserver.html |32 +- .../hadoop/hbase/coprocessor/WALObserver.html |16 +- .../class-use/MasterCoprocessorEnvironment.html | 142 +- .../coprocessor/class-use/ObserverContext.html | 166 +- .../class-use/RegionCoprocessorEnvironment.html |16 +- .../class-use/WALCoprocessorEnvironment.html| 8 +- .../ExampleMasterObserverWithMetrics.html |26 +- .../ExampleRegionObserverWithMetrics.html | 2 +- .../example/ZooKeeperScanPolicyObserver.html| 2 +- .../hadoop/hbase/executor/package-tree.html | 2 +- .../hadoop/hbase/filter/package-tree.html | 8 +- .../hadoop/hbase/io/hfile/package-tree.html | 8 +- .../apache/hadoop/hbase/ipc/package-tree.html | 2 +- .../hadoop/hbase/mapreduce/package-tree.html| 2 +- .../hbase/master/MasterCoprocessorHost.html | 156 +- .../hadoop/hbase/master/package-tree.html | 6 +- .../hbase/master/procedure/package-tree.html| 2 +- .../org/apache/hadoop/hbase/package-tree.html |16 +- .../org/apache/hadoop/hbase/package-use.html|26 +- .../hbase/procedure2/class-use/LockType.html|20 +- .../hadoop/hbase/procedure2/package-tree.html | 4 +- .../hbase/quotas/MasterSpaceQuotaObserver.html | 2 +- .../hadoop/hbase/quotas/package-tree.html | 4 +- .../regionserver/RSRpcServices.LogDelegate.html | 4 +- .../hbase/regionserver/RSRpcServices.html | 160 +- ...ionCoprocessorHost.CoprocessorOperation.html |12 +- ...RegionCoprocessorHost.EndpointOperation.html |10 +- ...ocessorHost.EndpointOperationWithResult.html |10 +- ...RegionCoprocessorHost.RegionEnvironment.html |26 +- .../RegionCoprocessorHost.RegionOperation.html |12 +- ...processorHost.RegionOperationWithResult.html |12 +- ...processorHost.TableCoprocessorAttribute.html |20 +- .../regionserver/RegionCoprocessorHost.html | 174 +- .../hadoop/hbase/regionserver/package-tree.html |16 +- .../regionserver/querymatcher/package-tree.html | 2 +- .../regionserver/wal/ProtobufLogReader.html | 4 +- .../WALCellCodec.ByteStringCompressor.html | 2 +- .../WALCellCodec.ByteStringUncompressor.html| 2 +- .../hbase/regionserver/wal/package-tree.html| 2 +- .../regionserver/ReplicationObserver.html | 2 +- .../hadoop/hbase/rest/model/package-tree.html | 2 +- ...upAdminEndpoint.RSGroupAdminServiceImpl.html |24 +- .../hbase/rsgroup/RSGroupAdminEndpoint.html |46 +-
[34/51] [partial] hbase-site git commit: Published site at .
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/fa7d6c0c/devapidocs/org/apache/hadoop/hbase/procedure2/class-use/LockType.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/procedure2/class-use/LockType.html b/devapidocs/org/apache/hadoop/hbase/procedure2/class-use/LockType.html index 25013e5..865a104 100644 --- a/devapidocs/org/apache/hadoop/hbase/procedure2/class-use/LockType.html +++ b/devapidocs/org/apache/hadoop/hbase/procedure2/class-use/LockType.html @@ -122,10 +122,10 @@ default void -MasterObserver.postRequestLock(ObserverContextMasterCoprocessorEnvironmentctx, +MasterObserver.postRequestLock(ObserverContextMasterCoprocessorEnvironmentctx, http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">Stringnamespace, TableNametableName, - HRegionInfo[]regionInfos, + RegionInfo[]regionInfos, LockTypetype, http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">Stringdescription) Called after new LockProcedure is queued. @@ -133,10 +133,10 @@ default void -MasterObserver.preRequestLock(ObserverContextMasterCoprocessorEnvironmentctx, +MasterObserver.preRequestLock(ObserverContextMasterCoprocessorEnvironmentctx, http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">Stringnamespace, TableNametableName, - HRegionInfo[]regionInfos, + RegionInfo[]regionInfos, LockTypetype, http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">Stringdescription) Called before new LockProcedure is queued. @@ -158,17 +158,17 @@ void -MasterCoprocessorHost.postRequestLock(http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">Stringnamespace, +MasterCoprocessorHost.postRequestLock(http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">Stringnamespace, TableNametableName, - HRegionInfo[]regionInfos, + RegionInfo[]regionInfos, LockTypetype, http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">Stringdescription) void -MasterCoprocessorHost.preRequestLock(http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">Stringnamespace, +MasterCoprocessorHost.preRequestLock(http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">Stringnamespace, TableNametableName, - HRegionInfo[]regionInfos, + RegionInfo[]regionInfos, LockTypetype, http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">Stringdescription) @@ -382,10 +382,10 @@ the order they are declared. void -AccessController.preRequestLock(ObserverContextMasterCoprocessorEnvironmentctx, +AccessController.preRequestLock(ObserverContextMasterCoprocessorEnvironmentctx, http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">Stringnamespace, TableNametableName, - HRegionInfo[]regionInfos, + RegionInfo[]regionInfos, LockTypetype, http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">Stringdescription) http://git-wip-us.apache.org/repos/asf/hbase-site/blob/fa7d6c0c/devapidocs/org/apache/hadoop/hbase/procedure2/package-tree.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/procedure2/package-tree.html b/devapidocs/org/apache/hadoop/hbase/procedure2/package-tree.html index c528d3a..0673765 100644 --- a/devapidocs/org/apache/hadoop/hbase/procedure2/package-tree.html +++ b/devapidocs/org/apache/hadoop/hbase/procedure2/package-tree.html @@ -203,11 +203,11 @@ java.lang.http://docs.oracle.com/javase/8/docs/api/java/lang/Enum.html?is-external=true; title="class or interface in java.lang">EnumE (implements java.lang.http://docs.oracle.com/javase/8/docs/api/java/lang/Comparable.html?is-external=true; title="class or interface in java.lang">ComparableT, java.io.http://docs.oracle.com/javase/8/docs/api/java/io/Serializable.html?is-external=true; title="class or interface in java.io">Serializable)
[14/51] [partial] hbase-site git commit: Published site at .
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/fa7d6c0c/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RSRpcServices.ScannerListener.html -- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RSRpcServices.ScannerListener.html b/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RSRpcServices.ScannerListener.html index e0b1774..f3d4c5e 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RSRpcServices.ScannerListener.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RSRpcServices.ScannerListener.html @@ -605,13 +605,13 @@ 597 * @param row 598 * @param family 599 * @param qualifier -600 * @param op +600 * @param compareOp 601 * @param comparator @throws IOException 602 */ 603 private boolean checkAndRowMutate(final Region region, final ListClientProtos.Action actions, -604 final CellScanner cellScanner, byte[] row, byte[] family, byte[] qualifier, -605 CompareOperator op, ByteArrayComparable comparator, RegionActionResult.Builder builder, -606 ActivePolicyEnforcement spaceQuotaEnforcement) throws IOException { +604final CellScanner cellScanner, byte[] row, byte[] family, byte[] qualifier, +605 CompareOperator op, ByteArrayComparable comparator, RegionActionResult.Builder builder, +606 ActivePolicyEnforcement spaceQuotaEnforcement) throws IOException { 607if (!region.getRegionInfo().isMetaTable()) { 608 regionServer.cacheFlusher.reclaimMemStoreMemory(); 609} @@ -656,2842 +656,2846 @@ 648 649 /** 650 * Execute an append mutation. -651 * @return result to return to client if default operation should be -652 * bypassed as indicated by RegionObserver, null otherwise -653 * @throws IOException -654 */ -655 private Result append(final Region region, final OperationQuota quota, -656 final MutationProto mutation, final CellScanner cellScanner, long nonceGroup, -657 ActivePolicyEnforcement spaceQuota) -658 throws IOException { -659long before = EnvironmentEdgeManager.currentTime(); -660Append append = ProtobufUtil.toAppend(mutation, cellScanner); -661checkCellSizeLimit(region, append); -662 spaceQuota.getPolicyEnforcement(region).check(append); -663quota.addMutation(append); -664Result r = null; -665if (region.getCoprocessorHost() != null) { -666 r = region.getCoprocessorHost().preAppend(append); -667} -668if (r == null) { -669 boolean canProceed = startNonceOperation(mutation, nonceGroup); -670 boolean success = false; -671 try { -672long nonce = mutation.hasNonce() ? mutation.getNonce() : HConstants.NO_NONCE; -673if (canProceed) { -674 r = region.append(append, nonceGroup, nonce); -675} else { -676 // convert duplicate append to get -677 ListCell results = region.get(ProtobufUtil.toGet(mutation, cellScanner), false, -678nonceGroup, nonce); -679 r = Result.create(results); -680} -681success = true; -682 } finally { -683if (canProceed) { -684 endNonceOperation(mutation, nonceGroup, success); -685} -686 } -687 if (region.getCoprocessorHost() != null) { -688r = region.getCoprocessorHost().postAppend(append, r); -689 } -690} -691if (regionServer.metricsRegionServer != null) { -692 regionServer.metricsRegionServer.updateAppend( -693 EnvironmentEdgeManager.currentTime() - before); +651 * +652 * @param region +653 * @param m +654 * @param cellScanner +655 * @return result to return to client if default operation should be +656 * bypassed as indicated by RegionObserver, null otherwise +657 * @throws IOException +658 */ +659 private Result append(final Region region, final OperationQuota quota, +660 final MutationProto mutation, final CellScanner cellScanner, long nonceGroup, +661 ActivePolicyEnforcement spaceQuota) +662 throws IOException { +663long before = EnvironmentEdgeManager.currentTime(); +664Append append = ProtobufUtil.toAppend(mutation, cellScanner); +665checkCellSizeLimit(region, append); +666 spaceQuota.getPolicyEnforcement(region).check(append); +667quota.addMutation(append); +668Result r = null; +669if (region.getCoprocessorHost() != null) { +670 r = region.getCoprocessorHost().preAppend(append); +671} +672if (r == null) { +673 boolean canProceed = startNonceOperation(mutation, nonceGroup); +674 boolean success = false; +675 try { +676long nonce = mutation.hasNonce() ? mutation.getNonce() : HConstants.NO_NONCE; +677if (canProceed) { +678 r = region.append(append, nonceGroup, nonce); +679} else { +680
[18/51] [partial] hbase-site git commit: Published site at .
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/fa7d6c0c/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RSRpcServices.RegionScannerCloseCallBack.html -- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RSRpcServices.RegionScannerCloseCallBack.html b/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RSRpcServices.RegionScannerCloseCallBack.html index e0b1774..f3d4c5e 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RSRpcServices.RegionScannerCloseCallBack.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RSRpcServices.RegionScannerCloseCallBack.html @@ -605,13 +605,13 @@ 597 * @param row 598 * @param family 599 * @param qualifier -600 * @param op +600 * @param compareOp 601 * @param comparator @throws IOException 602 */ 603 private boolean checkAndRowMutate(final Region region, final ListClientProtos.Action actions, -604 final CellScanner cellScanner, byte[] row, byte[] family, byte[] qualifier, -605 CompareOperator op, ByteArrayComparable comparator, RegionActionResult.Builder builder, -606 ActivePolicyEnforcement spaceQuotaEnforcement) throws IOException { +604final CellScanner cellScanner, byte[] row, byte[] family, byte[] qualifier, +605 CompareOperator op, ByteArrayComparable comparator, RegionActionResult.Builder builder, +606 ActivePolicyEnforcement spaceQuotaEnforcement) throws IOException { 607if (!region.getRegionInfo().isMetaTable()) { 608 regionServer.cacheFlusher.reclaimMemStoreMemory(); 609} @@ -656,2842 +656,2846 @@ 648 649 /** 650 * Execute an append mutation. -651 * @return result to return to client if default operation should be -652 * bypassed as indicated by RegionObserver, null otherwise -653 * @throws IOException -654 */ -655 private Result append(final Region region, final OperationQuota quota, -656 final MutationProto mutation, final CellScanner cellScanner, long nonceGroup, -657 ActivePolicyEnforcement spaceQuota) -658 throws IOException { -659long before = EnvironmentEdgeManager.currentTime(); -660Append append = ProtobufUtil.toAppend(mutation, cellScanner); -661checkCellSizeLimit(region, append); -662 spaceQuota.getPolicyEnforcement(region).check(append); -663quota.addMutation(append); -664Result r = null; -665if (region.getCoprocessorHost() != null) { -666 r = region.getCoprocessorHost().preAppend(append); -667} -668if (r == null) { -669 boolean canProceed = startNonceOperation(mutation, nonceGroup); -670 boolean success = false; -671 try { -672long nonce = mutation.hasNonce() ? mutation.getNonce() : HConstants.NO_NONCE; -673if (canProceed) { -674 r = region.append(append, nonceGroup, nonce); -675} else { -676 // convert duplicate append to get -677 ListCell results = region.get(ProtobufUtil.toGet(mutation, cellScanner), false, -678nonceGroup, nonce); -679 r = Result.create(results); -680} -681success = true; -682 } finally { -683if (canProceed) { -684 endNonceOperation(mutation, nonceGroup, success); -685} -686 } -687 if (region.getCoprocessorHost() != null) { -688r = region.getCoprocessorHost().postAppend(append, r); -689 } -690} -691if (regionServer.metricsRegionServer != null) { -692 regionServer.metricsRegionServer.updateAppend( -693 EnvironmentEdgeManager.currentTime() - before); +651 * +652 * @param region +653 * @param m +654 * @param cellScanner +655 * @return result to return to client if default operation should be +656 * bypassed as indicated by RegionObserver, null otherwise +657 * @throws IOException +658 */ +659 private Result append(final Region region, final OperationQuota quota, +660 final MutationProto mutation, final CellScanner cellScanner, long nonceGroup, +661 ActivePolicyEnforcement spaceQuota) +662 throws IOException { +663long before = EnvironmentEdgeManager.currentTime(); +664Append append = ProtobufUtil.toAppend(mutation, cellScanner); +665checkCellSizeLimit(region, append); +666 spaceQuota.getPolicyEnforcement(region).check(append); +667quota.addMutation(append); +668Result r = null; +669if (region.getCoprocessorHost() != null) { +670 r = region.getCoprocessorHost().preAppend(append); +671} +672if (r == null) { +673 boolean canProceed = startNonceOperation(mutation, nonceGroup); +674 boolean success = false; +675 try { +676long nonce = mutation.hasNonce() ? mutation.getNonce() : HConstants.NO_NONCE; +677if (canProceed) { +678 r =
[08/51] [partial] hbase-site git commit: Published site at .
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/fa7d6c0c/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RegionCoprocessorHost.RegionOperation.html -- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RegionCoprocessorHost.RegionOperation.html b/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RegionCoprocessorHost.RegionOperation.html index cf3f141..a4d46aa 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RegionCoprocessorHost.RegionOperation.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RegionCoprocessorHost.RegionOperation.html @@ -27,1612 +27,1609 @@ 019 020package org.apache.hadoop.hbase.regionserver; 021 -022import com.google.protobuf.Message; -023import com.google.protobuf.Service; -024 -025import java.io.IOException; -026import java.util.ArrayList; -027import java.util.List; -028import java.util.Map; -029import java.util.NavigableSet; -030import java.util.UUID; -031import java.util.concurrent.ConcurrentHashMap; -032import java.util.concurrent.ConcurrentMap; -033import java.util.regex.Matcher; -034 -035import org.apache.commons.collections4.map.AbstractReferenceMap; -036import org.apache.commons.collections4.map.ReferenceMap; -037import org.apache.commons.lang3.ClassUtils; -038import org.apache.commons.logging.Log; -039import org.apache.commons.logging.LogFactory; -040import org.apache.hadoop.conf.Configuration; -041import org.apache.hadoop.fs.FileSystem; -042import org.apache.hadoop.fs.Path; -043import org.apache.hadoop.hbase.Cell; -044import org.apache.hadoop.hbase.CompareOperator; -045import org.apache.hadoop.hbase.Coprocessor; -046import org.apache.hadoop.hbase.HBaseConfiguration; -047import org.apache.hadoop.hbase.HBaseInterfaceAudience; -048import org.apache.hadoop.hbase.HConstants; -049import org.apache.hadoop.hbase.HRegionInfo; -050import org.apache.yetus.audience.InterfaceAudience; -051import org.apache.yetus.audience.InterfaceStability; -052import org.apache.hadoop.hbase.client.Append; -053import org.apache.hadoop.hbase.client.Delete; -054import org.apache.hadoop.hbase.client.Durability; -055import org.apache.hadoop.hbase.client.Get; -056import org.apache.hadoop.hbase.client.Increment; -057import org.apache.hadoop.hbase.client.Mutation; -058import org.apache.hadoop.hbase.client.Put; -059import org.apache.hadoop.hbase.client.Result; -060import org.apache.hadoop.hbase.client.Scan; -061import org.apache.hadoop.hbase.client.TableDescriptor; -062import org.apache.hadoop.hbase.coprocessor.CoprocessorHost; -063import org.apache.hadoop.hbase.coprocessor.CoprocessorService; -064import org.apache.hadoop.hbase.coprocessor.EndpointObserver; -065import org.apache.hadoop.hbase.coprocessor.MetricsCoprocessor; -066import org.apache.hadoop.hbase.coprocessor.ObserverContext; -067import org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment; -068import org.apache.hadoop.hbase.coprocessor.RegionObserver; -069import org.apache.hadoop.hbase.coprocessor.RegionObserver.MutationType; -070import org.apache.hadoop.hbase.filter.ByteArrayComparable; -071import org.apache.hadoop.hbase.io.FSDataInputStreamWrapper; -072import org.apache.hadoop.hbase.io.Reference; -073import org.apache.hadoop.hbase.io.hfile.CacheConfig; -074import org.apache.hadoop.hbase.ipc.RpcServer; -075import org.apache.hadoop.hbase.metrics.MetricRegistry; -076import org.apache.hadoop.hbase.regionserver.Region.Operation; -077import org.apache.hadoop.hbase.regionserver.compactions.CompactionLifeCycleTracker; -078import org.apache.hadoop.hbase.regionserver.compactions.CompactionRequest; -079import org.apache.hadoop.hbase.regionserver.querymatcher.DeleteTracker; -080import org.apache.hadoop.hbase.security.User; -081import org.apache.hadoop.hbase.util.Bytes; -082import org.apache.hadoop.hbase.util.CoprocessorClassLoader; -083import org.apache.hadoop.hbase.util.Pair; -084import org.apache.hadoop.hbase.wal.WALEdit; -085import org.apache.hadoop.hbase.wal.WALKey; +022import java.io.IOException; +023import java.util.ArrayList; +024import java.util.List; +025import java.util.Map; +026import java.util.NavigableSet; +027import java.util.UUID; +028import java.util.concurrent.ConcurrentHashMap; +029import java.util.concurrent.ConcurrentMap; +030import java.util.regex.Matcher; +031 +032import com.google.protobuf.Message; +033import com.google.protobuf.Service; +034import org.apache.commons.collections4.map.AbstractReferenceMap; +035import org.apache.commons.collections4.map.ReferenceMap; +036import org.apache.commons.lang3.ClassUtils; +037import org.apache.commons.logging.Log; +038import org.apache.commons.logging.LogFactory; +039import org.apache.hadoop.conf.Configuration; +040import org.apache.hadoop.fs.FileSystem; +041import org.apache.hadoop.fs.Path; +042import org.apache.hadoop.hbase.Cell; +043import
[42/51] [partial] hbase-site git commit: Published site at .
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/fa7d6c0c/devapidocs/org/apache/hadoop/hbase/coprocessor/MasterObserver.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/coprocessor/MasterObserver.html b/devapidocs/org/apache/hadoop/hbase/coprocessor/MasterObserver.html index 97e3009..03c5fbd 100644 --- a/devapidocs/org/apache/hadoop/hbase/coprocessor/MasterObserver.html +++ b/devapidocs/org/apache/hadoop/hbase/coprocessor/MasterObserver.html @@ -216,8 +216,8 @@ extends default void -postAssign(ObserverContextMasterCoprocessorEnvironmentctx, - HRegionInforegionInfo) +postAssign(ObserverContextMasterCoprocessorEnvironmentctx, + RegionInforegionInfo) Called after the region assignment has been requested. @@ -268,9 +268,9 @@ extends default void -postCompletedCreateTableAction(ObserverContextMasterCoprocessorEnvironmentctx, +postCompletedCreateTableAction(ObserverContextMasterCoprocessorEnvironmentctx, TableDescriptordesc, - HRegionInfo[]regions) + RegionInfo[]regions) Called after the createTable operation has been requested. @@ -306,9 +306,9 @@ extends default void -postCompletedMergeRegionsAction(ObserverContextMasterCoprocessorEnvironmentctx, - HRegionInfo[]regionsToMerge, - HRegionInfomergedRegion) +postCompletedMergeRegionsAction(ObserverContextMasterCoprocessorEnvironmentctx, + RegionInfo[]regionsToMerge, + RegionInfomergedRegion) called after the regions merge. @@ -330,9 +330,9 @@ extends default void -postCompletedSplitRegionAction(ObserverContextMasterCoprocessorEnvironmentc, - HRegionInforegionInfoA, - HRegionInforegionInfoB) +postCompletedSplitRegionAction(ObserverContextMasterCoprocessorEnvironmentc, + RegionInforegionInfoA, + RegionInforegionInfoB) Called after the region is split. @@ -353,9 +353,9 @@ extends default void -postCreateTable(ObserverContextMasterCoprocessorEnvironmentctx, +postCreateTable(ObserverContextMasterCoprocessorEnvironmentctx, TableDescriptordesc, - HRegionInfo[]regions) + RegionInfo[]regions) Called after the createTable operation has been requested. @@ -498,16 +498,16 @@ extends default void -postMergeRegions(ObserverContextMasterCoprocessorEnvironmentc, -HRegionInfo[]regionsToMerge) +postMergeRegions(ObserverContextMasterCoprocessorEnvironmentc, +RegionInfo[]regionsToMerge) called after merge regions request. default void -postMergeRegionsCommitAction(ObserverContextMasterCoprocessorEnvironmentctx, -HRegionInfo[]regionsToMerge, -HRegionInfomergedRegion) +postMergeRegionsCommitAction(ObserverContextMasterCoprocessorEnvironmentctx, +RegionInfo[]regionsToMerge, +RegionInfomergedRegion) This will be called after PONR step as part of regions merge transaction. @@ -536,8 +536,8 @@ extends default void -postMove(ObserverContextMasterCoprocessorEnvironmentctx, -HRegionInforegion, +postMove(ObserverContextMasterCoprocessorEnvironmentctx, +RegionInforegion, ServerNamesrcServer, ServerNamedestServer) Called after the region move has been requested. @@ -570,8 +570,8 @@ extends default void -postRegionOffline(ObserverContextMasterCoprocessorEnvironmentctx, - HRegionInforegionInfo) +postRegionOffline(ObserverContextMasterCoprocessorEnvironmentctx, + RegionInforegionInfo) Called after the region has been marked offline. @@ -591,10 +591,10 @@ extends default void -postRequestLock(ObserverContextMasterCoprocessorEnvironmentctx, +postRequestLock(ObserverContextMasterCoprocessorEnvironmentctx, http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">Stringnamespace, TableNametableName, - HRegionInfo[]regionInfos, + RegionInfo[]regionInfos, LockTypetype, http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">Stringdescription) Called after new LockProcedure is queued. @@ -610,8 +610,8 @@ extends default void -postRollBackMergeRegionsAction(ObserverContextMasterCoprocessorEnvironmentctx, - HRegionInfo[]regionsToMerge) +postRollBackMergeRegionsAction(ObserverContextMasterCoprocessorEnvironmentctx, + RegionInfo[]regionsToMerge) This will be called after the roll
[46/51] [partial] hbase-site git commit: Published site at .
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/fa7d6c0c/devapidocs/org/apache/hadoop/hbase/class-use/HRegionInfo.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/class-use/HRegionInfo.html b/devapidocs/org/apache/hadoop/hbase/class-use/HRegionInfo.html index 4748823..78bca47 100644 --- a/devapidocs/org/apache/hadoop/hbase/class-use/HRegionInfo.html +++ b/devapidocs/org/apache/hadoop/hbase/class-use/HRegionInfo.html @@ -126,93 +126,85 @@ -org.apache.hadoop.hbase.coprocessor.example - - - org.apache.hadoop.hbase.favored - + org.apache.hadoop.hbase.io - + org.apache.hadoop.hbase.mapred Provides HBase http://wiki.apache.org/hadoop/HadoopMapReduce;>MapReduce Input/OutputFormats, a table indexing MapReduce job, and utility methods. - + org.apache.hadoop.hbase.mapreduce Provides HBase http://wiki.apache.org/hadoop/HadoopMapReduce;>MapReduce Input/OutputFormats, a table indexing MapReduce job, and utility methods. - -org.apache.hadoop.hbase.master - - -org.apache.hadoop.hbase.master.assignment +org.apache.hadoop.hbase.master -org.apache.hadoop.hbase.master.balancer +org.apache.hadoop.hbase.master.assignment -org.apache.hadoop.hbase.master.locking +org.apache.hadoop.hbase.master.balancer -org.apache.hadoop.hbase.master.normalizer +org.apache.hadoop.hbase.master.locking -org.apache.hadoop.hbase.master.procedure +org.apache.hadoop.hbase.master.normalizer -org.apache.hadoop.hbase.master.snapshot +org.apache.hadoop.hbase.master.procedure -org.apache.hadoop.hbase.mob +org.apache.hadoop.hbase.master.snapshot -org.apache.hadoop.hbase.namespace +org.apache.hadoop.hbase.mob -org.apache.hadoop.hbase.quotas +org.apache.hadoop.hbase.namespace -org.apache.hadoop.hbase.regionserver +org.apache.hadoop.hbase.quotas -org.apache.hadoop.hbase.regionserver.handler +org.apache.hadoop.hbase.regionserver -org.apache.hadoop.hbase.regionserver.wal +org.apache.hadoop.hbase.regionserver.handler -org.apache.hadoop.hbase.replication.regionserver +org.apache.hadoop.hbase.regionserver.wal -org.apache.hadoop.hbase.rsgroup +org.apache.hadoop.hbase.replication.regionserver -org.apache.hadoop.hbase.security.access +org.apache.hadoop.hbase.rsgroup @@ -1468,19 +1460,6 @@ Input/OutputFormats, a table indexing MapReduce job, and utility methods. Uses of HRegionInfo in org.apache.hadoop.hbase.coprocessor -Methods in org.apache.hadoop.hbase.coprocessor that return HRegionInfo - -Modifier and Type -Method and Description - - - -HRegionInfo -RegionCoprocessorEnvironment.getRegionInfo() - - - - Methods in org.apache.hadoop.hbase.coprocessor with parameters of type HRegionInfo Modifier and Type @@ -1500,256 +1479,6 @@ Input/OutputFormats, a table indexing MapReduce job, and utility methods. org.apache.hadoop.hbase.protobuf.generated.ExportProtos.ExportRequestrequest) -default void -MasterObserver.postAssign(ObserverContextMasterCoprocessorEnvironmentctx, - HRegionInforegionInfo) -Called after the region assignment has been requested. - - - -default void -MasterObserver.postCompletedCreateTableAction(ObserverContextMasterCoprocessorEnvironmentctx, - TableDescriptordesc, - HRegionInfo[]regions) -Called after the createTable operation has been requested. - - - -default void -MasterObserver.postCompletedMergeRegionsAction(ObserverContextMasterCoprocessorEnvironmentctx, - HRegionInfo[]regionsToMerge, - HRegionInfomergedRegion) -called after the regions merge. - - - -default void -MasterObserver.postCompletedMergeRegionsAction(ObserverContextMasterCoprocessorEnvironmentctx, - HRegionInfo[]regionsToMerge, - HRegionInfomergedRegion) -called after the regions merge. - - - -default void -MasterObserver.postCompletedSplitRegionAction(ObserverContextMasterCoprocessorEnvironmentc, - HRegionInforegionInfoA, - HRegionInforegionInfoB) -Called after the region is split. - - - -default void -MasterObserver.postCreateTable(ObserverContextMasterCoprocessorEnvironmentctx, - TableDescriptordesc, - HRegionInfo[]regions) -Called after the createTable operation has been requested. - - - -default void -MasterObserver.postMergeRegions(ObserverContextMasterCoprocessorEnvironmentc, -HRegionInfo[]regionsToMerge) -called after merge regions request. - - - -default void -MasterObserver.postMergeRegionsCommitAction(ObserverContextMasterCoprocessorEnvironmentctx, -HRegionInfo[]regionsToMerge, -HRegionInfomergedRegion) -This will be called after PONR step as part of regions merge transaction. - - - -default
[33/51] [partial] hbase-site git commit: Published site at .
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/fa7d6c0c/devapidocs/org/apache/hadoop/hbase/regionserver/RSRpcServices.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/regionserver/RSRpcServices.html b/devapidocs/org/apache/hadoop/hbase/regionserver/RSRpcServices.html index ef3ffad..a85d83e 100644 --- a/devapidocs/org/apache/hadoop/hbase/regionserver/RSRpcServices.html +++ b/devapidocs/org/apache/hadoop/hbase/regionserver/RSRpcServices.html @@ -1150,7 +1150,7 @@ implements DEFAULT_LOG_DELEGATE -private staticRSRpcServices.LogDelegate DEFAULT_LOG_DELEGATE +private staticRSRpcServices.LogDelegate DEFAULT_LOG_DELEGATE @@ -1159,7 +1159,7 @@ implements ld -private finalRSRpcServices.LogDelegate ld +private finalRSRpcServices.LogDelegate ld @@ -1169,7 +1169,7 @@ implements SCANNER_ALREADY_CLOSED http://docs.oracle.com/javase/8/docs/api/java/lang/Deprecated.html?is-external=true; title="class or interface in java.lang">@Deprecated -private static finalhttp://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true; title="class or interface in java.io">IOException SCANNER_ALREADY_CLOSED +private static finalhttp://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true; title="class or interface in java.io">IOException SCANNER_ALREADY_CLOSED Deprecated. @@ -1187,7 +1187,7 @@ private static finalhttp://docs.oracle.com/javase/8/docs/api/java RSRpcServices -publicRSRpcServices(HRegionServerrs) +publicRSRpcServices(HRegionServerrs) throws http://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true; title="class or interface in java.io">IOException Throws: @@ -1201,7 +1201,7 @@ private static finalhttp://docs.oracle.com/javase/8/docs/api/java RSRpcServices -RSRpcServices(HRegionServerrs, +RSRpcServices(HRegionServerrs, RSRpcServices.LogDelegateld) throws http://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true; title="class or interface in java.io">IOException @@ -1367,7 +1367,7 @@ private static finalhttp://docs.oracle.com/javase/8/docs/api/java row - family - qualifier - -op - +compareOp - comparator - @throws IOException Throws: http://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true; title="class or interface in java.io">IOException @@ -1380,7 +1380,7 @@ private static finalhttp://docs.oracle.com/javase/8/docs/api/java append -privateResultappend(Regionregion, +privateResultappend(Regionregion, OperationQuotaquota, org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.MutationProtomutation, CellScannercellScanner, @@ -1389,6 +1389,10 @@ private static finalhttp://docs.oracle.com/javase/8/docs/api/java throws http://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true; title="class or interface in java.io">IOException Execute an append mutation. +Parameters: +region - +m - +cellScanner - Returns: result to return to client if default operation should be bypassed as indicated by RegionObserver, null otherwise @@ -1403,7 +1407,7 @@ private static finalhttp://docs.oracle.com/javase/8/docs/api/java increment -privateResultincrement(Regionregion, +privateResultincrement(Regionregion, OperationQuotaquota, org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.MutationProtomutation, CellScannercells, @@ -1428,7 +1432,7 @@ private static finalhttp://docs.oracle.com/javase/8/docs/api/java doNonAtomicRegionMutation -privatehttp://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true; title="class or interface in java.util">ListCellScannabledoNonAtomicRegionMutation(Regionregion, +privatehttp://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true; title="class or interface in java.util">ListCellScannabledoNonAtomicRegionMutation(Regionregion, OperationQuotaquota, org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.RegionActionactions, CellScannercellScanner, @@ -1461,7 +1465,7 @@ private static finalhttp://docs.oracle.com/javase/8/docs/api/java checkCellSizeLimit -privatevoidcheckCellSizeLimit(Regionregion, +privatevoidcheckCellSizeLimit(Regionregion, Mutationm) throws http://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true; title="class or interface in java.io">IOException @@ -1476,7 +1480,7 @@ private static finalhttp://docs.oracle.com/javase/8/docs/api/java doBatchOp
[37/51] [partial] hbase-site git commit: Published site at .
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/fa7d6c0c/devapidocs/org/apache/hadoop/hbase/coprocessor/example/ExampleMasterObserverWithMetrics.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/coprocessor/example/ExampleMasterObserverWithMetrics.html b/devapidocs/org/apache/hadoop/hbase/coprocessor/example/ExampleMasterObserverWithMetrics.html index 0e36eb3..b05b907 100644 --- a/devapidocs/org/apache/hadoop/hbase/coprocessor/example/ExampleMasterObserverWithMetrics.html +++ b/devapidocs/org/apache/hadoop/hbase/coprocessor/example/ExampleMasterObserverWithMetrics.html @@ -234,17 +234,17 @@ implements void -postCreateTable(ObserverContextMasterCoprocessorEnvironmentctx, +postCreateTable(ObserverContextMasterCoprocessorEnvironmentctx, TableDescriptordesc, - HRegionInfo[]regions) + RegionInfo[]regions) Called after the createTable operation has been requested. void -preCreateTable(ObserverContextMasterCoprocessorEnvironmentctx, +preCreateTable(ObserverContextMasterCoprocessorEnvironmentctx, TableDescriptordesc, - HRegionInfo[]regions) + RegionInfo[]regions) Called before a new table is created by HMaster. @@ -273,7 +273,7 @@ implements MasterObserver -postAbortProcedure, postAddColumnFamily, postAddReplicationPeer, postAddRSGroup, postAssign, postBalance, postBalanceRSGroup, postBalanceSwitch, postClearDeadServers, postCloneSnapshot, postCompletedAddColumnFamilyAction, postCompletedCreateTableAction, post CompletedDeleteColumnFamilyAction, postCompletedDeleteTableAction, postCompletedDisableTableAction, postCompletedEnableTableAction, postCompletedMergeRegionsAction, href="../../../../../../org/apache/hadoop/hbase/coprocessor/MasterObserver.html#postCompletedModifyColumnFamilyAction-org.apache.hadoop.hbase.coprocessor.ObserverContext-org.apache.hadoop.hbase.TableName-org.apache.hadoop.hbase.client.ColumnFamilyDescriptor-">postCompletedModifyColumnFamilyAction, > href="../../../../../../org/apache/hadoop/hbase/coprocessor/MasterObserver.html#postCompletedModifyTableAction-org.apache.hadoop.hbase.coprocessor.ObserverContext-org.apache.hadoop.hbase.TableName-org.apache.hadoop.hbase.client.TableDescriptor-">postCompletedModifyTableAction, > href="../../../../../../org/apache/hadoop/hbase/coprocessor/MasterObserver.html#postCompletedSplitRegionAction-org.apache.hadoop.hbase.coprocessor.ObserverContext-org.apache.hadoop.hbase.HRegionInfo-org.apache.hadoop.hbase.HRegionInfo-">postCompletedSplitRegionAction, > href="../../../../../../org/apache/hadoop/hbase/coprocessor/MasterObserver.html#postCompl etedTruncateTableAction-org.apache.hadoop.hbase.coprocessor.ObserverContext-org.apache.hadoop.hbase.TableName-">postCompletedTruncateTableAction, postCreateNamespace, postDeleteColumnFamily, postDeleteNamespace, postDeleteSnapshot, postDeleteTable, postDisableReplicationPeer, postDisableTable, postEnableReplicationPeer, postEnableTable, postGetLocks, postGetNamespaceDescriptor, postGetProcedures, postGetReplicationPeerConfig, postGetTableDescriptors, postGetTableNames, postListDeadServers, postListNamespaceDescriptors, postListRepli cationPeers, postListSnapshot, postLockHeartbeat, postMergeRegions, postMergeRegionsCommitActi on, postModifyColumnFamily, postModifyNamespace, postModifyTable, postMove, postMoveServers, postMoveServersAndTables, postMoveTables, postRegionOffline, postRemoveReplicationPeer, postRemoveRSGroup, postRequestLock, postRestoreSnapshot, postRollBackMergeRegionsAction, postRollBackSplitRegionAction, postSetNamespaceQuota, postSetSplitOrMergeEnabled, postSetTableQuota, postSetUserQuota, postSetUserQuota, postSetUserQuota, postSnapshot, postStartMaster, postTableFlush, postTruncateTable, postUnassign, postUpdateReplicationPeerConfig, preAbortProcedure, preAddColumnFamily, preAddColumnFamilyAction, preAddReplicationPeer, preAddRSGroup, preAssign, preBalance, preBalanceRSGroup, preBalanceSwitch, preClearDeadServers, preCloneSnapshot, preCreateNamespace, preCreateTableAction, preDeleteColumnFamily, preDeleteColumnFamilyAction, preDeleteNamespace, preDeleteSnapshot, preDeleteTable, preDeleteTableAction, preDisableReplicationPeer, preDisableTableAction, preEnableReplicationPeer, preEnableTable, preEnableTableAction, preGetLocks, preGetNamespaceDescriptor, preGetProcedures, preGetReplicationPeerConfig, preGetTableDescriptors, preGetTableNames, preListDeadServers, preListNamespaceDescriptors, preListReplicationPeers, preListSnapshot, preLockHeartbeat, preMasterInitialization, preMergeRegions, preMergeRegionsAction, preMergeRegionsCommitAction, preModifyColumnFamily, preModifyColumnFamilyAction, preModifyNamespace, preModifyTable, preModifyTableAction, preMove, preMoveServers, preMoveServersA ndTables, preMoveTables,
[19/51] [partial] hbase-site git commit: Published site at .
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/fa7d6c0c/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RSRpcServices.LogDelegate.html -- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RSRpcServices.LogDelegate.html b/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RSRpcServices.LogDelegate.html index e0b1774..f3d4c5e 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RSRpcServices.LogDelegate.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RSRpcServices.LogDelegate.html @@ -605,13 +605,13 @@ 597 * @param row 598 * @param family 599 * @param qualifier -600 * @param op +600 * @param compareOp 601 * @param comparator @throws IOException 602 */ 603 private boolean checkAndRowMutate(final Region region, final ListClientProtos.Action actions, -604 final CellScanner cellScanner, byte[] row, byte[] family, byte[] qualifier, -605 CompareOperator op, ByteArrayComparable comparator, RegionActionResult.Builder builder, -606 ActivePolicyEnforcement spaceQuotaEnforcement) throws IOException { +604final CellScanner cellScanner, byte[] row, byte[] family, byte[] qualifier, +605 CompareOperator op, ByteArrayComparable comparator, RegionActionResult.Builder builder, +606 ActivePolicyEnforcement spaceQuotaEnforcement) throws IOException { 607if (!region.getRegionInfo().isMetaTable()) { 608 regionServer.cacheFlusher.reclaimMemStoreMemory(); 609} @@ -656,2842 +656,2846 @@ 648 649 /** 650 * Execute an append mutation. -651 * @return result to return to client if default operation should be -652 * bypassed as indicated by RegionObserver, null otherwise -653 * @throws IOException -654 */ -655 private Result append(final Region region, final OperationQuota quota, -656 final MutationProto mutation, final CellScanner cellScanner, long nonceGroup, -657 ActivePolicyEnforcement spaceQuota) -658 throws IOException { -659long before = EnvironmentEdgeManager.currentTime(); -660Append append = ProtobufUtil.toAppend(mutation, cellScanner); -661checkCellSizeLimit(region, append); -662 spaceQuota.getPolicyEnforcement(region).check(append); -663quota.addMutation(append); -664Result r = null; -665if (region.getCoprocessorHost() != null) { -666 r = region.getCoprocessorHost().preAppend(append); -667} -668if (r == null) { -669 boolean canProceed = startNonceOperation(mutation, nonceGroup); -670 boolean success = false; -671 try { -672long nonce = mutation.hasNonce() ? mutation.getNonce() : HConstants.NO_NONCE; -673if (canProceed) { -674 r = region.append(append, nonceGroup, nonce); -675} else { -676 // convert duplicate append to get -677 ListCell results = region.get(ProtobufUtil.toGet(mutation, cellScanner), false, -678nonceGroup, nonce); -679 r = Result.create(results); -680} -681success = true; -682 } finally { -683if (canProceed) { -684 endNonceOperation(mutation, nonceGroup, success); -685} -686 } -687 if (region.getCoprocessorHost() != null) { -688r = region.getCoprocessorHost().postAppend(append, r); -689 } -690} -691if (regionServer.metricsRegionServer != null) { -692 regionServer.metricsRegionServer.updateAppend( -693 EnvironmentEdgeManager.currentTime() - before); +651 * +652 * @param region +653 * @param m +654 * @param cellScanner +655 * @return result to return to client if default operation should be +656 * bypassed as indicated by RegionObserver, null otherwise +657 * @throws IOException +658 */ +659 private Result append(final Region region, final OperationQuota quota, +660 final MutationProto mutation, final CellScanner cellScanner, long nonceGroup, +661 ActivePolicyEnforcement spaceQuota) +662 throws IOException { +663long before = EnvironmentEdgeManager.currentTime(); +664Append append = ProtobufUtil.toAppend(mutation, cellScanner); +665checkCellSizeLimit(region, append); +666 spaceQuota.getPolicyEnforcement(region).check(append); +667quota.addMutation(append); +668Result r = null; +669if (region.getCoprocessorHost() != null) { +670 r = region.getCoprocessorHost().preAppend(append); +671} +672if (r == null) { +673 boolean canProceed = startNonceOperation(mutation, nonceGroup); +674 boolean success = false; +675 try { +676long nonce = mutation.hasNonce() ? mutation.getNonce() : HConstants.NO_NONCE; +677if (canProceed) { +678 r = region.append(append, nonceGroup, nonce); +679} else { +680 // convert
[44/51] [partial] hbase-site git commit: Published site at .
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/fa7d6c0c/devapidocs/org/apache/hadoop/hbase/client/class-use/RegionInfo.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/client/class-use/RegionInfo.html b/devapidocs/org/apache/hadoop/hbase/client/class-use/RegionInfo.html index a736446..cea3764 100644 --- a/devapidocs/org/apache/hadoop/hbase/client/class-use/RegionInfo.html +++ b/devapidocs/org/apache/hadoop/hbase/client/class-use/RegionInfo.html @@ -93,6 +93,32 @@ +org.apache.hadoop.hbase.coprocessor + +Table of Contents + + + +org.apache.hadoop.hbase.coprocessor.example + + + +org.apache.hadoop.hbase.master + + + +org.apache.hadoop.hbase.regionserver + + + +org.apache.hadoop.hbase.rsgroup + + + +org.apache.hadoop.hbase.security.access + + + org.apache.hadoop.hbase.util @@ -379,6 +405,615 @@ + + + +Uses of RegionInfo in org.apache.hadoop.hbase.coprocessor + +Methods in org.apache.hadoop.hbase.coprocessor that return RegionInfo + +Modifier and Type +Method and Description + + + +RegionInfo +RegionCoprocessorEnvironment.getRegionInfo() + + + + +Methods in org.apache.hadoop.hbase.coprocessor with parameters of type RegionInfo + +Modifier and Type +Method and Description + + + +default void +MasterObserver.postAssign(ObserverContextMasterCoprocessorEnvironmentctx, + RegionInforegionInfo) +Called after the region assignment has been requested. + + + +default void +MasterObserver.postCompletedCreateTableAction(ObserverContextMasterCoprocessorEnvironmentctx, + TableDescriptordesc, + RegionInfo[]regions) +Called after the createTable operation has been requested. + + + +default void +MasterObserver.postCompletedMergeRegionsAction(ObserverContextMasterCoprocessorEnvironmentctx, + RegionInfo[]regionsToMerge, + RegionInfomergedRegion) +called after the regions merge. + + + +default void +MasterObserver.postCompletedMergeRegionsAction(ObserverContextMasterCoprocessorEnvironmentctx, + RegionInfo[]regionsToMerge, + RegionInfomergedRegion) +called after the regions merge. + + + +default void +MasterObserver.postCompletedSplitRegionAction(ObserverContextMasterCoprocessorEnvironmentc, + RegionInforegionInfoA, + RegionInforegionInfoB) +Called after the region is split. + + + +default void +MasterObserver.postCreateTable(ObserverContextMasterCoprocessorEnvironmentctx, + TableDescriptordesc, + RegionInfo[]regions) +Called after the createTable operation has been requested. + + + +default void +MasterObserver.postMergeRegions(ObserverContextMasterCoprocessorEnvironmentc, +RegionInfo[]regionsToMerge) +called after merge regions request. + + + +default void +MasterObserver.postMergeRegionsCommitAction(ObserverContextMasterCoprocessorEnvironmentctx, +RegionInfo[]regionsToMerge, +RegionInfomergedRegion) +This will be called after PONR step as part of regions merge transaction. + + + +default void +MasterObserver.postMergeRegionsCommitAction(ObserverContextMasterCoprocessorEnvironmentctx, +RegionInfo[]regionsToMerge, +RegionInfomergedRegion) +This will be called after PONR step as part of regions merge transaction. + + + +default void +MasterObserver.postMove(ObserverContextMasterCoprocessorEnvironmentctx, +RegionInforegion, +ServerNamesrcServer, +ServerNamedestServer) +Called after the region move has been requested. + + + +default void +MasterObserver.postRegionOffline(ObserverContextMasterCoprocessorEnvironmentctx, + RegionInforegionInfo) +Called after the region has been marked offline. + + + +default void +RegionObserver.postReplayWALs(ObserverContext? extends RegionCoprocessorEnvironmentctx, + RegionInfoinfo, + org.apache.hadoop.fs.Pathedits) +Called after replaying WALs for this region. + + + +default void +MasterObserver.postRequestLock(ObserverContextMasterCoprocessorEnvironmentctx, + http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">Stringnamespace, + TableNametableName, + RegionInfo[]regionInfos, + LockTypetype, + http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">Stringdescription) +Called after new LockProcedure is queued. + + + +default void +MasterObserver.postRollBackMergeRegionsAction(ObserverContextMasterCoprocessorEnvironmentctx, + RegionInfo[]regionsToMerge) +This will be called after the roll back of the
[45/51] [partial] hbase-site git commit: Published site at .
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/fa7d6c0c/devapidocs/org/apache/hadoop/hbase/class-use/MetaMutationAnnotation.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/class-use/MetaMutationAnnotation.html b/devapidocs/org/apache/hadoop/hbase/class-use/MetaMutationAnnotation.html index b171e46..56d62c5 100644 --- a/devapidocs/org/apache/hadoop/hbase/class-use/MetaMutationAnnotation.html +++ b/devapidocs/org/apache/hadoop/hbase/class-use/MetaMutationAnnotation.html @@ -110,8 +110,8 @@ default void -MasterObserver.preMergeRegionsCommitAction(ObserverContextMasterCoprocessorEnvironmentctx, - HRegionInfo[]regionsToMerge, +MasterObserver.preMergeRegionsCommitAction(ObserverContextMasterCoprocessorEnvironmentctx, + RegionInfo[]regionsToMerge, http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true; title="class or interface in java.util">ListMutationmetaEntries) This will be called before PONR step as part of regions merge transaction. @@ -132,7 +132,7 @@ boolean -MasterCoprocessorHost.preMergeRegionsCommit(HRegionInfo[]regionsToMerge, +MasterCoprocessorHost.preMergeRegionsCommit(RegionInfo[]regionsToMerge, http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true; title="class or interface in java.util">ListMutationmetaEntries, Useruser) Invoked before merge regions operation writes the new region to hbase:meta http://git-wip-us.apache.org/repos/asf/hbase-site/blob/fa7d6c0c/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 abaf35b..22f5ad9 100644 --- a/devapidocs/org/apache/hadoop/hbase/class-use/ServerName.html +++ b/devapidocs/org/apache/hadoop/hbase/class-use/ServerName.html @@ -2063,8 +2063,8 @@ Input/OutputFormats, a table indexing MapReduce job, and utility methods. default void -MasterObserver.postMove(ObserverContextMasterCoprocessorEnvironmentctx, -HRegionInforegion, +MasterObserver.postMove(ObserverContextMasterCoprocessorEnvironmentctx, +RegionInforegion, ServerNamesrcServer, ServerNamedestServer) Called after the region move has been requested. @@ -2072,8 +2072,8 @@ Input/OutputFormats, a table indexing MapReduce job, and utility methods. default void -MasterObserver.preMove(ObserverContextMasterCoprocessorEnvironmentctx, - HRegionInforegion, +MasterObserver.preMove(ObserverContextMasterCoprocessorEnvironmentctx, + RegionInforegion, ServerNamesrcServer, ServerNamedestServer) Called prior to moving a given region from one region server to another. @@ -3310,13 +3310,13 @@ Input/OutputFormats, a table indexing MapReduce job, and utility methods. void -MasterCoprocessorHost.postMove(HRegionInforegion, +MasterCoprocessorHost.postMove(RegionInforegion, ServerNamesrcServer, ServerNamedestServer) boolean -MasterCoprocessorHost.preMove(HRegionInforegion, +MasterCoprocessorHost.preMove(RegionInforegion, ServerNamesrcServer, ServerNamedestServer) @@ -5363,8 +5363,8 @@ Input/OutputFormats, a table indexing MapReduce job, and utility methods. void -AccessController.preMove(ObserverContextMasterCoprocessorEnvironmentc, - HRegionInforegion, +AccessController.preMove(ObserverContextMasterCoprocessorEnvironmentc, + RegionInforegion, ServerNamesrcServer, ServerNamedestServer) http://git-wip-us.apache.org/repos/asf/hbase-site/blob/fa7d6c0c/devapidocs/org/apache/hadoop/hbase/class-use/TableName.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/class-use/TableName.html b/devapidocs/org/apache/hadoop/hbase/class-use/TableName.html index 01d2141..9857de6 100644 --- a/devapidocs/org/apache/hadoop/hbase/class-use/TableName.html +++ b/devapidocs/org/apache/hadoop/hbase/class-use/TableName.html @@ -5336,10 +5336,10 @@ service. default void -MasterObserver.postRequestLock(ObserverContextMasterCoprocessorEnvironmentctx, +MasterObserver.postRequestLock(ObserverContextMasterCoprocessorEnvironmentctx, http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">Stringnamespace, TableNametableName, - HRegionInfo[]regionInfos, + RegionInfo[]regionInfos, LockTypetype, http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">Stringdescription) Called after new LockProcedure is queued. @@
[41/51] [partial] hbase-site git commit: Published site at .
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/fa7d6c0c/devapidocs/org/apache/hadoop/hbase/coprocessor/RegionCoprocessorEnvironment.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/coprocessor/RegionCoprocessorEnvironment.html b/devapidocs/org/apache/hadoop/hbase/coprocessor/RegionCoprocessorEnvironment.html index c3e262d..13ba3e1 100644 --- a/devapidocs/org/apache/hadoop/hbase/coprocessor/RegionCoprocessorEnvironment.html +++ b/devapidocs/org/apache/hadoop/hbase/coprocessor/RegionCoprocessorEnvironment.html @@ -142,7 +142,7 @@ extends getRegion() -HRegionInfo +RegionInfo getRegionInfo() @@ -194,7 +194,7 @@ extends getRegionInfo -HRegionInfogetRegionInfo() +RegionInfogetRegionInfo() Returns: region information for the region this coprocessor is running on http://git-wip-us.apache.org/repos/asf/hbase-site/blob/fa7d6c0c/devapidocs/org/apache/hadoop/hbase/coprocessor/RegionObserver.MutationType.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/coprocessor/RegionObserver.MutationType.html b/devapidocs/org/apache/hadoop/hbase/coprocessor/RegionObserver.MutationType.html index 5b16f67..3666fc1 100644 --- a/devapidocs/org/apache/hadoop/hbase/coprocessor/RegionObserver.MutationType.html +++ b/devapidocs/org/apache/hadoop/hbase/coprocessor/RegionObserver.MutationType.html @@ -237,7 +237,7 @@ the order they are declared. values -public staticRegionObserver.MutationType[]values() +public staticRegionObserver.MutationType[]values() Returns an array containing the constants of this enum type, in the order they are declared. This method may be used to iterate over the constants as follows: @@ -257,7 +257,7 @@ for (RegionObserver.MutationType c : RegionObserver.MutationType.values()) valueOf -public staticRegionObserver.MutationTypevalueOf(http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">Stringname) +public staticRegionObserver.MutationTypevalueOf(http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">Stringname) Returns the enum constant of this type with the specified name. The string must match exactly an identifier used to declare an enum constant in this type. (Extraneous whitespace characters are http://git-wip-us.apache.org/repos/asf/hbase-site/blob/fa7d6c0c/devapidocs/org/apache/hadoop/hbase/coprocessor/RegionObserver.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/coprocessor/RegionObserver.html b/devapidocs/org/apache/hadoop/hbase/coprocessor/RegionObserver.html index 4e7e056..3de7a02 100644 --- a/devapidocs/org/apache/hadoop/hbase/coprocessor/RegionObserver.html +++ b/devapidocs/org/apache/hadoop/hbase/coprocessor/RegionObserver.html @@ -391,8 +391,8 @@ extends default void -postReplayWALs(ObserverContext? extends RegionCoprocessorEnvironmentctx, - HRegionInfoinfo, +postReplayWALs(ObserverContext? extends RegionCoprocessorEnvironmentctx, + RegionInfoinfo, org.apache.hadoop.fs.Pathedits) Called after replaying WALs for this region. @@ -457,8 +457,8 @@ extends default void -postWALRestore(ObserverContext? extends RegionCoprocessorEnvironmentctx, - HRegionInfoinfo, +postWALRestore(ObserverContext? extends RegionCoprocessorEnvironmentctx, + RegionInfoinfo, WALKeylogKey, WALEditlogEdit) Called after a WALEdit @@ -686,8 +686,8 @@ extends default void -preReplayWALs(ObserverContext? extends RegionCoprocessorEnvironmentctx, - HRegionInfoinfo, +preReplayWALs(ObserverContext? extends RegionCoprocessorEnvironmentctx, + RegionInfoinfo, org.apache.hadoop.fs.Pathedits) Called before replaying WALs for this region. @@ -745,8 +745,8 @@ extends default void -preWALRestore(ObserverContext? extends RegionCoprocessorEnvironmentctx, - HRegionInfoinfo, +preWALRestore(ObserverContext? extends RegionCoprocessorEnvironmentctx, + RegionInfoinfo, WALKeylogKey, WALEditlogEdit) Called before a WALEdit @@ -2182,14 +2182,14 @@ extends - + preReplayWALs defaultvoidpreReplayWALs(ObserverContext? extends RegionCoprocessorEnvironmentctx, - HRegionInfoinfo, + RegionInfoinfo, org.apache.hadoop.fs.Pathedits) throws http://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true; title="class or interface in java.io">IOException Called before replaying WALs for this region. @@ -2205,14 +2205,14 @@ extends - + postReplayWALs defaultvoidpostReplayWALs(ObserverContext?
[48/51] [partial] hbase-site git commit: Published site at .
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/fa7d6c0c/devapidocs/index-all.html -- diff --git a/devapidocs/index-all.html b/devapidocs/index-all.html index 654ca2b..636eab4 100644 --- a/devapidocs/index-all.html +++ b/devapidocs/index-all.html @@ -10511,7 +10511,7 @@ checkLimitOfRows(int, int, boolean, ScannerContext, ClientProtos.ScanResponse.Builder) - Method in class org.apache.hadoop.hbase.regionserver.RSRpcServices -checkLockPermissions(User, String, TableName, HRegionInfo[], String) - Method in class org.apache.hadoop.hbase.security.access.AccessController +checkLockPermissions(User, String, TableName, RegionInfo[], String) - Method in class org.apache.hadoop.hbase.security.access.AccessController checkLogRoll() - Method in class org.apache.hadoop.hbase.regionserver.wal.FSHLog @@ -78533,11 +78533,11 @@ service. postApply(QuotaProtos.Quotas) - Method in interface org.apache.hadoop.hbase.quotas.MasterQuotaManager.SetQuotaOperations -postAssign(ObserverContextMasterCoprocessorEnvironment, HRegionInfo) - Method in interface org.apache.hadoop.hbase.coprocessor.MasterObserver +postAssign(ObserverContextMasterCoprocessorEnvironment, RegionInfo) - Method in interface org.apache.hadoop.hbase.coprocessor.MasterObserver Called after the region assignment has been requested. -postAssign(HRegionInfo) - Method in class org.apache.hadoop.hbase.master.MasterCoprocessorHost +postAssign(RegionInfo) - Method in class org.apache.hadoop.hbase.master.MasterCoprocessorHost postBalance(ObserverContextMasterCoprocessorEnvironment, ListRegionPlan) - Method in interface org.apache.hadoop.hbase.coprocessor.MasterObserver @@ -78666,13 +78666,13 @@ service. postCompletedAddColumnFamilyAction(TableName, ColumnFamilyDescriptor, User) - Method in class org.apache.hadoop.hbase.master.MasterCoprocessorHost -postCompletedCreateTableAction(ObserverContextMasterCoprocessorEnvironment, TableDescriptor, HRegionInfo[]) - Method in interface org.apache.hadoop.hbase.coprocessor.MasterObserver +postCompletedCreateTableAction(ObserverContextMasterCoprocessorEnvironment, TableDescriptor, RegionInfo[]) - Method in interface org.apache.hadoop.hbase.coprocessor.MasterObserver Called after the createTable operation has been requested. -postCompletedCreateTableAction(TableDescriptor, HRegionInfo[], User) - Method in class org.apache.hadoop.hbase.master.MasterCoprocessorHost +postCompletedCreateTableAction(TableDescriptor, RegionInfo[], User) - Method in class org.apache.hadoop.hbase.master.MasterCoprocessorHost -postCompletedCreateTableAction(ObserverContextMasterCoprocessorEnvironment, TableDescriptor, HRegionInfo[]) - Method in class org.apache.hadoop.hbase.security.access.AccessController +postCompletedCreateTableAction(ObserverContextMasterCoprocessorEnvironment, TableDescriptor, RegionInfo[]) - Method in class org.apache.hadoop.hbase.security.access.AccessController postCompletedDeleteColumnFamilyAction(ObserverContextMasterCoprocessorEnvironment, TableName, byte[]) - Method in interface org.apache.hadoop.hbase.coprocessor.MasterObserver @@ -78703,11 +78703,11 @@ service. Post merge region action -postCompletedMergeRegionsAction(ObserverContextMasterCoprocessorEnvironment, HRegionInfo[], HRegionInfo) - Method in interface org.apache.hadoop.hbase.coprocessor.MasterObserver +postCompletedMergeRegionsAction(ObserverContextMasterCoprocessorEnvironment, RegionInfo[], RegionInfo) - Method in interface org.apache.hadoop.hbase.coprocessor.MasterObserver called after the regions merge. -postCompletedMergeRegionsAction(HRegionInfo[], HRegionInfo, User) - Method in class org.apache.hadoop.hbase.master.MasterCoprocessorHost +postCompletedMergeRegionsAction(RegionInfo[], RegionInfo, User) - Method in class org.apache.hadoop.hbase.master.MasterCoprocessorHost Invoked after completing merge regions operation @@ -78723,11 +78723,11 @@ service. postCompletedModifyTableAction(TableName, TableDescriptor, User) - Method in class org.apache.hadoop.hbase.master.MasterCoprocessorHost -postCompletedSplitRegionAction(ObserverContextMasterCoprocessorEnvironment, HRegionInfo, HRegionInfo) - Method in interface org.apache.hadoop.hbase.coprocessor.MasterObserver +postCompletedSplitRegionAction(ObserverContextMasterCoprocessorEnvironment, RegionInfo, RegionInfo) - Method in interface org.apache.hadoop.hbase.coprocessor.MasterObserver Called after the region is split. -postCompletedSplitRegionAction(HRegionInfo, HRegionInfo, User) - Method in class org.apache.hadoop.hbase.master.MasterCoprocessorHost +postCompletedSplitRegionAction(RegionInfo, RegionInfo, User) - Method in class org.apache.hadoop.hbase.master.MasterCoprocessorHost Invoked just after a split @@ -78760,13 +78760,13 @@ service. postCreateReplicationEndPoint(ObserverContextRegionServerCoprocessorEnvironment,
[40/51] [partial] hbase-site git commit: Published site at .
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/fa7d6c0c/devapidocs/org/apache/hadoop/hbase/coprocessor/class-use/MasterCoprocessorEnvironment.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/coprocessor/class-use/MasterCoprocessorEnvironment.html b/devapidocs/org/apache/hadoop/hbase/coprocessor/class-use/MasterCoprocessorEnvironment.html index 5df8bf9..12ff615 100644 --- a/devapidocs/org/apache/hadoop/hbase/coprocessor/class-use/MasterCoprocessorEnvironment.html +++ b/devapidocs/org/apache/hadoop/hbase/coprocessor/class-use/MasterCoprocessorEnvironment.html @@ -159,8 +159,8 @@ default void -MasterObserver.postAssign(ObserverContextMasterCoprocessorEnvironmentctx, - HRegionInforegionInfo) +MasterObserver.postAssign(ObserverContextMasterCoprocessorEnvironmentctx, + RegionInforegionInfo) Called after the region assignment has been requested. @@ -211,9 +211,9 @@ default void -MasterObserver.postCompletedCreateTableAction(ObserverContextMasterCoprocessorEnvironmentctx, +MasterObserver.postCompletedCreateTableAction(ObserverContextMasterCoprocessorEnvironmentctx, TableDescriptordesc, - HRegionInfo[]regions) + RegionInfo[]regions) Called after the createTable operation has been requested. @@ -249,9 +249,9 @@ default void -MasterObserver.postCompletedMergeRegionsAction(ObserverContextMasterCoprocessorEnvironmentctx, - HRegionInfo[]regionsToMerge, - HRegionInfomergedRegion) +MasterObserver.postCompletedMergeRegionsAction(ObserverContextMasterCoprocessorEnvironmentctx, + RegionInfo[]regionsToMerge, + RegionInfomergedRegion) called after the regions merge. @@ -273,9 +273,9 @@ default void -MasterObserver.postCompletedSplitRegionAction(ObserverContextMasterCoprocessorEnvironmentc, - HRegionInforegionInfoA, - HRegionInforegionInfoB) +MasterObserver.postCompletedSplitRegionAction(ObserverContextMasterCoprocessorEnvironmentc, + RegionInforegionInfoA, + RegionInforegionInfoB) Called after the region is split. @@ -296,9 +296,9 @@ default void -MasterObserver.postCreateTable(ObserverContextMasterCoprocessorEnvironmentctx, +MasterObserver.postCreateTable(ObserverContextMasterCoprocessorEnvironmentctx, TableDescriptordesc, - HRegionInfo[]regions) + RegionInfo[]regions) Called after the createTable operation has been requested. @@ -441,16 +441,16 @@ default void -MasterObserver.postMergeRegions(ObserverContextMasterCoprocessorEnvironmentc, -HRegionInfo[]regionsToMerge) +MasterObserver.postMergeRegions(ObserverContextMasterCoprocessorEnvironmentc, +RegionInfo[]regionsToMerge) called after merge regions request. default void -MasterObserver.postMergeRegionsCommitAction(ObserverContextMasterCoprocessorEnvironmentctx, -HRegionInfo[]regionsToMerge, -HRegionInfomergedRegion) +MasterObserver.postMergeRegionsCommitAction(ObserverContextMasterCoprocessorEnvironmentctx, +RegionInfo[]regionsToMerge, +RegionInfomergedRegion) This will be called after PONR step as part of regions merge transaction. @@ -479,8 +479,8 @@ default void -MasterObserver.postMove(ObserverContextMasterCoprocessorEnvironmentctx, -HRegionInforegion, +MasterObserver.postMove(ObserverContextMasterCoprocessorEnvironmentctx, +RegionInforegion, ServerNamesrcServer, ServerNamedestServer) Called after the region move has been requested. @@ -513,8 +513,8 @@ default void -MasterObserver.postRegionOffline(ObserverContextMasterCoprocessorEnvironmentctx, - HRegionInforegionInfo) +MasterObserver.postRegionOffline(ObserverContextMasterCoprocessorEnvironmentctx, + RegionInforegionInfo) Called after the region has been marked offline. @@ -534,10 +534,10 @@ default void -MasterObserver.postRequestLock(ObserverContextMasterCoprocessorEnvironmentctx, +MasterObserver.postRequestLock(ObserverContextMasterCoprocessorEnvironmentctx, http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">Stringnamespace, TableNametableName, - HRegionInfo[]regionInfos, + RegionInfo[]regionInfos, LockTypetype, http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">Stringdescription) Called after new LockProcedure is queued.
[10/51] [partial] hbase-site git commit: Published site at .
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/fa7d6c0c/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RegionCoprocessorHost.EndpointOperationWithResult.html -- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RegionCoprocessorHost.EndpointOperationWithResult.html b/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RegionCoprocessorHost.EndpointOperationWithResult.html index cf3f141..a4d46aa 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RegionCoprocessorHost.EndpointOperationWithResult.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RegionCoprocessorHost.EndpointOperationWithResult.html @@ -27,1612 +27,1609 @@ 019 020package org.apache.hadoop.hbase.regionserver; 021 -022import com.google.protobuf.Message; -023import com.google.protobuf.Service; -024 -025import java.io.IOException; -026import java.util.ArrayList; -027import java.util.List; -028import java.util.Map; -029import java.util.NavigableSet; -030import java.util.UUID; -031import java.util.concurrent.ConcurrentHashMap; -032import java.util.concurrent.ConcurrentMap; -033import java.util.regex.Matcher; -034 -035import org.apache.commons.collections4.map.AbstractReferenceMap; -036import org.apache.commons.collections4.map.ReferenceMap; -037import org.apache.commons.lang3.ClassUtils; -038import org.apache.commons.logging.Log; -039import org.apache.commons.logging.LogFactory; -040import org.apache.hadoop.conf.Configuration; -041import org.apache.hadoop.fs.FileSystem; -042import org.apache.hadoop.fs.Path; -043import org.apache.hadoop.hbase.Cell; -044import org.apache.hadoop.hbase.CompareOperator; -045import org.apache.hadoop.hbase.Coprocessor; -046import org.apache.hadoop.hbase.HBaseConfiguration; -047import org.apache.hadoop.hbase.HBaseInterfaceAudience; -048import org.apache.hadoop.hbase.HConstants; -049import org.apache.hadoop.hbase.HRegionInfo; -050import org.apache.yetus.audience.InterfaceAudience; -051import org.apache.yetus.audience.InterfaceStability; -052import org.apache.hadoop.hbase.client.Append; -053import org.apache.hadoop.hbase.client.Delete; -054import org.apache.hadoop.hbase.client.Durability; -055import org.apache.hadoop.hbase.client.Get; -056import org.apache.hadoop.hbase.client.Increment; -057import org.apache.hadoop.hbase.client.Mutation; -058import org.apache.hadoop.hbase.client.Put; -059import org.apache.hadoop.hbase.client.Result; -060import org.apache.hadoop.hbase.client.Scan; -061import org.apache.hadoop.hbase.client.TableDescriptor; -062import org.apache.hadoop.hbase.coprocessor.CoprocessorHost; -063import org.apache.hadoop.hbase.coprocessor.CoprocessorService; -064import org.apache.hadoop.hbase.coprocessor.EndpointObserver; -065import org.apache.hadoop.hbase.coprocessor.MetricsCoprocessor; -066import org.apache.hadoop.hbase.coprocessor.ObserverContext; -067import org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment; -068import org.apache.hadoop.hbase.coprocessor.RegionObserver; -069import org.apache.hadoop.hbase.coprocessor.RegionObserver.MutationType; -070import org.apache.hadoop.hbase.filter.ByteArrayComparable; -071import org.apache.hadoop.hbase.io.FSDataInputStreamWrapper; -072import org.apache.hadoop.hbase.io.Reference; -073import org.apache.hadoop.hbase.io.hfile.CacheConfig; -074import org.apache.hadoop.hbase.ipc.RpcServer; -075import org.apache.hadoop.hbase.metrics.MetricRegistry; -076import org.apache.hadoop.hbase.regionserver.Region.Operation; -077import org.apache.hadoop.hbase.regionserver.compactions.CompactionLifeCycleTracker; -078import org.apache.hadoop.hbase.regionserver.compactions.CompactionRequest; -079import org.apache.hadoop.hbase.regionserver.querymatcher.DeleteTracker; -080import org.apache.hadoop.hbase.security.User; -081import org.apache.hadoop.hbase.util.Bytes; -082import org.apache.hadoop.hbase.util.CoprocessorClassLoader; -083import org.apache.hadoop.hbase.util.Pair; -084import org.apache.hadoop.hbase.wal.WALEdit; -085import org.apache.hadoop.hbase.wal.WALKey; +022import java.io.IOException; +023import java.util.ArrayList; +024import java.util.List; +025import java.util.Map; +026import java.util.NavigableSet; +027import java.util.UUID; +028import java.util.concurrent.ConcurrentHashMap; +029import java.util.concurrent.ConcurrentMap; +030import java.util.regex.Matcher; +031 +032import com.google.protobuf.Message; +033import com.google.protobuf.Service; +034import org.apache.commons.collections4.map.AbstractReferenceMap; +035import org.apache.commons.collections4.map.ReferenceMap; +036import org.apache.commons.lang3.ClassUtils; +037import org.apache.commons.logging.Log; +038import org.apache.commons.logging.LogFactory; +039import org.apache.hadoop.conf.Configuration; +040import org.apache.hadoop.fs.FileSystem; +041import org.apache.hadoop.fs.Path; +042import
[20/51] [partial] hbase-site git commit: Published site at .
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/fa7d6c0c/devapidocs/src-html/org/apache/hadoop/hbase/master/MasterCoprocessorHost.html -- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/master/MasterCoprocessorHost.html b/devapidocs/src-html/org/apache/hadoop/hbase/master/MasterCoprocessorHost.html index 4b35f07..2a29b1c 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/master/MasterCoprocessorHost.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/master/MasterCoprocessorHost.html @@ -36,35 +36,35 @@ 028import org.apache.commons.logging.LogFactory; 029import org.apache.hadoop.conf.Configuration; 030import org.apache.hadoop.hbase.Coprocessor; -031import org.apache.hadoop.hbase.HRegionInfo; -032import org.apache.hadoop.hbase.MetaMutationAnnotation; -033import org.apache.hadoop.hbase.NamespaceDescriptor; -034import org.apache.hadoop.hbase.ServerName; -035import org.apache.hadoop.hbase.TableName; -036import org.apache.yetus.audience.InterfaceAudience; -037import org.apache.hadoop.hbase.client.ColumnFamilyDescriptor; -038import org.apache.hadoop.hbase.client.MasterSwitchType; -039import org.apache.hadoop.hbase.client.Mutation; -040import org.apache.hadoop.hbase.client.TableDescriptor; -041import org.apache.hadoop.hbase.coprocessor.CoprocessorHost; -042import org.apache.hadoop.hbase.coprocessor.CoprocessorService; -043import org.apache.hadoop.hbase.coprocessor.MasterCoprocessorEnvironment; -044import org.apache.hadoop.hbase.coprocessor.MasterObserver; -045import org.apache.hadoop.hbase.coprocessor.MetricsCoprocessor; -046import org.apache.hadoop.hbase.coprocessor.ObserverContext; -047import org.apache.hadoop.hbase.ipc.RpcServer; -048import org.apache.hadoop.hbase.master.locking.LockProcedure; -049import org.apache.hadoop.hbase.master.procedure.MasterProcedureEnv; -050import org.apache.hadoop.hbase.metrics.MetricRegistry; -051import org.apache.hadoop.hbase.net.Address; -052import org.apache.hadoop.hbase.procedure2.LockType; -053import org.apache.hadoop.hbase.procedure2.LockedResource; -054import org.apache.hadoop.hbase.procedure2.Procedure; -055import org.apache.hadoop.hbase.procedure2.ProcedureExecutor; -056import org.apache.hadoop.hbase.replication.ReplicationPeerConfig; -057import org.apache.hadoop.hbase.security.User; -058import org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.Quotas; -059import org.apache.hadoop.hbase.shaded.protobuf.generated.SnapshotProtos.SnapshotDescription; +031import org.apache.hadoop.hbase.MetaMutationAnnotation; +032import org.apache.hadoop.hbase.NamespaceDescriptor; +033import org.apache.hadoop.hbase.ServerName; +034import org.apache.hadoop.hbase.TableName; +035import org.apache.hadoop.hbase.client.ColumnFamilyDescriptor; +036import org.apache.hadoop.hbase.client.MasterSwitchType; +037import org.apache.hadoop.hbase.client.Mutation; +038import org.apache.hadoop.hbase.client.RegionInfo; +039import org.apache.hadoop.hbase.client.TableDescriptor; +040import org.apache.hadoop.hbase.coprocessor.CoprocessorHost; +041import org.apache.hadoop.hbase.coprocessor.CoprocessorService; +042import org.apache.hadoop.hbase.coprocessor.MasterCoprocessorEnvironment; +043import org.apache.hadoop.hbase.coprocessor.MasterObserver; +044import org.apache.hadoop.hbase.coprocessor.MetricsCoprocessor; +045import org.apache.hadoop.hbase.coprocessor.ObserverContext; +046import org.apache.hadoop.hbase.ipc.RpcServer; +047import org.apache.hadoop.hbase.master.locking.LockProcedure; +048import org.apache.hadoop.hbase.master.procedure.MasterProcedureEnv; +049import org.apache.hadoop.hbase.metrics.MetricRegistry; +050import org.apache.hadoop.hbase.net.Address; +051import org.apache.hadoop.hbase.procedure2.LockType; +052import org.apache.hadoop.hbase.procedure2.LockedResource; +053import org.apache.hadoop.hbase.procedure2.Procedure; +054import org.apache.hadoop.hbase.procedure2.ProcedureExecutor; +055import org.apache.hadoop.hbase.replication.ReplicationPeerConfig; +056import org.apache.hadoop.hbase.security.User; +057import org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.Quotas; +058import org.apache.hadoop.hbase.shaded.protobuf.generated.SnapshotProtos.SnapshotDescription; +059import org.apache.yetus.audience.InterfaceAudience; 060 061/** 062 * Provides the coprocessor framework and environment for master oriented @@ -250,7 +250,7 @@ 242 243 /* Implementation of hooks for invoking MasterObservers */ 244 -245 public void preCreateTable(final TableDescriptor htd, final HRegionInfo[] regions) +245 public void preCreateTable(final TableDescriptor htd, final RegionInfo[] regions) 246 throws IOException { 247execOperation(coprocessors.isEmpty() ? null : new CoprocessorOperation() { 248 @Override @@ -261,7 +261,7 @@ 253}); 254 } 255 -256 public void postCreateTable(final TableDescriptor htd,
[12/51] [partial] hbase-site git commit: Published site at .
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/fa7d6c0c/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RegionCoprocessorHost.CoprocessorOperation.html -- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RegionCoprocessorHost.CoprocessorOperation.html b/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RegionCoprocessorHost.CoprocessorOperation.html index cf3f141..a4d46aa 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RegionCoprocessorHost.CoprocessorOperation.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RegionCoprocessorHost.CoprocessorOperation.html @@ -27,1612 +27,1609 @@ 019 020package org.apache.hadoop.hbase.regionserver; 021 -022import com.google.protobuf.Message; -023import com.google.protobuf.Service; -024 -025import java.io.IOException; -026import java.util.ArrayList; -027import java.util.List; -028import java.util.Map; -029import java.util.NavigableSet; -030import java.util.UUID; -031import java.util.concurrent.ConcurrentHashMap; -032import java.util.concurrent.ConcurrentMap; -033import java.util.regex.Matcher; -034 -035import org.apache.commons.collections4.map.AbstractReferenceMap; -036import org.apache.commons.collections4.map.ReferenceMap; -037import org.apache.commons.lang3.ClassUtils; -038import org.apache.commons.logging.Log; -039import org.apache.commons.logging.LogFactory; -040import org.apache.hadoop.conf.Configuration; -041import org.apache.hadoop.fs.FileSystem; -042import org.apache.hadoop.fs.Path; -043import org.apache.hadoop.hbase.Cell; -044import org.apache.hadoop.hbase.CompareOperator; -045import org.apache.hadoop.hbase.Coprocessor; -046import org.apache.hadoop.hbase.HBaseConfiguration; -047import org.apache.hadoop.hbase.HBaseInterfaceAudience; -048import org.apache.hadoop.hbase.HConstants; -049import org.apache.hadoop.hbase.HRegionInfo; -050import org.apache.yetus.audience.InterfaceAudience; -051import org.apache.yetus.audience.InterfaceStability; -052import org.apache.hadoop.hbase.client.Append; -053import org.apache.hadoop.hbase.client.Delete; -054import org.apache.hadoop.hbase.client.Durability; -055import org.apache.hadoop.hbase.client.Get; -056import org.apache.hadoop.hbase.client.Increment; -057import org.apache.hadoop.hbase.client.Mutation; -058import org.apache.hadoop.hbase.client.Put; -059import org.apache.hadoop.hbase.client.Result; -060import org.apache.hadoop.hbase.client.Scan; -061import org.apache.hadoop.hbase.client.TableDescriptor; -062import org.apache.hadoop.hbase.coprocessor.CoprocessorHost; -063import org.apache.hadoop.hbase.coprocessor.CoprocessorService; -064import org.apache.hadoop.hbase.coprocessor.EndpointObserver; -065import org.apache.hadoop.hbase.coprocessor.MetricsCoprocessor; -066import org.apache.hadoop.hbase.coprocessor.ObserverContext; -067import org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment; -068import org.apache.hadoop.hbase.coprocessor.RegionObserver; -069import org.apache.hadoop.hbase.coprocessor.RegionObserver.MutationType; -070import org.apache.hadoop.hbase.filter.ByteArrayComparable; -071import org.apache.hadoop.hbase.io.FSDataInputStreamWrapper; -072import org.apache.hadoop.hbase.io.Reference; -073import org.apache.hadoop.hbase.io.hfile.CacheConfig; -074import org.apache.hadoop.hbase.ipc.RpcServer; -075import org.apache.hadoop.hbase.metrics.MetricRegistry; -076import org.apache.hadoop.hbase.regionserver.Region.Operation; -077import org.apache.hadoop.hbase.regionserver.compactions.CompactionLifeCycleTracker; -078import org.apache.hadoop.hbase.regionserver.compactions.CompactionRequest; -079import org.apache.hadoop.hbase.regionserver.querymatcher.DeleteTracker; -080import org.apache.hadoop.hbase.security.User; -081import org.apache.hadoop.hbase.util.Bytes; -082import org.apache.hadoop.hbase.util.CoprocessorClassLoader; -083import org.apache.hadoop.hbase.util.Pair; -084import org.apache.hadoop.hbase.wal.WALEdit; -085import org.apache.hadoop.hbase.wal.WALKey; +022import java.io.IOException; +023import java.util.ArrayList; +024import java.util.List; +025import java.util.Map; +026import java.util.NavigableSet; +027import java.util.UUID; +028import java.util.concurrent.ConcurrentHashMap; +029import java.util.concurrent.ConcurrentMap; +030import java.util.regex.Matcher; +031 +032import com.google.protobuf.Message; +033import com.google.protobuf.Service; +034import org.apache.commons.collections4.map.AbstractReferenceMap; +035import org.apache.commons.collections4.map.ReferenceMap; +036import org.apache.commons.lang3.ClassUtils; +037import org.apache.commons.logging.Log; +038import org.apache.commons.logging.LogFactory; +039import org.apache.hadoop.conf.Configuration; +040import org.apache.hadoop.fs.FileSystem; +041import org.apache.hadoop.fs.Path; +042import org.apache.hadoop.hbase.Cell; +043import
[32/51] [partial] hbase-site git commit: Published site at .
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/fa7d6c0c/devapidocs/org/apache/hadoop/hbase/regionserver/RegionCoprocessorHost.CoprocessorOperation.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/regionserver/RegionCoprocessorHost.CoprocessorOperation.html b/devapidocs/org/apache/hadoop/hbase/regionserver/RegionCoprocessorHost.CoprocessorOperation.html index c642459..33ba028 100644 --- a/devapidocs/org/apache/hadoop/hbase/regionserver/RegionCoprocessorHost.CoprocessorOperation.html +++ b/devapidocs/org/apache/hadoop/hbase/regionserver/RegionCoprocessorHost.CoprocessorOperation.html @@ -122,7 +122,7 @@ var activeTableTab = "activeTableTab"; -private abstract static class RegionCoprocessorHost.CoprocessorOperation +private abstract static class RegionCoprocessorHost.CoprocessorOperation extends ObserverContextRegionCoprocessorEnvironment @@ -210,7 +210,7 @@ extends CoprocessorOperation -publicCoprocessorOperation() +publicCoprocessorOperation() @@ -219,7 +219,7 @@ extends CoprocessorOperation -publicCoprocessorOperation(Useruser) +publicCoprocessorOperation(Useruser) @@ -236,7 +236,7 @@ extends call -public abstractvoidcall(Coprocessorobserver, +public abstractvoidcall(Coprocessorobserver, ObserverContextRegionCoprocessorEnvironmentctx) throws http://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true; title="class or interface in java.io">IOException @@ -251,7 +251,7 @@ extends hasCall -public abstractbooleanhasCall(Coprocessorobserver) +public abstractbooleanhasCall(Coprocessorobserver) @@ -260,7 +260,7 @@ extends postEnvCall -publicvoidpostEnvCall(RegionCoprocessorHost.RegionEnvironmentenv) +publicvoidpostEnvCall(RegionCoprocessorHost.RegionEnvironmentenv) http://git-wip-us.apache.org/repos/asf/hbase-site/blob/fa7d6c0c/devapidocs/org/apache/hadoop/hbase/regionserver/RegionCoprocessorHost.EndpointOperation.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/regionserver/RegionCoprocessorHost.EndpointOperation.html b/devapidocs/org/apache/hadoop/hbase/regionserver/RegionCoprocessorHost.EndpointOperation.html index 928bb34..19789fc 100644 --- a/devapidocs/org/apache/hadoop/hbase/regionserver/RegionCoprocessorHost.EndpointOperation.html +++ b/devapidocs/org/apache/hadoop/hbase/regionserver/RegionCoprocessorHost.EndpointOperation.html @@ -127,7 +127,7 @@ var activeTableTab = "activeTableTab"; -private abstract static class RegionCoprocessorHost.EndpointOperation +private abstract static class RegionCoprocessorHost.EndpointOperation extends RegionCoprocessorHost.CoprocessorOperation @@ -222,7 +222,7 @@ extends EndpointOperation -privateEndpointOperation() +privateEndpointOperation() @@ -239,7 +239,7 @@ extends call -public abstractvoidcall(EndpointObserverobserver, +public abstractvoidcall(EndpointObserverobserver, ObserverContextRegionCoprocessorEnvironmentctx) throws http://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true; title="class or interface in java.io">IOException @@ -254,7 +254,7 @@ extends hasCall -publicbooleanhasCall(Coprocessorobserver) +publicbooleanhasCall(Coprocessorobserver) Specified by: hasCallin classRegionCoprocessorHost.CoprocessorOperation @@ -267,7 +267,7 @@ extends call -publicvoidcall(Coprocessorobserver, +publicvoidcall(Coprocessorobserver, ObserverContextRegionCoprocessorEnvironmentctx) throws http://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true; title="class or interface in java.io">IOException http://git-wip-us.apache.org/repos/asf/hbase-site/blob/fa7d6c0c/devapidocs/org/apache/hadoop/hbase/regionserver/RegionCoprocessorHost.EndpointOperationWithResult.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/regionserver/RegionCoprocessorHost.EndpointOperationWithResult.html b/devapidocs/org/apache/hadoop/hbase/regionserver/RegionCoprocessorHost.EndpointOperationWithResult.html index a936dce..8ce2879 100644 --- a/devapidocs/org/apache/hadoop/hbase/regionserver/RegionCoprocessorHost.EndpointOperationWithResult.html +++ b/devapidocs/org/apache/hadoop/hbase/regionserver/RegionCoprocessorHost.EndpointOperationWithResult.html @@ -128,7 +128,7 @@ var activeTableTab = "activeTableTab"; -private abstract static class RegionCoprocessorHost.EndpointOperationWithResultT +private abstract static class RegionCoprocessorHost.EndpointOperationWithResultT extends RegionCoprocessorHost.EndpointOperation @@ -243,7 +243,7 @@ extends result -privateT result +privateT result @@ -260,7 +260,7 @@ extends EndpointOperationWithResult
[27/51] [partial] hbase-site git commit: Published site at .
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/fa7d6c0c/devapidocs/org/apache/hadoop/hbase/security/access/AccessController.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/security/access/AccessController.html b/devapidocs/org/apache/hadoop/hbase/security/access/AccessController.html index b256835..4c43167 100644 --- a/devapidocs/org/apache/hadoop/hbase/security/access/AccessController.html +++ b/devapidocs/org/apache/hadoop/hbase/security/access/AccessController.html @@ -114,7 +114,7 @@ var activeTableTab = "activeTableTab"; @InterfaceAudience.LimitedPrivate(value="Configuration") -public class AccessController +public class AccessController extends http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true; title="class or interface in java.lang">Object implements MasterObserver, RegionObserver, RegionServerObserver, org.apache.hadoop.hbase.protobuf.generated.AccessControlProtos.AccessControlService.Interface, CoprocessorService, EndpointObserver, BulkLoadObserver Provides basic authorization checks for data access and administrative @@ -353,10 +353,10 @@ implements private void -checkLockPermissions(Useruser, +checkLockPermissions(Useruser, http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">Stringnamespace, TableNametableName, -HRegionInfo[]regionInfos, +RegionInfo[]regionInfos, http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">Stringreason) @@ -484,9 +484,9 @@ implements void -postCompletedCreateTableAction(ObserverContextMasterCoprocessorEnvironmentc, +postCompletedCreateTableAction(ObserverContextMasterCoprocessorEnvironmentc, TableDescriptordesc, - HRegionInfo[]regions) + RegionInfo[]regions) Called after the createTable operation has been requested. @@ -717,8 +717,8 @@ implements void -preAssign(ObserverContextMasterCoprocessorEnvironmentc, - HRegionInforegionInfo) +preAssign(ObserverContextMasterCoprocessorEnvironmentc, + RegionInforegionInfo) Called prior to assigning a specific region. @@ -867,9 +867,9 @@ implements void -preCreateTable(ObserverContextMasterCoprocessorEnvironmentc, +preCreateTable(ObserverContextMasterCoprocessorEnvironmentc, TableDescriptordesc, - HRegionInfo[]regions) + RegionInfo[]regions) Called before a new table is created by HMaster. @@ -1047,8 +1047,8 @@ implements void -preMergeRegions(ObserverContextMasterCoprocessorEnvironmentctx, - HRegionInfo[]regionsToMerge) +preMergeRegions(ObserverContextMasterCoprocessorEnvironmentctx, + RegionInfo[]regionsToMerge) Called before merge regions request. @@ -1077,8 +1077,8 @@ implements void -preMove(ObserverContextMasterCoprocessorEnvironmentc, - HRegionInforegion, +preMove(ObserverContextMasterCoprocessorEnvironmentc, + RegionInforegion, ServerNamesrcServer, ServerNamedestServer) Called prior to moving a given region from one region server to another. @@ -1134,8 +1134,8 @@ implements void -preRegionOffline(ObserverContextMasterCoprocessorEnvironmentc, -HRegionInforegionInfo) +preRegionOffline(ObserverContextMasterCoprocessorEnvironmentc, +RegionInforegionInfo) Called prior to marking a given region as offline. @@ -1163,10 +1163,10 @@ implements void -preRequestLock(ObserverContextMasterCoprocessorEnvironmentctx, +preRequestLock(ObserverContextMasterCoprocessorEnvironmentctx, http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">Stringnamespace, TableNametableName, - HRegionInfo[]regionInfos, + RegionInfo[]regionInfos, LockTypetype, http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">Stringdescription) Called before new LockProcedure is queued. @@ -1314,8 +1314,8 @@ implements void -preUnassign(ObserverContextMasterCoprocessorEnvironmentc, - HRegionInforegionInfo, +preUnassign(ObserverContextMasterCoprocessorEnvironmentc, + RegionInforegionInfo, booleanforce) Called prior to unassigning a given region. @@ -1451,14 +1451,14 @@ implements MasterObserver -postAddColumnFamily, postAddReplicationPeer, postAddRSGroup, postAssign, postBalance, postBalanceRSGroup, postBalanceSwitch, postClearDeadServers, postCloneSnapsh ot, postCompletedAddColumnFamilyAction, postCompletedDeleteColumnFamilyAction, postCompletedDeleteTableAction,
[16/51] [partial] hbase-site git commit: Published site at .
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/fa7d6c0c/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RSRpcServices.RegionScannerShippedCallBack.html -- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RSRpcServices.RegionScannerShippedCallBack.html b/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RSRpcServices.RegionScannerShippedCallBack.html index e0b1774..f3d4c5e 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RSRpcServices.RegionScannerShippedCallBack.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RSRpcServices.RegionScannerShippedCallBack.html @@ -605,13 +605,13 @@ 597 * @param row 598 * @param family 599 * @param qualifier -600 * @param op +600 * @param compareOp 601 * @param comparator @throws IOException 602 */ 603 private boolean checkAndRowMutate(final Region region, final ListClientProtos.Action actions, -604 final CellScanner cellScanner, byte[] row, byte[] family, byte[] qualifier, -605 CompareOperator op, ByteArrayComparable comparator, RegionActionResult.Builder builder, -606 ActivePolicyEnforcement spaceQuotaEnforcement) throws IOException { +604final CellScanner cellScanner, byte[] row, byte[] family, byte[] qualifier, +605 CompareOperator op, ByteArrayComparable comparator, RegionActionResult.Builder builder, +606 ActivePolicyEnforcement spaceQuotaEnforcement) throws IOException { 607if (!region.getRegionInfo().isMetaTable()) { 608 regionServer.cacheFlusher.reclaimMemStoreMemory(); 609} @@ -656,2842 +656,2846 @@ 648 649 /** 650 * Execute an append mutation. -651 * @return result to return to client if default operation should be -652 * bypassed as indicated by RegionObserver, null otherwise -653 * @throws IOException -654 */ -655 private Result append(final Region region, final OperationQuota quota, -656 final MutationProto mutation, final CellScanner cellScanner, long nonceGroup, -657 ActivePolicyEnforcement spaceQuota) -658 throws IOException { -659long before = EnvironmentEdgeManager.currentTime(); -660Append append = ProtobufUtil.toAppend(mutation, cellScanner); -661checkCellSizeLimit(region, append); -662 spaceQuota.getPolicyEnforcement(region).check(append); -663quota.addMutation(append); -664Result r = null; -665if (region.getCoprocessorHost() != null) { -666 r = region.getCoprocessorHost().preAppend(append); -667} -668if (r == null) { -669 boolean canProceed = startNonceOperation(mutation, nonceGroup); -670 boolean success = false; -671 try { -672long nonce = mutation.hasNonce() ? mutation.getNonce() : HConstants.NO_NONCE; -673if (canProceed) { -674 r = region.append(append, nonceGroup, nonce); -675} else { -676 // convert duplicate append to get -677 ListCell results = region.get(ProtobufUtil.toGet(mutation, cellScanner), false, -678nonceGroup, nonce); -679 r = Result.create(results); -680} -681success = true; -682 } finally { -683if (canProceed) { -684 endNonceOperation(mutation, nonceGroup, success); -685} -686 } -687 if (region.getCoprocessorHost() != null) { -688r = region.getCoprocessorHost().postAppend(append, r); -689 } -690} -691if (regionServer.metricsRegionServer != null) { -692 regionServer.metricsRegionServer.updateAppend( -693 EnvironmentEdgeManager.currentTime() - before); +651 * +652 * @param region +653 * @param m +654 * @param cellScanner +655 * @return result to return to client if default operation should be +656 * bypassed as indicated by RegionObserver, null otherwise +657 * @throws IOException +658 */ +659 private Result append(final Region region, final OperationQuota quota, +660 final MutationProto mutation, final CellScanner cellScanner, long nonceGroup, +661 ActivePolicyEnforcement spaceQuota) +662 throws IOException { +663long before = EnvironmentEdgeManager.currentTime(); +664Append append = ProtobufUtil.toAppend(mutation, cellScanner); +665checkCellSizeLimit(region, append); +666 spaceQuota.getPolicyEnforcement(region).check(append); +667quota.addMutation(append); +668Result r = null; +669if (region.getCoprocessorHost() != null) { +670 r = region.getCoprocessorHost().preAppend(append); +671} +672if (r == null) { +673 boolean canProceed = startNonceOperation(mutation, nonceGroup); +674 boolean success = false; +675 try { +676long nonce = mutation.hasNonce() ? mutation.getNonce() : HConstants.NO_NONCE; +677if (canProceed) { +678 r =
[11/51] [partial] hbase-site git commit: Published site at .
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/fa7d6c0c/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RegionCoprocessorHost.EndpointOperation.html -- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RegionCoprocessorHost.EndpointOperation.html b/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RegionCoprocessorHost.EndpointOperation.html index cf3f141..a4d46aa 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RegionCoprocessorHost.EndpointOperation.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RegionCoprocessorHost.EndpointOperation.html @@ -27,1612 +27,1609 @@ 019 020package org.apache.hadoop.hbase.regionserver; 021 -022import com.google.protobuf.Message; -023import com.google.protobuf.Service; -024 -025import java.io.IOException; -026import java.util.ArrayList; -027import java.util.List; -028import java.util.Map; -029import java.util.NavigableSet; -030import java.util.UUID; -031import java.util.concurrent.ConcurrentHashMap; -032import java.util.concurrent.ConcurrentMap; -033import java.util.regex.Matcher; -034 -035import org.apache.commons.collections4.map.AbstractReferenceMap; -036import org.apache.commons.collections4.map.ReferenceMap; -037import org.apache.commons.lang3.ClassUtils; -038import org.apache.commons.logging.Log; -039import org.apache.commons.logging.LogFactory; -040import org.apache.hadoop.conf.Configuration; -041import org.apache.hadoop.fs.FileSystem; -042import org.apache.hadoop.fs.Path; -043import org.apache.hadoop.hbase.Cell; -044import org.apache.hadoop.hbase.CompareOperator; -045import org.apache.hadoop.hbase.Coprocessor; -046import org.apache.hadoop.hbase.HBaseConfiguration; -047import org.apache.hadoop.hbase.HBaseInterfaceAudience; -048import org.apache.hadoop.hbase.HConstants; -049import org.apache.hadoop.hbase.HRegionInfo; -050import org.apache.yetus.audience.InterfaceAudience; -051import org.apache.yetus.audience.InterfaceStability; -052import org.apache.hadoop.hbase.client.Append; -053import org.apache.hadoop.hbase.client.Delete; -054import org.apache.hadoop.hbase.client.Durability; -055import org.apache.hadoop.hbase.client.Get; -056import org.apache.hadoop.hbase.client.Increment; -057import org.apache.hadoop.hbase.client.Mutation; -058import org.apache.hadoop.hbase.client.Put; -059import org.apache.hadoop.hbase.client.Result; -060import org.apache.hadoop.hbase.client.Scan; -061import org.apache.hadoop.hbase.client.TableDescriptor; -062import org.apache.hadoop.hbase.coprocessor.CoprocessorHost; -063import org.apache.hadoop.hbase.coprocessor.CoprocessorService; -064import org.apache.hadoop.hbase.coprocessor.EndpointObserver; -065import org.apache.hadoop.hbase.coprocessor.MetricsCoprocessor; -066import org.apache.hadoop.hbase.coprocessor.ObserverContext; -067import org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment; -068import org.apache.hadoop.hbase.coprocessor.RegionObserver; -069import org.apache.hadoop.hbase.coprocessor.RegionObserver.MutationType; -070import org.apache.hadoop.hbase.filter.ByteArrayComparable; -071import org.apache.hadoop.hbase.io.FSDataInputStreamWrapper; -072import org.apache.hadoop.hbase.io.Reference; -073import org.apache.hadoop.hbase.io.hfile.CacheConfig; -074import org.apache.hadoop.hbase.ipc.RpcServer; -075import org.apache.hadoop.hbase.metrics.MetricRegistry; -076import org.apache.hadoop.hbase.regionserver.Region.Operation; -077import org.apache.hadoop.hbase.regionserver.compactions.CompactionLifeCycleTracker; -078import org.apache.hadoop.hbase.regionserver.compactions.CompactionRequest; -079import org.apache.hadoop.hbase.regionserver.querymatcher.DeleteTracker; -080import org.apache.hadoop.hbase.security.User; -081import org.apache.hadoop.hbase.util.Bytes; -082import org.apache.hadoop.hbase.util.CoprocessorClassLoader; -083import org.apache.hadoop.hbase.util.Pair; -084import org.apache.hadoop.hbase.wal.WALEdit; -085import org.apache.hadoop.hbase.wal.WALKey; +022import java.io.IOException; +023import java.util.ArrayList; +024import java.util.List; +025import java.util.Map; +026import java.util.NavigableSet; +027import java.util.UUID; +028import java.util.concurrent.ConcurrentHashMap; +029import java.util.concurrent.ConcurrentMap; +030import java.util.regex.Matcher; +031 +032import com.google.protobuf.Message; +033import com.google.protobuf.Service; +034import org.apache.commons.collections4.map.AbstractReferenceMap; +035import org.apache.commons.collections4.map.ReferenceMap; +036import org.apache.commons.lang3.ClassUtils; +037import org.apache.commons.logging.Log; +038import org.apache.commons.logging.LogFactory; +039import org.apache.hadoop.conf.Configuration; +040import org.apache.hadoop.fs.FileSystem; +041import org.apache.hadoop.fs.Path; +042import org.apache.hadoop.hbase.Cell; +043import
[30/51] [partial] hbase-site git commit: Published site at .
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/fa7d6c0c/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 ef0a936..7e58719 100644 --- a/devapidocs/org/apache/hadoop/hbase/regionserver/package-tree.html +++ b/devapidocs/org/apache/hadoop/hbase/regionserver/package-tree.html @@ -696,18 +696,18 @@ java.lang.http://docs.oracle.com/javase/8/docs/api/java/lang/Enum.html?is-external=true; title="class or interface in java.lang">EnumE (implements java.lang.http://docs.oracle.com/javase/8/docs/api/java/lang/Comparable.html?is-external=true; title="class or interface in java.lang">ComparableT, java.io.http://docs.oracle.com/javase/8/docs/api/java/io/Serializable.html?is-external=true; title="class or interface in java.io">Serializable) +org.apache.hadoop.hbase.regionserver.SplitLogWorker.TaskExecutor.Status +org.apache.hadoop.hbase.regionserver.Region.FlushResult.Result org.apache.hadoop.hbase.regionserver.BloomType -org.apache.hadoop.hbase.regionserver.ScannerContext.NextState org.apache.hadoop.hbase.regionserver.CompactingMemStore.IndexType -org.apache.hadoop.hbase.regionserver.ScanType -org.apache.hadoop.hbase.regionserver.SplitLogWorker.TaskExecutor.Status -org.apache.hadoop.hbase.regionserver.Region.Operation org.apache.hadoop.hbase.regionserver.FlushType -org.apache.hadoop.hbase.regionserver.MetricsRegionServerSourceFactoryImpl.FactoryStorage -org.apache.hadoop.hbase.regionserver.MemStoreCompactor.Action -org.apache.hadoop.hbase.regionserver.ScannerContext.LimitScope -org.apache.hadoop.hbase.regionserver.Region.FlushResult.Result +org.apache.hadoop.hbase.regionserver.Region.Operation org.apache.hadoop.hbase.regionserver.DefaultHeapMemoryTuner.StepDirection +org.apache.hadoop.hbase.regionserver.ScannerContext.LimitScope +org.apache.hadoop.hbase.regionserver.ScanType +org.apache.hadoop.hbase.regionserver.MemStoreCompactor.Action +org.apache.hadoop.hbase.regionserver.MetricsRegionServerSourceFactoryImpl.FactoryStorage +org.apache.hadoop.hbase.regionserver.ScannerContext.NextState http://git-wip-us.apache.org/repos/asf/hbase-site/blob/fa7d6c0c/devapidocs/org/apache/hadoop/hbase/regionserver/querymatcher/package-tree.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/regionserver/querymatcher/package-tree.html b/devapidocs/org/apache/hadoop/hbase/regionserver/querymatcher/package-tree.html index b9cd85d..9d29552 100644 --- a/devapidocs/org/apache/hadoop/hbase/regionserver/querymatcher/package-tree.html +++ b/devapidocs/org/apache/hadoop/hbase/regionserver/querymatcher/package-tree.html @@ -130,8 +130,8 @@ java.lang.http://docs.oracle.com/javase/8/docs/api/java/lang/Enum.html?is-external=true; title="class or interface in java.lang">EnumE (implements java.lang.http://docs.oracle.com/javase/8/docs/api/java/lang/Comparable.html?is-external=true; title="class or interface in java.lang">ComparableT, java.io.http://docs.oracle.com/javase/8/docs/api/java/io/Serializable.html?is-external=true; title="class or interface in java.io">Serializable) -org.apache.hadoop.hbase.regionserver.querymatcher.StripeCompactionScanQueryMatcher.DropDeletesInOutput org.apache.hadoop.hbase.regionserver.querymatcher.ScanQueryMatcher.MatchCode +org.apache.hadoop.hbase.regionserver.querymatcher.StripeCompactionScanQueryMatcher.DropDeletesInOutput org.apache.hadoop.hbase.regionserver.querymatcher.DeleteTracker.DeleteResult http://git-wip-us.apache.org/repos/asf/hbase-site/blob/fa7d6c0c/devapidocs/org/apache/hadoop/hbase/regionserver/wal/ProtobufLogReader.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/regionserver/wal/ProtobufLogReader.html b/devapidocs/org/apache/hadoop/hbase/regionserver/wal/ProtobufLogReader.html index 42bd22d..865da7d 100644 --- a/devapidocs/org/apache/hadoop/hbase/regionserver/wal/ProtobufLogReader.html +++ b/devapidocs/org/apache/hadoop/hbase/regionserver/wal/ProtobufLogReader.html @@ -873,7 +873,7 @@ publiclong extractHiddenEof -privatehttp://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true; title="class or interface in java.io">IOExceptionextractHiddenEof(http://docs.oracle.com/javase/8/docs/api/java/lang/Exception.html?is-external=true; title="class or interface in java.lang">Exceptionex) +privatehttp://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true; title="class or interface in java.io">IOExceptionextractHiddenEof(http://docs.oracle.com/javase/8/docs/api/java/lang/Exception.html?is-external=true; title="class or interface in java.lang">Exceptionex) @@ -882,7 +882,7 @@ publiclong seekOnFs
[07/51] [partial] hbase-site git commit: Published site at .
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/fa7d6c0c/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RegionCoprocessorHost.RegionOperationWithResult.html -- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RegionCoprocessorHost.RegionOperationWithResult.html b/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RegionCoprocessorHost.RegionOperationWithResult.html index cf3f141..a4d46aa 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RegionCoprocessorHost.RegionOperationWithResult.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RegionCoprocessorHost.RegionOperationWithResult.html @@ -27,1612 +27,1609 @@ 019 020package org.apache.hadoop.hbase.regionserver; 021 -022import com.google.protobuf.Message; -023import com.google.protobuf.Service; -024 -025import java.io.IOException; -026import java.util.ArrayList; -027import java.util.List; -028import java.util.Map; -029import java.util.NavigableSet; -030import java.util.UUID; -031import java.util.concurrent.ConcurrentHashMap; -032import java.util.concurrent.ConcurrentMap; -033import java.util.regex.Matcher; -034 -035import org.apache.commons.collections4.map.AbstractReferenceMap; -036import org.apache.commons.collections4.map.ReferenceMap; -037import org.apache.commons.lang3.ClassUtils; -038import org.apache.commons.logging.Log; -039import org.apache.commons.logging.LogFactory; -040import org.apache.hadoop.conf.Configuration; -041import org.apache.hadoop.fs.FileSystem; -042import org.apache.hadoop.fs.Path; -043import org.apache.hadoop.hbase.Cell; -044import org.apache.hadoop.hbase.CompareOperator; -045import org.apache.hadoop.hbase.Coprocessor; -046import org.apache.hadoop.hbase.HBaseConfiguration; -047import org.apache.hadoop.hbase.HBaseInterfaceAudience; -048import org.apache.hadoop.hbase.HConstants; -049import org.apache.hadoop.hbase.HRegionInfo; -050import org.apache.yetus.audience.InterfaceAudience; -051import org.apache.yetus.audience.InterfaceStability; -052import org.apache.hadoop.hbase.client.Append; -053import org.apache.hadoop.hbase.client.Delete; -054import org.apache.hadoop.hbase.client.Durability; -055import org.apache.hadoop.hbase.client.Get; -056import org.apache.hadoop.hbase.client.Increment; -057import org.apache.hadoop.hbase.client.Mutation; -058import org.apache.hadoop.hbase.client.Put; -059import org.apache.hadoop.hbase.client.Result; -060import org.apache.hadoop.hbase.client.Scan; -061import org.apache.hadoop.hbase.client.TableDescriptor; -062import org.apache.hadoop.hbase.coprocessor.CoprocessorHost; -063import org.apache.hadoop.hbase.coprocessor.CoprocessorService; -064import org.apache.hadoop.hbase.coprocessor.EndpointObserver; -065import org.apache.hadoop.hbase.coprocessor.MetricsCoprocessor; -066import org.apache.hadoop.hbase.coprocessor.ObserverContext; -067import org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment; -068import org.apache.hadoop.hbase.coprocessor.RegionObserver; -069import org.apache.hadoop.hbase.coprocessor.RegionObserver.MutationType; -070import org.apache.hadoop.hbase.filter.ByteArrayComparable; -071import org.apache.hadoop.hbase.io.FSDataInputStreamWrapper; -072import org.apache.hadoop.hbase.io.Reference; -073import org.apache.hadoop.hbase.io.hfile.CacheConfig; -074import org.apache.hadoop.hbase.ipc.RpcServer; -075import org.apache.hadoop.hbase.metrics.MetricRegistry; -076import org.apache.hadoop.hbase.regionserver.Region.Operation; -077import org.apache.hadoop.hbase.regionserver.compactions.CompactionLifeCycleTracker; -078import org.apache.hadoop.hbase.regionserver.compactions.CompactionRequest; -079import org.apache.hadoop.hbase.regionserver.querymatcher.DeleteTracker; -080import org.apache.hadoop.hbase.security.User; -081import org.apache.hadoop.hbase.util.Bytes; -082import org.apache.hadoop.hbase.util.CoprocessorClassLoader; -083import org.apache.hadoop.hbase.util.Pair; -084import org.apache.hadoop.hbase.wal.WALEdit; -085import org.apache.hadoop.hbase.wal.WALKey; +022import java.io.IOException; +023import java.util.ArrayList; +024import java.util.List; +025import java.util.Map; +026import java.util.NavigableSet; +027import java.util.UUID; +028import java.util.concurrent.ConcurrentHashMap; +029import java.util.concurrent.ConcurrentMap; +030import java.util.regex.Matcher; +031 +032import com.google.protobuf.Message; +033import com.google.protobuf.Service; +034import org.apache.commons.collections4.map.AbstractReferenceMap; +035import org.apache.commons.collections4.map.ReferenceMap; +036import org.apache.commons.lang3.ClassUtils; +037import org.apache.commons.logging.Log; +038import org.apache.commons.logging.LogFactory; +039import org.apache.hadoop.conf.Configuration; +040import org.apache.hadoop.fs.FileSystem; +041import org.apache.hadoop.fs.Path; +042import
[25/51] [partial] hbase-site git commit: Published site at .
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/fa7d6c0c/devapidocs/org/apache/hadoop/hbase/security/class-use/User.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/security/class-use/User.html b/devapidocs/org/apache/hadoop/hbase/security/class-use/User.html index af3c56d..c58d582 100644 --- a/devapidocs/org/apache/hadoop/hbase/security/class-use/User.html +++ b/devapidocs/org/apache/hadoop/hbase/security/class-use/User.html @@ -556,8 +556,8 @@ void -MasterCoprocessorHost.postCompletedCreateTableAction(TableDescriptorhtd, - HRegionInfo[]regions, +MasterCoprocessorHost.postCompletedCreateTableAction(TableDescriptorhtd, + RegionInfo[]regions, Useruser) @@ -583,8 +583,8 @@ void -MasterCoprocessorHost.postCompletedMergeRegionsAction(HRegionInfo[]regionsToMerge, - HRegionInfomergedRegion, +MasterCoprocessorHost.postCompletedMergeRegionsAction(RegionInfo[]regionsToMerge, + RegionInfomergedRegion, Useruser) Invoked after completing merge regions operation @@ -603,8 +603,8 @@ void -MasterCoprocessorHost.postCompletedSplitRegionAction(HRegionInforegionInfoA, - HRegionInforegionInfoB, +MasterCoprocessorHost.postCompletedSplitRegionAction(RegionInforegionInfoA, + RegionInforegionInfoB, Useruser) Invoked just after a split @@ -616,15 +616,15 @@ void -MasterCoprocessorHost.postMergeRegionsCommit(HRegionInfo[]regionsToMerge, - HRegionInfomergedRegion, +MasterCoprocessorHost.postMergeRegionsCommit(RegionInfo[]regionsToMerge, + RegionInfomergedRegion, Useruser) Invoked after merge regions operation writes the new region to hbase:meta void -MasterCoprocessorHost.postRollBackMergeRegionsAction(HRegionInfo[]regionsToMerge, +MasterCoprocessorHost.postRollBackMergeRegionsAction(RegionInfo[]regionsToMerge, Useruser) Invoked after rollback merge regions operation @@ -643,8 +643,8 @@ void -MasterCoprocessorHost.preCreateTableAction(TableDescriptorhtd, -HRegionInfo[]regions, +MasterCoprocessorHost.preCreateTableAction(TableDescriptorhtd, +RegionInfo[]regions, Useruser) @@ -670,14 +670,14 @@ boolean -MasterCoprocessorHost.preMergeRegionsAction(HRegionInfo[]regionsToMerge, +MasterCoprocessorHost.preMergeRegionsAction(RegionInfo[]regionsToMerge, Useruser) Invoked just before a merge boolean -MasterCoprocessorHost.preMergeRegionsCommit(HRegionInfo[]regionsToMerge, +MasterCoprocessorHost.preMergeRegionsCommit(RegionInfo[]regionsToMerge, http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true; title="class or interface in java.util">ListMutationmetaEntries, Useruser) Invoked before merge regions operation writes the new region to hbase:meta @@ -1559,10 +1559,10 @@ private void -AccessController.checkLockPermissions(Useruser, +AccessController.checkLockPermissions(Useruser, http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">Stringnamespace, TableNametableName, -HRegionInfo[]regionInfos, +RegionInfo[]regionInfos, http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">Stringreason)
[09/51] [partial] hbase-site git commit: Published site at .
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/fa7d6c0c/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RegionCoprocessorHost.RegionEnvironment.html -- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RegionCoprocessorHost.RegionEnvironment.html b/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RegionCoprocessorHost.RegionEnvironment.html index cf3f141..a4d46aa 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RegionCoprocessorHost.RegionEnvironment.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RegionCoprocessorHost.RegionEnvironment.html @@ -27,1612 +27,1609 @@ 019 020package org.apache.hadoop.hbase.regionserver; 021 -022import com.google.protobuf.Message; -023import com.google.protobuf.Service; -024 -025import java.io.IOException; -026import java.util.ArrayList; -027import java.util.List; -028import java.util.Map; -029import java.util.NavigableSet; -030import java.util.UUID; -031import java.util.concurrent.ConcurrentHashMap; -032import java.util.concurrent.ConcurrentMap; -033import java.util.regex.Matcher; -034 -035import org.apache.commons.collections4.map.AbstractReferenceMap; -036import org.apache.commons.collections4.map.ReferenceMap; -037import org.apache.commons.lang3.ClassUtils; -038import org.apache.commons.logging.Log; -039import org.apache.commons.logging.LogFactory; -040import org.apache.hadoop.conf.Configuration; -041import org.apache.hadoop.fs.FileSystem; -042import org.apache.hadoop.fs.Path; -043import org.apache.hadoop.hbase.Cell; -044import org.apache.hadoop.hbase.CompareOperator; -045import org.apache.hadoop.hbase.Coprocessor; -046import org.apache.hadoop.hbase.HBaseConfiguration; -047import org.apache.hadoop.hbase.HBaseInterfaceAudience; -048import org.apache.hadoop.hbase.HConstants; -049import org.apache.hadoop.hbase.HRegionInfo; -050import org.apache.yetus.audience.InterfaceAudience; -051import org.apache.yetus.audience.InterfaceStability; -052import org.apache.hadoop.hbase.client.Append; -053import org.apache.hadoop.hbase.client.Delete; -054import org.apache.hadoop.hbase.client.Durability; -055import org.apache.hadoop.hbase.client.Get; -056import org.apache.hadoop.hbase.client.Increment; -057import org.apache.hadoop.hbase.client.Mutation; -058import org.apache.hadoop.hbase.client.Put; -059import org.apache.hadoop.hbase.client.Result; -060import org.apache.hadoop.hbase.client.Scan; -061import org.apache.hadoop.hbase.client.TableDescriptor; -062import org.apache.hadoop.hbase.coprocessor.CoprocessorHost; -063import org.apache.hadoop.hbase.coprocessor.CoprocessorService; -064import org.apache.hadoop.hbase.coprocessor.EndpointObserver; -065import org.apache.hadoop.hbase.coprocessor.MetricsCoprocessor; -066import org.apache.hadoop.hbase.coprocessor.ObserverContext; -067import org.apache.hadoop.hbase.coprocessor.RegionCoprocessorEnvironment; -068import org.apache.hadoop.hbase.coprocessor.RegionObserver; -069import org.apache.hadoop.hbase.coprocessor.RegionObserver.MutationType; -070import org.apache.hadoop.hbase.filter.ByteArrayComparable; -071import org.apache.hadoop.hbase.io.FSDataInputStreamWrapper; -072import org.apache.hadoop.hbase.io.Reference; -073import org.apache.hadoop.hbase.io.hfile.CacheConfig; -074import org.apache.hadoop.hbase.ipc.RpcServer; -075import org.apache.hadoop.hbase.metrics.MetricRegistry; -076import org.apache.hadoop.hbase.regionserver.Region.Operation; -077import org.apache.hadoop.hbase.regionserver.compactions.CompactionLifeCycleTracker; -078import org.apache.hadoop.hbase.regionserver.compactions.CompactionRequest; -079import org.apache.hadoop.hbase.regionserver.querymatcher.DeleteTracker; -080import org.apache.hadoop.hbase.security.User; -081import org.apache.hadoop.hbase.util.Bytes; -082import org.apache.hadoop.hbase.util.CoprocessorClassLoader; -083import org.apache.hadoop.hbase.util.Pair; -084import org.apache.hadoop.hbase.wal.WALEdit; -085import org.apache.hadoop.hbase.wal.WALKey; +022import java.io.IOException; +023import java.util.ArrayList; +024import java.util.List; +025import java.util.Map; +026import java.util.NavigableSet; +027import java.util.UUID; +028import java.util.concurrent.ConcurrentHashMap; +029import java.util.concurrent.ConcurrentMap; +030import java.util.regex.Matcher; +031 +032import com.google.protobuf.Message; +033import com.google.protobuf.Service; +034import org.apache.commons.collections4.map.AbstractReferenceMap; +035import org.apache.commons.collections4.map.ReferenceMap; +036import org.apache.commons.lang3.ClassUtils; +037import org.apache.commons.logging.Log; +038import org.apache.commons.logging.LogFactory; +039import org.apache.hadoop.conf.Configuration; +040import org.apache.hadoop.fs.FileSystem; +041import org.apache.hadoop.fs.Path; +042import org.apache.hadoop.hbase.Cell; +043import
[49/51] [partial] hbase-site git commit: Published site at .
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/fa7d6c0c/checkstyle.rss -- diff --git a/checkstyle.rss b/checkstyle.rss index e93e00e..e889a6e 100644 --- a/checkstyle.rss +++ b/checkstyle.rss @@ -26,7 +26,7 @@ under the License. 2007 - 2017 The Apache Software Foundation File: 2042, - Errors: 14017, + Errors: 14003, Warnings: 0, Infos: 0 @@ -377,7 +377,7 @@ under the License. 0 - 28 + 27 @@ -1553,7 +1553,7 @@ under the License. 0 - 4 + 0 @@ -3989,7 +3989,7 @@ under the License. 0 - 1 + 0 @@ -5165,7 +5165,7 @@ under the License. 0 - 180 + 178 @@ -8203,7 +8203,7 @@ under the License. 0 - 5 + 3 @@ -14391,7 +14391,7 @@ under the License. 0 - 20 + 19 @@ -15105,7 +15105,7 @@ under the License. 0 - 40 + 37 @@ -22161,7 +22161,7 @@ under the License. 0 - 147 + 152 @@ -22469,7 +22469,7 @@ under the License. 0 - 2 + 1 @@ -23239,7 +23239,7 @@ under the License. 0 - 1 + 0 @@ -26249,7 +26249,7 @@ under the License. 0 - 25 + 24 @@ -26543,7 +26543,7 @@ under the License. 0 - 74 + 73 @@ -28139,7 +28139,7 @@ under the License. 0 - 2 + 1 http://git-wip-us.apache.org/repos/asf/hbase-site/blob/fa7d6c0c/coc.html -- diff --git a/coc.html b/coc.html index 5d66216..c8946a8 100644 --- a/coc.html +++ b/coc.html @@ -7,7 +7,7 @@ - + Apache HBase Code of Conduct Policy @@ -380,7 +380,7 @@ email to mailto:priv...@hbase.apache.org;>the priv https://www.apache.org/;>The Apache Software Foundation. All rights reserved. - Last Published: 2017-09-20 + Last Published: 2017-09-21 http://git-wip-us.apache.org/repos/asf/hbase-site/blob/fa7d6c0c/cygwin.html -- diff --git a/cygwin.html b/cygwin.html index d577b53..14a5995 100644 --- a/cygwin.html +++ b/cygwin.html @@ -7,7 +7,7 @@ - + Apache HBase Installing Apache HBase (TM) on Windows using Cygwin @@ -679,7 +679,7 @@ Now your HBase server is running, start coding and build that next https://www.apache.org/;>The Apache Software Foundation. All rights reserved. - Last Published: 2017-09-20 + Last Published: 2017-09-21 http://git-wip-us.apache.org/repos/asf/hbase-site/blob/fa7d6c0c/dependencies.html -- diff --git a/dependencies.html b/dependencies.html index c4d9445..36cb413 100644 --- a/dependencies.html +++ b/dependencies.html @@ -7,7 +7,7 @@ - + Apache HBase Project Dependencies @@ -445,7 +445,7 @@
[47/51] [partial] hbase-site git commit: Published site at .
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/fa7d6c0c/devapidocs/org/apache/hadoop/hbase/backup/BackupObserver.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/backup/BackupObserver.html b/devapidocs/org/apache/hadoop/hbase/backup/BackupObserver.html index 7ce0252..71f261b 100644 --- a/devapidocs/org/apache/hadoop/hbase/backup/BackupObserver.html +++ b/devapidocs/org/apache/hadoop/hbase/backup/BackupObserver.html @@ -231,7 +231,7 @@ implements RegionObserver -postAppend, postBatchMutate, postBatchMutateIndispensably, postCheckAndDelete, postCheckAndPut, postClose, postCloseRegionOperation, postCommitStoreFile, postCompact, postCompactSelection, postDelete, postExists, postFlush, postFlush, postGetOp, postIncrement, postInstantiateDeleteTracker, postLogReplay, postMutationBeforeWAL, postOpen, postPut, postReplayWALs, postScannerClose, postScannerFilterRow, postScannerNext, postScannerOpen, postStartRegionOperation, postStoreFileReaderOpen, postWALRestore, preAppend, preAppendAfterRowLock, preBatchMutate, preBulkLoadHFile, preCheckAndDelete, preCheckAndDeleteAfterRowLock, preCheckAndPut, preCheckAndPutAfterRowLock, preClose, preCompact, preCompactScannerOpen, preCompactS election, preDelete, preExists, preFlush, preFlush, preFlushScannerOpen, preGetOp, preIncrement, preIncrementAfterRowLock, preOpen, prePrepareTimeStampForDeleteVersion, prePut, preReplayWALs, preScannerClose, preScannerNext, preScannerOpen, preStoreFileReaderOpen, preStoreScannerOpen, preWALRestore +postAppend, postBatchMutate, postBatchMutateIndispensably, postCheckAndDelete, postCheckAndPut, postClose, postCloseRegionOperation, postCommitStoreFile, postCompact, postCompactSelection, postDelete, postExists, postFlush, postFlush, postGetOp, postIncrement, postInstantiateDeleteTracker, postLogReplay, postMutationBeforeWAL, postOpen, postPut, postReplayWALs, postScannerClose, postScannerFilterRow, postScannerNext, postScannerOpen, postStartRegionOperation, postStoreFileReaderOpen, postWALRestore, preAppend, preAppendAfterRowLock, preBatchMutate, preBulkLoadHFile, preCheckAndDelete, preCheckAndDeleteAfterRowLock, preCheckAndPut, preCheckAndPutAfterRowLock, preClose, preCompact, preCompactScannerOpen, preCompactSelection, href="../../../../../org/apache/hadoop/hbase/coprocessor/RegionObserver.html#preDelete-org.apache.hadoop.hbase.coprocessor.ObserverContext-org.apache.hadoop.hbase.client.Delete-org.apache.hadoop.hbase.wal.WALEdit-org.apache.hadoop.hbase.client.Durability-">preDelete, > href="../../../../../org/apache/hadoop/hbase/coprocessor/RegionObserver.html#preExists-org.apache.hadoop.hbase.coprocessor.ObserverContext-org.apache.hadoop.hbase.client.Get-boolean-">preExists, > href="../../../../../org/apache/hadoop/hbase/coprocessor/RegionObserver.html#preFlush-org.apache.hadoop.hbase.coprocessor.ObserverContext-">preFlush, > href="../../../../../org/apache/hadoop/hbase/coprocessor/RegionObserver.html#preFlush-org.apache.hadoop.hbase.coprocessor.ObserverContext-org.apache.hadoop.hbase.regionserver.Store-org.apache.hadoop.hbase.regionserver.InternalScanner-">preFlush, > href="../../../../../org/apache/hadoop/hbase/coprocessor/RegionObserver.html#preF lushScannerOpen-org.apache.hadoop.hbase.coprocessor.ObserverContext-org.apache.hadoop.hbase.regionserver.Store-java.util.List-org.apache.hadoop.hbase.regionserver.InternalScanner-long-">preFlushScannerOpen, preGetOp, preIncrement, preIncrementAfterRowLock, p reOpen, prePrepareTimeStampForDeleteVersion, prePut, preReplayWALs, preScannerClose, preScannerNext, preScannerOpen, preStoreFileReaderOpen< /a>, preStoreScannerOpen, preWALRestore http://git-wip-us.apache.org/repos/asf/hbase-site/blob/fa7d6c0c/devapidocs/org/apache/hadoop/hbase/backup/package-tree.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/backup/package-tree.html b/devapidocs/org/apache/hadoop/hbase/backup/package-tree.html index e7821df..42a6b9f 100644 --- a/devapidocs/org/apache/hadoop/hbase/backup/package-tree.html +++ b/devapidocs/org/apache/hadoop/hbase/backup/package-tree.html @@ -169,8 +169,8 @@ org.apache.hadoop.hbase.backup.BackupRestoreConstants.BackupCommand org.apache.hadoop.hbase.backup.BackupInfo.BackupPhase -org.apache.hadoop.hbase.backup.BackupInfo.BackupState org.apache.hadoop.hbase.backup.BackupType +org.apache.hadoop.hbase.backup.BackupInfo.BackupState
[28/51] [partial] hbase-site git commit: Published site at .
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/fa7d6c0c/devapidocs/org/apache/hadoop/hbase/security/access/AccessController.OpType.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/security/access/AccessController.OpType.html b/devapidocs/org/apache/hadoop/hbase/security/access/AccessController.OpType.html index 20c9a0a..0605e31 100644 --- a/devapidocs/org/apache/hadoop/hbase/security/access/AccessController.OpType.html +++ b/devapidocs/org/apache/hadoop/hbase/security/access/AccessController.OpType.html @@ -122,7 +122,7 @@ var activeTableTab = "activeTableTab"; -private static enum AccessController.OpType +private static enum AccessController.OpType extends http://docs.oracle.com/javase/8/docs/api/java/lang/Enum.html?is-external=true; title="class or interface in java.lang">EnumAccessController.OpType @@ -257,7 +257,7 @@ the order they are declared. GET -public static finalAccessController.OpType GET +public static finalAccessController.OpType GET @@ -266,7 +266,7 @@ the order they are declared. EXISTS -public static finalAccessController.OpType EXISTS +public static finalAccessController.OpType EXISTS @@ -275,7 +275,7 @@ the order they are declared. SCAN -public static finalAccessController.OpType SCAN +public static finalAccessController.OpType SCAN @@ -284,7 +284,7 @@ the order they are declared. PUT -public static finalAccessController.OpType PUT +public static finalAccessController.OpType PUT @@ -293,7 +293,7 @@ the order they are declared. DELETE -public static finalAccessController.OpType DELETE +public static finalAccessController.OpType DELETE @@ -302,7 +302,7 @@ the order they are declared. CHECK_AND_PUT -public static finalAccessController.OpType CHECK_AND_PUT +public static finalAccessController.OpType CHECK_AND_PUT @@ -311,7 +311,7 @@ the order they are declared. CHECK_AND_DELETE -public static finalAccessController.OpType CHECK_AND_DELETE +public static finalAccessController.OpType CHECK_AND_DELETE @@ -320,7 +320,7 @@ the order they are declared. INCREMENT_COLUMN_VALUE -public static finalAccessController.OpType INCREMENT_COLUMN_VALUE +public static finalAccessController.OpType INCREMENT_COLUMN_VALUE @@ -329,7 +329,7 @@ the order they are declared. APPEND -public static finalAccessController.OpType APPEND +public static finalAccessController.OpType APPEND @@ -338,7 +338,7 @@ the order they are declared. INCREMENT -public static finalAccessController.OpType INCREMENT +public static finalAccessController.OpType INCREMENT @@ -355,7 +355,7 @@ the order they are declared. type -privatehttp://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String type +privatehttp://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String type @@ -372,7 +372,7 @@ the order they are declared. values -public staticAccessController.OpType[]values() +public staticAccessController.OpType[]values() Returns an array containing the constants of this enum type, in the order they are declared. This method may be used to iterate over the constants as follows: @@ -392,7 +392,7 @@ for (AccessController.OpType c : AccessController.OpType.values()) valueOf -public staticAccessController.OpTypevalueOf(http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">Stringname) +public staticAccessController.OpTypevalueOf(http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">Stringname) Returns the enum constant of this type with the specified name. The string must match exactly an identifier used to declare an enum constant in this type. (Extraneous whitespace characters are @@ -414,7 +414,7 @@ not permitted.) toString -publichttp://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">StringtoString() +publichttp://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">StringtoString() Overrides: http://docs.oracle.com/javase/8/docs/api/java/lang/Enum.html?is-external=true#toString--; title="class or interface in java.lang">toStringin classhttp://docs.oracle.com/javase/8/docs/api/java/lang/Enum.html?is-external=true; title="class or interface in java.lang">EnumAccessController.OpType
[15/51] [partial] hbase-site git commit: Published site at .
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/fa7d6c0c/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RSRpcServices.RegionScannersCloseCallBack.html -- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RSRpcServices.RegionScannersCloseCallBack.html b/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RSRpcServices.RegionScannersCloseCallBack.html index e0b1774..f3d4c5e 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RSRpcServices.RegionScannersCloseCallBack.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RSRpcServices.RegionScannersCloseCallBack.html @@ -605,13 +605,13 @@ 597 * @param row 598 * @param family 599 * @param qualifier -600 * @param op +600 * @param compareOp 601 * @param comparator @throws IOException 602 */ 603 private boolean checkAndRowMutate(final Region region, final ListClientProtos.Action actions, -604 final CellScanner cellScanner, byte[] row, byte[] family, byte[] qualifier, -605 CompareOperator op, ByteArrayComparable comparator, RegionActionResult.Builder builder, -606 ActivePolicyEnforcement spaceQuotaEnforcement) throws IOException { +604final CellScanner cellScanner, byte[] row, byte[] family, byte[] qualifier, +605 CompareOperator op, ByteArrayComparable comparator, RegionActionResult.Builder builder, +606 ActivePolicyEnforcement spaceQuotaEnforcement) throws IOException { 607if (!region.getRegionInfo().isMetaTable()) { 608 regionServer.cacheFlusher.reclaimMemStoreMemory(); 609} @@ -656,2842 +656,2846 @@ 648 649 /** 650 * Execute an append mutation. -651 * @return result to return to client if default operation should be -652 * bypassed as indicated by RegionObserver, null otherwise -653 * @throws IOException -654 */ -655 private Result append(final Region region, final OperationQuota quota, -656 final MutationProto mutation, final CellScanner cellScanner, long nonceGroup, -657 ActivePolicyEnforcement spaceQuota) -658 throws IOException { -659long before = EnvironmentEdgeManager.currentTime(); -660Append append = ProtobufUtil.toAppend(mutation, cellScanner); -661checkCellSizeLimit(region, append); -662 spaceQuota.getPolicyEnforcement(region).check(append); -663quota.addMutation(append); -664Result r = null; -665if (region.getCoprocessorHost() != null) { -666 r = region.getCoprocessorHost().preAppend(append); -667} -668if (r == null) { -669 boolean canProceed = startNonceOperation(mutation, nonceGroup); -670 boolean success = false; -671 try { -672long nonce = mutation.hasNonce() ? mutation.getNonce() : HConstants.NO_NONCE; -673if (canProceed) { -674 r = region.append(append, nonceGroup, nonce); -675} else { -676 // convert duplicate append to get -677 ListCell results = region.get(ProtobufUtil.toGet(mutation, cellScanner), false, -678nonceGroup, nonce); -679 r = Result.create(results); -680} -681success = true; -682 } finally { -683if (canProceed) { -684 endNonceOperation(mutation, nonceGroup, success); -685} -686 } -687 if (region.getCoprocessorHost() != null) { -688r = region.getCoprocessorHost().postAppend(append, r); -689 } -690} -691if (regionServer.metricsRegionServer != null) { -692 regionServer.metricsRegionServer.updateAppend( -693 EnvironmentEdgeManager.currentTime() - before); +651 * +652 * @param region +653 * @param m +654 * @param cellScanner +655 * @return result to return to client if default operation should be +656 * bypassed as indicated by RegionObserver, null otherwise +657 * @throws IOException +658 */ +659 private Result append(final Region region, final OperationQuota quota, +660 final MutationProto mutation, final CellScanner cellScanner, long nonceGroup, +661 ActivePolicyEnforcement spaceQuota) +662 throws IOException { +663long before = EnvironmentEdgeManager.currentTime(); +664Append append = ProtobufUtil.toAppend(mutation, cellScanner); +665checkCellSizeLimit(region, append); +666 spaceQuota.getPolicyEnforcement(region).check(append); +667quota.addMutation(append); +668Result r = null; +669if (region.getCoprocessorHost() != null) { +670 r = region.getCoprocessorHost().preAppend(append); +671} +672if (r == null) { +673 boolean canProceed = startNonceOperation(mutation, nonceGroup); +674 boolean success = false; +675 try { +676long nonce = mutation.hasNonce() ? mutation.getNonce() : HConstants.NO_NONCE; +677if (canProceed) { +678 r =
[21/51] [partial] hbase-site git commit: Published site at .
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/fa7d6c0c/devapidocs/src-html/org/apache/hadoop/hbase/master/MasterCoprocessorHost.CoprocessorOperation.html -- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/master/MasterCoprocessorHost.CoprocessorOperation.html b/devapidocs/src-html/org/apache/hadoop/hbase/master/MasterCoprocessorHost.CoprocessorOperation.html index 4b35f07..2a29b1c 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/master/MasterCoprocessorHost.CoprocessorOperation.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/master/MasterCoprocessorHost.CoprocessorOperation.html @@ -36,35 +36,35 @@ 028import org.apache.commons.logging.LogFactory; 029import org.apache.hadoop.conf.Configuration; 030import org.apache.hadoop.hbase.Coprocessor; -031import org.apache.hadoop.hbase.HRegionInfo; -032import org.apache.hadoop.hbase.MetaMutationAnnotation; -033import org.apache.hadoop.hbase.NamespaceDescriptor; -034import org.apache.hadoop.hbase.ServerName; -035import org.apache.hadoop.hbase.TableName; -036import org.apache.yetus.audience.InterfaceAudience; -037import org.apache.hadoop.hbase.client.ColumnFamilyDescriptor; -038import org.apache.hadoop.hbase.client.MasterSwitchType; -039import org.apache.hadoop.hbase.client.Mutation; -040import org.apache.hadoop.hbase.client.TableDescriptor; -041import org.apache.hadoop.hbase.coprocessor.CoprocessorHost; -042import org.apache.hadoop.hbase.coprocessor.CoprocessorService; -043import org.apache.hadoop.hbase.coprocessor.MasterCoprocessorEnvironment; -044import org.apache.hadoop.hbase.coprocessor.MasterObserver; -045import org.apache.hadoop.hbase.coprocessor.MetricsCoprocessor; -046import org.apache.hadoop.hbase.coprocessor.ObserverContext; -047import org.apache.hadoop.hbase.ipc.RpcServer; -048import org.apache.hadoop.hbase.master.locking.LockProcedure; -049import org.apache.hadoop.hbase.master.procedure.MasterProcedureEnv; -050import org.apache.hadoop.hbase.metrics.MetricRegistry; -051import org.apache.hadoop.hbase.net.Address; -052import org.apache.hadoop.hbase.procedure2.LockType; -053import org.apache.hadoop.hbase.procedure2.LockedResource; -054import org.apache.hadoop.hbase.procedure2.Procedure; -055import org.apache.hadoop.hbase.procedure2.ProcedureExecutor; -056import org.apache.hadoop.hbase.replication.ReplicationPeerConfig; -057import org.apache.hadoop.hbase.security.User; -058import org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.Quotas; -059import org.apache.hadoop.hbase.shaded.protobuf.generated.SnapshotProtos.SnapshotDescription; +031import org.apache.hadoop.hbase.MetaMutationAnnotation; +032import org.apache.hadoop.hbase.NamespaceDescriptor; +033import org.apache.hadoop.hbase.ServerName; +034import org.apache.hadoop.hbase.TableName; +035import org.apache.hadoop.hbase.client.ColumnFamilyDescriptor; +036import org.apache.hadoop.hbase.client.MasterSwitchType; +037import org.apache.hadoop.hbase.client.Mutation; +038import org.apache.hadoop.hbase.client.RegionInfo; +039import org.apache.hadoop.hbase.client.TableDescriptor; +040import org.apache.hadoop.hbase.coprocessor.CoprocessorHost; +041import org.apache.hadoop.hbase.coprocessor.CoprocessorService; +042import org.apache.hadoop.hbase.coprocessor.MasterCoprocessorEnvironment; +043import org.apache.hadoop.hbase.coprocessor.MasterObserver; +044import org.apache.hadoop.hbase.coprocessor.MetricsCoprocessor; +045import org.apache.hadoop.hbase.coprocessor.ObserverContext; +046import org.apache.hadoop.hbase.ipc.RpcServer; +047import org.apache.hadoop.hbase.master.locking.LockProcedure; +048import org.apache.hadoop.hbase.master.procedure.MasterProcedureEnv; +049import org.apache.hadoop.hbase.metrics.MetricRegistry; +050import org.apache.hadoop.hbase.net.Address; +051import org.apache.hadoop.hbase.procedure2.LockType; +052import org.apache.hadoop.hbase.procedure2.LockedResource; +053import org.apache.hadoop.hbase.procedure2.Procedure; +054import org.apache.hadoop.hbase.procedure2.ProcedureExecutor; +055import org.apache.hadoop.hbase.replication.ReplicationPeerConfig; +056import org.apache.hadoop.hbase.security.User; +057import org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.Quotas; +058import org.apache.hadoop.hbase.shaded.protobuf.generated.SnapshotProtos.SnapshotDescription; +059import org.apache.yetus.audience.InterfaceAudience; 060 061/** 062 * Provides the coprocessor framework and environment for master oriented @@ -250,7 +250,7 @@ 242 243 /* Implementation of hooks for invoking MasterObservers */ 244 -245 public void preCreateTable(final TableDescriptor htd, final HRegionInfo[] regions) +245 public void preCreateTable(final TableDescriptor htd, final RegionInfo[] regions) 246 throws IOException { 247execOperation(coprocessors.isEmpty() ? null : new CoprocessorOperation() { 248 @Override @@
[13/51] [partial] hbase-site git commit: Published site at .
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/fa7d6c0c/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RSRpcServices.html -- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RSRpcServices.html b/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RSRpcServices.html index e0b1774..f3d4c5e 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RSRpcServices.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RSRpcServices.html @@ -605,13 +605,13 @@ 597 * @param row 598 * @param family 599 * @param qualifier -600 * @param op +600 * @param compareOp 601 * @param comparator @throws IOException 602 */ 603 private boolean checkAndRowMutate(final Region region, final ListClientProtos.Action actions, -604 final CellScanner cellScanner, byte[] row, byte[] family, byte[] qualifier, -605 CompareOperator op, ByteArrayComparable comparator, RegionActionResult.Builder builder, -606 ActivePolicyEnforcement spaceQuotaEnforcement) throws IOException { +604final CellScanner cellScanner, byte[] row, byte[] family, byte[] qualifier, +605 CompareOperator op, ByteArrayComparable comparator, RegionActionResult.Builder builder, +606 ActivePolicyEnforcement spaceQuotaEnforcement) throws IOException { 607if (!region.getRegionInfo().isMetaTable()) { 608 regionServer.cacheFlusher.reclaimMemStoreMemory(); 609} @@ -656,2842 +656,2846 @@ 648 649 /** 650 * Execute an append mutation. -651 * @return result to return to client if default operation should be -652 * bypassed as indicated by RegionObserver, null otherwise -653 * @throws IOException -654 */ -655 private Result append(final Region region, final OperationQuota quota, -656 final MutationProto mutation, final CellScanner cellScanner, long nonceGroup, -657 ActivePolicyEnforcement spaceQuota) -658 throws IOException { -659long before = EnvironmentEdgeManager.currentTime(); -660Append append = ProtobufUtil.toAppend(mutation, cellScanner); -661checkCellSizeLimit(region, append); -662 spaceQuota.getPolicyEnforcement(region).check(append); -663quota.addMutation(append); -664Result r = null; -665if (region.getCoprocessorHost() != null) { -666 r = region.getCoprocessorHost().preAppend(append); -667} -668if (r == null) { -669 boolean canProceed = startNonceOperation(mutation, nonceGroup); -670 boolean success = false; -671 try { -672long nonce = mutation.hasNonce() ? mutation.getNonce() : HConstants.NO_NONCE; -673if (canProceed) { -674 r = region.append(append, nonceGroup, nonce); -675} else { -676 // convert duplicate append to get -677 ListCell results = region.get(ProtobufUtil.toGet(mutation, cellScanner), false, -678nonceGroup, nonce); -679 r = Result.create(results); -680} -681success = true; -682 } finally { -683if (canProceed) { -684 endNonceOperation(mutation, nonceGroup, success); -685} -686 } -687 if (region.getCoprocessorHost() != null) { -688r = region.getCoprocessorHost().postAppend(append, r); -689 } -690} -691if (regionServer.metricsRegionServer != null) { -692 regionServer.metricsRegionServer.updateAppend( -693 EnvironmentEdgeManager.currentTime() - before); +651 * +652 * @param region +653 * @param m +654 * @param cellScanner +655 * @return result to return to client if default operation should be +656 * bypassed as indicated by RegionObserver, null otherwise +657 * @throws IOException +658 */ +659 private Result append(final Region region, final OperationQuota quota, +660 final MutationProto mutation, final CellScanner cellScanner, long nonceGroup, +661 ActivePolicyEnforcement spaceQuota) +662 throws IOException { +663long before = EnvironmentEdgeManager.currentTime(); +664Append append = ProtobufUtil.toAppend(mutation, cellScanner); +665checkCellSizeLimit(region, append); +666 spaceQuota.getPolicyEnforcement(region).check(append); +667quota.addMutation(append); +668Result r = null; +669if (region.getCoprocessorHost() != null) { +670 r = region.getCoprocessorHost().preAppend(append); +671} +672if (r == null) { +673 boolean canProceed = startNonceOperation(mutation, nonceGroup); +674 boolean success = false; +675 try { +676long nonce = mutation.hasNonce() ? mutation.getNonce() : HConstants.NO_NONCE; +677if (canProceed) { +678 r = region.append(append, nonceGroup, nonce); +679} else { +680 // convert duplicate append to get +681 ListCell results =
[39/51] [partial] hbase-site git commit: Published site at .
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/fa7d6c0c/devapidocs/org/apache/hadoop/hbase/coprocessor/class-use/ObserverContext.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/coprocessor/class-use/ObserverContext.html b/devapidocs/org/apache/hadoop/hbase/coprocessor/class-use/ObserverContext.html index 8a5b494..b175474 100644 --- a/devapidocs/org/apache/hadoop/hbase/coprocessor/class-use/ObserverContext.html +++ b/devapidocs/org/apache/hadoop/hbase/coprocessor/class-use/ObserverContext.html @@ -285,8 +285,8 @@ default void -MasterObserver.postAssign(ObserverContextMasterCoprocessorEnvironmentctx, - HRegionInforegionInfo) +MasterObserver.postAssign(ObserverContextMasterCoprocessorEnvironmentctx, + RegionInforegionInfo) Called after the region assignment has been requested. @@ -436,9 +436,9 @@ default void -MasterObserver.postCompletedCreateTableAction(ObserverContextMasterCoprocessorEnvironmentctx, +MasterObserver.postCompletedCreateTableAction(ObserverContextMasterCoprocessorEnvironmentctx, TableDescriptordesc, - HRegionInfo[]regions) + RegionInfo[]regions) Called after the createTable operation has been requested. @@ -474,9 +474,9 @@ default void -MasterObserver.postCompletedMergeRegionsAction(ObserverContextMasterCoprocessorEnvironmentctx, - HRegionInfo[]regionsToMerge, - HRegionInfomergedRegion) +MasterObserver.postCompletedMergeRegionsAction(ObserverContextMasterCoprocessorEnvironmentctx, + RegionInfo[]regionsToMerge, + RegionInfomergedRegion) called after the regions merge. @@ -498,9 +498,9 @@ default void -MasterObserver.postCompletedSplitRegionAction(ObserverContextMasterCoprocessorEnvironmentc, - HRegionInforegionInfoA, - HRegionInforegionInfoB) +MasterObserver.postCompletedSplitRegionAction(ObserverContextMasterCoprocessorEnvironmentc, + RegionInforegionInfoA, + RegionInforegionInfoB) Called after the region is split. @@ -528,9 +528,9 @@ default void -MasterObserver.postCreateTable(ObserverContextMasterCoprocessorEnvironmentctx, +MasterObserver.postCreateTable(ObserverContextMasterCoprocessorEnvironmentctx, TableDescriptordesc, - HRegionInfo[]regions) + RegionInfo[]regions) Called after the createTable operation has been requested. @@ -743,16 +743,16 @@ default void -MasterObserver.postMergeRegions(ObserverContextMasterCoprocessorEnvironmentc, -HRegionInfo[]regionsToMerge) +MasterObserver.postMergeRegions(ObserverContextMasterCoprocessorEnvironmentc, +RegionInfo[]regionsToMerge) called after merge regions request. default void -MasterObserver.postMergeRegionsCommitAction(ObserverContextMasterCoprocessorEnvironmentctx, -HRegionInfo[]regionsToMerge, -HRegionInfomergedRegion) +MasterObserver.postMergeRegionsCommitAction(ObserverContextMasterCoprocessorEnvironmentctx, +RegionInfo[]regionsToMerge, +RegionInfomergedRegion) This will be called after PONR step as part of regions merge transaction. @@ -781,8 +781,8 @@ default void -MasterObserver.postMove(ObserverContextMasterCoprocessorEnvironmentctx, -HRegionInforegion, +MasterObserver.postMove(ObserverContextMasterCoprocessorEnvironmentctx, +RegionInforegion, ServerNamesrcServer, ServerNamedestServer) Called after the region move has been requested. @@ -841,8 +841,8 @@ default void -MasterObserver.postRegionOffline(ObserverContextMasterCoprocessorEnvironmentctx, - HRegionInforegionInfo) +MasterObserver.postRegionOffline(ObserverContextMasterCoprocessorEnvironmentctx, + RegionInforegionInfo) Called after the region has been marked offline. @@ -862,8 +862,8 @@ default void -RegionObserver.postReplayWALs(ObserverContext? extends RegionCoprocessorEnvironmentctx, - HRegionInfoinfo, +RegionObserver.postReplayWALs(ObserverContext? extends RegionCoprocessorEnvironmentctx, + RegionInfoinfo, org.apache.hadoop.fs.Pathedits) Called after replaying WALs for this region. @@ -878,10 +878,10 @@ default void -MasterObserver.postRequestLock(ObserverContextMasterCoprocessorEnvironmentctx, +MasterObserver.postRequestLock(ObserverContextMasterCoprocessorEnvironmentctx, http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">Stringnamespace, TableNametableName, -
[43/51] [partial] hbase-site git commit: Published site at .
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/fa7d6c0c/devapidocs/org/apache/hadoop/hbase/client/class-use/TableDescriptor.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/client/class-use/TableDescriptor.html b/devapidocs/org/apache/hadoop/hbase/client/class-use/TableDescriptor.html index 5f0110f..b687cd9 100644 --- a/devapidocs/org/apache/hadoop/hbase/client/class-use/TableDescriptor.html +++ b/devapidocs/org/apache/hadoop/hbase/client/class-use/TableDescriptor.html @@ -887,9 +887,9 @@ Input/OutputFormats, a table indexing MapReduce job, and utility methods. default void -MasterObserver.postCompletedCreateTableAction(ObserverContextMasterCoprocessorEnvironmentctx, +MasterObserver.postCompletedCreateTableAction(ObserverContextMasterCoprocessorEnvironmentctx, TableDescriptordesc, - HRegionInfo[]regions) + RegionInfo[]regions) Called after the createTable operation has been requested. @@ -903,9 +903,9 @@ Input/OutputFormats, a table indexing MapReduce job, and utility methods. default void -MasterObserver.postCreateTable(ObserverContextMasterCoprocessorEnvironmentctx, +MasterObserver.postCreateTable(ObserverContextMasterCoprocessorEnvironmentctx, TableDescriptordesc, - HRegionInfo[]regions) + RegionInfo[]regions) Called after the createTable operation has been requested. @@ -943,18 +943,18 @@ Input/OutputFormats, a table indexing MapReduce job, and utility methods. default void -MasterObserver.preCreateTable(ObserverContextMasterCoprocessorEnvironmentctx, +MasterObserver.preCreateTable(ObserverContextMasterCoprocessorEnvironmentctx, TableDescriptordesc, - HRegionInfo[]regions) + RegionInfo[]regions) Called before a new table is created by HMaster. default void -MasterObserver.preCreateTableAction(ObserverContextMasterCoprocessorEnvironmentctx, +MasterObserver.preCreateTableAction(ObserverContextMasterCoprocessorEnvironmentctx, TableDescriptordesc, -HRegionInfo[]regions) +RegionInfo[]regions) Called before a new table is created by HMaster. @@ -1050,15 +1050,15 @@ Input/OutputFormats, a table indexing MapReduce job, and utility methods. void -ExampleMasterObserverWithMetrics.postCreateTable(ObserverContextMasterCoprocessorEnvironmentctx, +ExampleMasterObserverWithMetrics.postCreateTable(ObserverContextMasterCoprocessorEnvironmentctx, TableDescriptordesc, - HRegionInfo[]regions) + RegionInfo[]regions) void -ExampleMasterObserverWithMetrics.preCreateTable(ObserverContextMasterCoprocessorEnvironmentctx, +ExampleMasterObserverWithMetrics.preCreateTable(ObserverContextMasterCoprocessorEnvironmentctx, TableDescriptordesc, - HRegionInfo[]regions) + RegionInfo[]regions) @@ -1297,8 +1297,8 @@ Input/OutputFormats, a table indexing MapReduce job, and utility methods. void -MasterCoprocessorHost.postCompletedCreateTableAction(TableDescriptorhtd, - HRegionInfo[]regions, +MasterCoprocessorHost.postCompletedCreateTableAction(TableDescriptorhtd, + RegionInfo[]regions, Useruser) @@ -1309,8 +1309,8 @@ Input/OutputFormats, a table indexing MapReduce job, and utility methods. void -MasterCoprocessorHost.postCreateTable(TableDescriptorhtd, - HRegionInfo[]regions) +MasterCoprocessorHost.postCreateTable(TableDescriptorhtd, + RegionInfo[]regions) void @@ -1334,13 +1334,13 @@ Input/OutputFormats, a table indexing MapReduce job, and utility methods. void -MasterCoprocessorHost.preCreateTable(TableDescriptorhtd, - HRegionInfo[]regions) +MasterCoprocessorHost.preCreateTable(TableDescriptorhtd, + RegionInfo[]regions) void -MasterCoprocessorHost.preCreateTableAction(TableDescriptorhtd, -HRegionInfo[]regions, +MasterCoprocessorHost.preCreateTableAction(TableDescriptorhtd, +RegionInfo[]regions, Useruser) @@ -2144,9 +2144,9 @@ Input/OutputFormats, a table indexing MapReduce job, and utility methods. void -RSGroupAdminEndpoint.preCreateTable(ObserverContextMasterCoprocessorEnvironmentctx, +RSGroupAdminEndpoint.preCreateTable(ObserverContextMasterCoprocessorEnvironmentctx, TableDescriptordesc, - HRegionInfo[]regions) + RegionInfo[]regions) @@ -2170,9 +2170,9 @@ Input/OutputFormats, a table indexing MapReduce job, and utility methods. void -AccessController.postCompletedCreateTableAction(ObserverContextMasterCoprocessorEnvironmentc,
[35/51] [partial] hbase-site git commit: Published site at .
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/fa7d6c0c/devapidocs/org/apache/hadoop/hbase/master/MasterCoprocessorHost.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/master/MasterCoprocessorHost.html b/devapidocs/org/apache/hadoop/hbase/master/MasterCoprocessorHost.html index 3714275..d17f758 100644 --- a/devapidocs/org/apache/hadoop/hbase/master/MasterCoprocessorHost.html +++ b/devapidocs/org/apache/hadoop/hbase/master/MasterCoprocessorHost.html @@ -269,7 +269,7 @@ extends void -postAssign(HRegionInforegionInfo) +postAssign(RegionInforegionInfo) void @@ -302,8 +302,8 @@ extends void -postCompletedCreateTableAction(TableDescriptorhtd, - HRegionInfo[]regions, +postCompletedCreateTableAction(TableDescriptorhtd, + RegionInfo[]regions, Useruser) @@ -329,8 +329,8 @@ extends void -postCompletedMergeRegionsAction(HRegionInfo[]regionsToMerge, - HRegionInfomergedRegion, +postCompletedMergeRegionsAction(RegionInfo[]regionsToMerge, + RegionInfomergedRegion, Useruser) Invoked after completing merge regions operation @@ -349,8 +349,8 @@ extends void -postCompletedSplitRegionAction(HRegionInforegionInfoA, - HRegionInforegionInfoB, +postCompletedSplitRegionAction(RegionInforegionInfoA, + RegionInforegionInfoB, Useruser) Invoked just after a split @@ -366,8 +366,8 @@ extends void -postCreateTable(TableDescriptorhtd, - HRegionInfo[]regions) +postCreateTable(TableDescriptorhtd, + RegionInfo[]regions) void @@ -452,12 +452,12 @@ extends void -postMergeRegions(HRegionInfo[]regionsToMerge) +postMergeRegions(RegionInfo[]regionsToMerge) void -postMergeRegionsCommit(HRegionInfo[]regionsToMerge, - HRegionInfomergedRegion, +postMergeRegionsCommit(RegionInfo[]regionsToMerge, + RegionInfomergedRegion, Useruser) Invoked after merge regions operation writes the new region to hbase:meta @@ -478,7 +478,7 @@ extends void -postMove(HRegionInforegion, +postMove(RegionInforegion, ServerNamesrcServer, ServerNamedestServer) @@ -500,7 +500,7 @@ extends void -postRegionOffline(HRegionInforegionInfo) +postRegionOffline(RegionInforegionInfo) void @@ -512,9 +512,9 @@ extends void -postRequestLock(http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">Stringnamespace, +postRequestLock(http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">Stringnamespace, TableNametableName, - HRegionInfo[]regionInfos, + RegionInfo[]regionInfos, LockTypetype, http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">Stringdescription) @@ -525,7 +525,7 @@ extends void -postRollBackMergeRegionsAction(HRegionInfo[]regionsToMerge, +postRollBackMergeRegionsAction(RegionInfo[]regionsToMerge, Useruser) Invoked after rollback merge regions operation @@ -587,7 +587,7 @@ extends void -postUnassign(HRegionInforegionInfo, +postUnassign(RegionInforegionInfo, booleanforce) @@ -622,7 +622,7 @@ extends boolean -preAssign(HRegionInforegionInfo) +preAssign(RegionInforegionInfo) boolean @@ -651,13 +651,13 @@ extends void -preCreateTable(TableDescriptorhtd, - HRegionInfo[]regions) +preCreateTable(TableDescriptorhtd, + RegionInfo[]regions) void -preCreateTableAction(TableDescriptorhtd, -HRegionInfo[]regions, +preCreateTableAction(TableDescriptorhtd, +RegionInfo[]regions, Useruser) @@ -768,18 +768,18 @@ extends void -preMergeRegions(HRegionInfo[]regionsToMerge) +preMergeRegions(RegionInfo[]regionsToMerge) boolean -preMergeRegionsAction(HRegionInfo[]regionsToMerge, +preMergeRegionsAction(RegionInfo[]regionsToMerge, Useruser) Invoked just before a merge boolean -preMergeRegionsCommit(HRegionInfo[]regionsToMerge, +preMergeRegionsCommit(RegionInfo[]regionsToMerge, http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true; title="class or interface in java.util">ListMutationmetaEntries, Useruser) Invoked before merge regions operation writes the new region to hbase:meta @@ -813,7 +813,7 @@ extends boolean -preMove(HRegionInforegion, +preMove(RegionInforegion, ServerNamesrcServer, ServerNamedestServer) @@ -835,7 +835,7 @@ extends
[23/51] [partial] hbase-site git commit: Published site at .
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/fa7d6c0c/devapidocs/org/apache/hadoop/hbase/thrift/package-tree.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/thrift/package-tree.html b/devapidocs/org/apache/hadoop/hbase/thrift/package-tree.html index 06ce7fd..59ab0ce 100644 --- a/devapidocs/org/apache/hadoop/hbase/thrift/package-tree.html +++ b/devapidocs/org/apache/hadoop/hbase/thrift/package-tree.html @@ -199,8 +199,8 @@ java.lang.http://docs.oracle.com/javase/8/docs/api/java/lang/Enum.html?is-external=true; title="class or interface in java.lang">EnumE (implements java.lang.http://docs.oracle.com/javase/8/docs/api/java/lang/Comparable.html?is-external=true; title="class or interface in java.lang">ComparableT, java.io.http://docs.oracle.com/javase/8/docs/api/java/io/Serializable.html?is-external=true; title="class or interface in java.io">Serializable) org.apache.hadoop.hbase.thrift.MetricsThriftServerSourceFactoryImpl.FactoryStorage -org.apache.hadoop.hbase.thrift.ThriftMetrics.ThriftServerType org.apache.hadoop.hbase.thrift.ThriftServerRunner.ImplType +org.apache.hadoop.hbase.thrift.ThriftMetrics.ThriftServerType http://git-wip-us.apache.org/repos/asf/hbase-site/blob/fa7d6c0c/devapidocs/org/apache/hadoop/hbase/tool/WriteSinkCoprocessor.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/tool/WriteSinkCoprocessor.html b/devapidocs/org/apache/hadoop/hbase/tool/WriteSinkCoprocessor.html index 2b42d10..4b59138 100644 --- a/devapidocs/org/apache/hadoop/hbase/tool/WriteSinkCoprocessor.html +++ b/devapidocs/org/apache/hadoop/hbase/tool/WriteSinkCoprocessor.html @@ -258,7 +258,7 @@ implements RegionObserver -postAppend, postBatchMutate, postBatchMutateIndispensably, postBulkLoadHFile, postCheckAndDelete, postCheckAndPut, postClose, postCloseRegionOperation, postCommitStoreFile, postCompact, postCompactSelection, postDelete, postExists, postFlush, postFlush, postGetOp, postIncrement, postInstantiateDeleteTracker, postLogReplay, postMutationBeforeWAL, postOpen, postPut, postReplayWALs, postScannerClose, postScannerFilterRow, postScannerNext, postScannerOpen, postStartRegion Operation, postStoreFileReaderOpen, postWALRestore, preAppend, preAppendAfterRowLock, preBulkLoadHFile, preCheckAndDelete, preCh eckAndDeleteAfterRowLock, preCheckAndPut, preCheckAndPutAfterRowLock, preClose, preCommitStoreFile, preCompact, preCompactScannerOpen, preCompactSelection, preDelete, preExists, preFlush, preFlush, preFlushScannerOpen, preGetOp, preIncrement, preIncrem entAfterRowLock, prePrepareTimeStampForDeleteVersion, prePut, preReplayWALs, preScannerClose, preScannerNext, preScannerOpen, preStoreFileReaderOp en, preStoreScannerOpen, preWALRestore +postAppend, postBatchMutate, postBatchMutateIndispensably, postBulkLoadHFile, postCheckAndDelete, postCheckAndPut, postClose, postCloseRegionOperation, postCommitStoreFile, postCompact, postCompactSelection, postDelete, postExists, postFlush, postFlush, postGetOp, postIncrement, postInstantiateDeleteTracker, postLogReplay, postMutationBeforeWAL, postOpen, postPut, postReplayWALs, postScannerClose, postScannerFilterRow, postScannerNext, postScannerOpen, postStart RegionOperation, postStoreFileReaderOpen, postWALRestore, preAppend, preAppendAfterRowLock, preBulkLoadHFile, preCheckAndDelete, preCheckAndDeleteAfterRowLock, preCheckAndPut, preCheckAndPutAfterRowLock, preClose, preCommitStoreFile, preCompact, preCompactScannerOpen, preCompactSelection, preDelete, preExists, preFlush, preFlush, preFlushScannerOpen, preGetOp, preIncrement, preIncrementAfterRowLock, prePrepareTimeStampForDeleteVersion, prePut, preReplayWALs, preScannerClose, preScannerNext, preScannerOpen, pr eStoreFileReaderOpen, preStoreScannerOpen, preWALRestore http://git-wip-us.apache.org/repos/asf/hbase-site/blob/fa7d6c0c/devapidocs/org/apache/hadoop/hbase/util/package-tree.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/util/package-tree.html b/devapidocs/org/apache/hadoop/hbase/util/package-tree.html index 76fefd8..e0df257 100644 --- a/devapidocs/org/apache/hadoop/hbase/util/package-tree.html +++ b/devapidocs/org/apache/hadoop/hbase/util/package-tree.html @@ -522,13 +522,13 @@ java.lang.http://docs.oracle.com/javase/8/docs/api/java/lang/Enum.html?is-external=true; title="class or interface in java.lang">EnumE (implements java.lang.http://docs.oracle.com/javase/8/docs/api/java/lang/Comparable.html?is-external=true; title="class or interface in java.lang">ComparableT, java.io.http://docs.oracle.com/javase/8/docs/api/java/io/Serializable.html?is-external=true; title="class or interface in java.io">Serializable)
[50/51] [partial] hbase-site git commit: Published site at .
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/fa7d6c0c/checkstyle-aggregate.html -- diff --git a/checkstyle-aggregate.html b/checkstyle-aggregate.html index 2fd9d84..487706e 100644 --- a/checkstyle-aggregate.html +++ b/checkstyle-aggregate.html @@ -7,7 +7,7 @@ - + Apache HBase Checkstyle Results @@ -289,7 +289,7 @@ 2042 0 0 -14017 +14003 Files @@ -689,1297 +689,1287 @@ 0 1 -org/apache/hadoop/hbase/backup/BackupObserver.java -0 -0 -1 - org/apache/hadoop/hbase/backup/BackupRestoreConstants.java 0 0 5 - + org/apache/hadoop/hbase/backup/BackupRestoreFactory.java 0 0 1 - + org/apache/hadoop/hbase/backup/BackupTableInfo.java 0 0 2 - + org/apache/hadoop/hbase/backup/FailedArchiveException.java 0 0 1 - + org/apache/hadoop/hbase/backup/HBackupFileSystem.java 0 0 1 - + org/apache/hadoop/hbase/backup/HFileArchiver.java 0 0 21 - + org/apache/hadoop/hbase/backup/LogUtils.java 0 0 2 - + org/apache/hadoop/hbase/backup/RestoreDriver.java 0 0 2 - + org/apache/hadoop/hbase/backup/RestoreJob.java 0 0 1 - + org/apache/hadoop/hbase/backup/RestoreRequest.java 0 0 1 - + org/apache/hadoop/hbase/backup/example/HFileArchiveManager.java 0 0 4 - + org/apache/hadoop/hbase/backup/example/LongTermArchivingHFileCleaner.java 0 0 5 - + org/apache/hadoop/hbase/backup/example/TableHFileArchiveTracker.java 0 0 6 - + org/apache/hadoop/hbase/backup/example/ZKTableArchiveClient.java 0 0 2 - + org/apache/hadoop/hbase/backup/impl/BackupAdminImpl.java 0 0 14 - + org/apache/hadoop/hbase/backup/impl/BackupCommands.java 0 0 56 - + org/apache/hadoop/hbase/backup/impl/BackupManager.java 0 0 5 - + org/apache/hadoop/hbase/backup/impl/BackupManifest.java 0 0 3 - + org/apache/hadoop/hbase/backup/impl/BackupSystemTable.java 0 0 26 - + org/apache/hadoop/hbase/backup/impl/FullTableBackupClient.java 0 0 3 - + org/apache/hadoop/hbase/backup/impl/IncrementalBackupManager.java 0 0 5 - + org/apache/hadoop/hbase/backup/impl/IncrementalTableBackupClient.java 0 0 6 - + org/apache/hadoop/hbase/backup/impl/RestoreTablesClient.java 0 0 2 - + org/apache/hadoop/hbase/backup/impl/TableBackupClient.java 0 0 14 - + org/apache/hadoop/hbase/backup/mapreduce/MapReduceBackupCopyJob.java 0 0 1 - + org/apache/hadoop/hbase/backup/mapreduce/MapReduceBackupMergeJob.java 0 0 2 - + org/apache/hadoop/hbase/backup/mapreduce/MapReduceHFileSplitterJob.java 0 0 1 - + org/apache/hadoop/hbase/backup/mapreduce/MapReduceRestoreJob.java 0 0 4 - + org/apache/hadoop/hbase/backup/master/BackupLogCleaner.java 0 0 1 - + org/apache/hadoop/hbase/backup/master/LogRollMasterProcedureManager.java 0 0 2 - + org/apache/hadoop/hbase/backup/regionserver/LogRollBackupSubprocedure.java 0 0 3 - + org/apache/hadoop/hbase/backup/regionserver/LogRollBackupSubprocedurePool.java 0 0 1 - + org/apache/hadoop/hbase/backup/regionserver/LogRollRegionServerProcedureManager.java 0 0 1 - + org/apache/hadoop/hbase/backup/util/BackupUtils.java 0 0 6 - + org/apache/hadoop/hbase/backup/util/RestoreTool.java 0 0 4 - + org/apache/hadoop/hbase/client/AbstractClientScanner.java 0 0 1 - + org/apache/hadoop/hbase/client/AbstractResponse.java 0 0 2 - + org/apache/hadoop/hbase/client/Action.java 0 0 2 - + org/apache/hadoop/hbase/client/Admin.java 0 0 121 - + org/apache/hadoop/hbase/client/Append.java 0 0 6 - + org/apache/hadoop/hbase/client/AsyncAdmin.java 0 0 22 - + org/apache/hadoop/hbase/client/AsyncAdminBuilder.java 0 0 9 - + org/apache/hadoop/hbase/client/AsyncAdminRequestRetryingCaller.java 0 0 2 - + org/apache/hadoop/hbase/client/AsyncBatchRpcRetryingCaller.java 0 0 5 - + org/apache/hadoop/hbase/client/AsyncClientScanner.java 0 0 6 - + org/apache/hadoop/hbase/client/AsyncConnection.java 0 0 1 - + org/apache/hadoop/hbase/client/AsyncConnectionConfiguration.java 0 0 1 - + org/apache/hadoop/hbase/client/AsyncConnectionImpl.java 0 0 2 - + org/apache/hadoop/hbase/client/AsyncHBaseAdmin.java 0 0 4 - + org/apache/hadoop/hbase/client/AsyncMasterRequestRpcRetryingCaller.java 0 0 2 - + org/apache/hadoop/hbase/client/AsyncMetaRegionLocator.java 0 0 1 - + org/apache/hadoop/hbase/client/AsyncNonMetaRegionLocator.java 0 0 7 - + org/apache/hadoop/hbase/client/AsyncProcess.java 0 0 13 - + org/apache/hadoop/hbase/client/AsyncProcessTask.java 0 0 2 - + org/apache/hadoop/hbase/client/AsyncRegionLocator.java 0 0 2 - + org/apache/hadoop/hbase/client/AsyncRegistryFactory.java 0 0 1 - + org/apache/hadoop/hbase/client/AsyncRequestFuture.java 0 0 1 - + org/apache/hadoop/hbase/client/AsyncRequestFutureImpl.java 0 0 26 - + org/apache/hadoop/hbase/client/AsyncRpcRetryingCaller.java 0 0 3 - + org/apache/hadoop/hbase/client/AsyncRpcRetryingCallerFactory.java 0 0 4 - +
[38/51] [partial] hbase-site git commit: Published site at .
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/fa7d6c0c/devapidocs/org/apache/hadoop/hbase/coprocessor/class-use/RegionCoprocessorEnvironment.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/coprocessor/class-use/RegionCoprocessorEnvironment.html b/devapidocs/org/apache/hadoop/hbase/coprocessor/class-use/RegionCoprocessorEnvironment.html index ac8cae0..e9dcde2 100644 --- a/devapidocs/org/apache/hadoop/hbase/coprocessor/class-use/RegionCoprocessorEnvironment.html +++ b/devapidocs/org/apache/hadoop/hbase/coprocessor/class-use/RegionCoprocessorEnvironment.html @@ -417,8 +417,8 @@ default void -RegionObserver.postReplayWALs(ObserverContext? extends RegionCoprocessorEnvironmentctx, - HRegionInfoinfo, +RegionObserver.postReplayWALs(ObserverContext? extends RegionCoprocessorEnvironmentctx, + RegionInfoinfo, org.apache.hadoop.fs.Pathedits) Called after replaying WALs for this region. @@ -483,8 +483,8 @@ default void -RegionObserver.postWALRestore(ObserverContext? extends RegionCoprocessorEnvironmentctx, - HRegionInfoinfo, +RegionObserver.postWALRestore(ObserverContext? extends RegionCoprocessorEnvironmentctx, + RegionInfoinfo, WALKeylogKey, WALEditlogEdit) Called after a WALEdit @@ -735,8 +735,8 @@ default void -RegionObserver.preReplayWALs(ObserverContext? extends RegionCoprocessorEnvironmentctx, - HRegionInfoinfo, +RegionObserver.preReplayWALs(ObserverContext? extends RegionCoprocessorEnvironmentctx, + RegionInfoinfo, org.apache.hadoop.fs.Pathedits) Called before replaying WALs for this region. @@ -794,8 +794,8 @@ default void -RegionObserver.preWALRestore(ObserverContext? extends RegionCoprocessorEnvironmentctx, - HRegionInfoinfo, +RegionObserver.preWALRestore(ObserverContext? extends RegionCoprocessorEnvironmentctx, + RegionInfoinfo, WALKeylogKey, WALEditlogEdit) Called before a WALEdit http://git-wip-us.apache.org/repos/asf/hbase-site/blob/fa7d6c0c/devapidocs/org/apache/hadoop/hbase/coprocessor/class-use/WALCoprocessorEnvironment.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/coprocessor/class-use/WALCoprocessorEnvironment.html b/devapidocs/org/apache/hadoop/hbase/coprocessor/class-use/WALCoprocessorEnvironment.html index 3bc8cbb..f981569 100644 --- a/devapidocs/org/apache/hadoop/hbase/coprocessor/class-use/WALCoprocessorEnvironment.html +++ b/devapidocs/org/apache/hadoop/hbase/coprocessor/class-use/WALCoprocessorEnvironment.html @@ -118,8 +118,8 @@ default void -WALObserver.postWALWrite(ObserverContext? extends WALCoprocessorEnvironmentctx, -HRegionInfoinfo, +WALObserver.postWALWrite(ObserverContext? extends WALCoprocessorEnvironmentctx, +RegionInfoinfo, WALKeylogKey, WALEditlogEdit) Called after a WALEdit @@ -136,8 +136,8 @@ default boolean -WALObserver.preWALWrite(ObserverContext? extends WALCoprocessorEnvironmentctx, - HRegionInfoinfo, +WALObserver.preWALWrite(ObserverContext? extends WALCoprocessorEnvironmentctx, + RegionInfoinfo, WALKeylogKey, WALEditlogEdit) Called before a WALEdit
[22/51] [partial] hbase-site git commit: Published site at .
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/fa7d6c0c/devapidocs/src-html/org/apache/hadoop/hbase/coprocessor/MasterObserver.html -- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/coprocessor/MasterObserver.html b/devapidocs/src-html/org/apache/hadoop/hbase/coprocessor/MasterObserver.html index 86eb98f..06c94bc 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/coprocessor/MasterObserver.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/coprocessor/MasterObserver.html @@ -33,28 +33,28 @@ 025 026import org.apache.hadoop.hbase.Coprocessor; 027import org.apache.hadoop.hbase.HBaseInterfaceAudience; -028import org.apache.hadoop.hbase.HRegionInfo; -029import org.apache.hadoop.hbase.MetaMutationAnnotation; -030import org.apache.hadoop.hbase.NamespaceDescriptor; -031import org.apache.hadoop.hbase.ServerName; -032import org.apache.hadoop.hbase.TableName; -033import org.apache.yetus.audience.InterfaceAudience; -034import org.apache.yetus.audience.InterfaceStability; -035import org.apache.hadoop.hbase.client.ColumnFamilyDescriptor; -036import org.apache.hadoop.hbase.client.MasterSwitchType; -037import org.apache.hadoop.hbase.client.Mutation; -038import org.apache.hadoop.hbase.client.TableDescriptor; -039import org.apache.hadoop.hbase.master.RegionPlan; -040import org.apache.hadoop.hbase.master.locking.LockProcedure; -041import org.apache.hadoop.hbase.master.procedure.MasterProcedureEnv; -042import org.apache.hadoop.hbase.net.Address; -043import org.apache.hadoop.hbase.procedure2.LockType; -044import org.apache.hadoop.hbase.procedure2.LockedResource; -045import org.apache.hadoop.hbase.procedure2.Procedure; -046import org.apache.hadoop.hbase.procedure2.ProcedureExecutor; -047import org.apache.hadoop.hbase.replication.ReplicationPeerConfig; -048import org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.Quotas; -049import org.apache.hadoop.hbase.shaded.protobuf.generated.SnapshotProtos.SnapshotDescription; +028import org.apache.hadoop.hbase.MetaMutationAnnotation; +029import org.apache.hadoop.hbase.NamespaceDescriptor; +030import org.apache.hadoop.hbase.ServerName; +031import org.apache.hadoop.hbase.TableName; +032import org.apache.hadoop.hbase.client.ColumnFamilyDescriptor; +033import org.apache.hadoop.hbase.client.MasterSwitchType; +034import org.apache.hadoop.hbase.client.Mutation; +035import org.apache.hadoop.hbase.client.RegionInfo; +036import org.apache.hadoop.hbase.client.TableDescriptor; +037import org.apache.hadoop.hbase.master.RegionPlan; +038import org.apache.hadoop.hbase.master.locking.LockProcedure; +039import org.apache.hadoop.hbase.master.procedure.MasterProcedureEnv; +040import org.apache.hadoop.hbase.net.Address; +041import org.apache.hadoop.hbase.procedure2.LockType; +042import org.apache.hadoop.hbase.procedure2.LockedResource; +043import org.apache.hadoop.hbase.procedure2.Procedure; +044import org.apache.hadoop.hbase.procedure2.ProcedureExecutor; +045import org.apache.hadoop.hbase.replication.ReplicationPeerConfig; +046import org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.Quotas; +047import org.apache.hadoop.hbase.shaded.protobuf.generated.SnapshotProtos.SnapshotDescription; +048import org.apache.yetus.audience.InterfaceAudience; +049import org.apache.yetus.audience.InterfaceStability; 050 051 052/** @@ -96,7 +96,7 @@ 088 * @param regions the initial regions created for the table 089 */ 090 default void preCreateTable(final ObserverContextMasterCoprocessorEnvironment ctx, -091 TableDescriptor desc, HRegionInfo[] regions) throws IOException {} +091 TableDescriptor desc, RegionInfo[] regions) throws IOException {} 092 093 /** 094 * Called after the createTable operation has been requested. Called as part @@ -106,7 +106,7 @@ 098 * @param regions the initial regions created for the table 099 */ 100 default void postCreateTable(final ObserverContextMasterCoprocessorEnvironment ctx, -101 TableDescriptor desc, HRegionInfo[] regions) throws IOException {} +101 TableDescriptor desc, RegionInfo[] regions) throws IOException {} 102 103 /** 104 * Called before a new table is created by @@ -121,7 +121,7 @@ 113 default void preCreateTableAction( 114 final ObserverContextMasterCoprocessorEnvironment ctx, 115 final TableDescriptor desc, -116 final HRegionInfo[] regions) throws IOException {} +116 final RegionInfo[] regions) throws IOException {} 117 118 /** 119 * Called after the createTable operation has been requested. Called as part @@ -135,7 +135,7 @@ 127 default void postCompletedCreateTableAction( 128 final ObserverContextMasterCoprocessorEnvironment ctx, 129 final TableDescriptor desc, -130 final HRegionInfo[] regions) throws IOException {} +130 final RegionInfo[] regions) throws IOException {} 131 132 /** 133
[31/51] [partial] hbase-site git commit: Published site at .
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/fa7d6c0c/devapidocs/org/apache/hadoop/hbase/regionserver/RegionCoprocessorHost.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/regionserver/RegionCoprocessorHost.html b/devapidocs/org/apache/hadoop/hbase/regionserver/RegionCoprocessorHost.html index 279ec68..bcf81d4 100644 --- a/devapidocs/org/apache/hadoop/hbase/regionserver/RegionCoprocessorHost.html +++ b/devapidocs/org/apache/hadoop/hbase/regionserver/RegionCoprocessorHost.html @@ -116,7 +116,7 @@ var activeTableTab = "activeTableTab"; @InterfaceAudience.LimitedPrivate(value="Coprocesssor") @InterfaceStability.Evolving -public class RegionCoprocessorHost +public class RegionCoprocessorHost extends CoprocessorHostRegionCoprocessorHost.RegionEnvironment Implements the coprocessor environment and runtime support for coprocessors loaded within a Region. @@ -448,7 +448,7 @@ extends void -postReplayWALs(HRegionInfoinfo, +postReplayWALs(RegionInfoinfo, org.apache.hadoop.fs.Pathedits) @@ -491,7 +491,7 @@ extends void -postWALRestore(HRegionInfoinfo, +postWALRestore(RegionInfoinfo, WALKeylogKey, WALEditlogEdit) @@ -664,7 +664,7 @@ extends void -preReplayWALs(HRegionInfoinfo, +preReplayWALs(RegionInfoinfo, org.apache.hadoop.fs.Pathedits) @@ -702,7 +702,7 @@ extends boolean -preWALRestore(HRegionInfoinfo, +preWALRestore(RegionInfoinfo, WALKeylogKey, WALEditlogEdit) @@ -748,7 +748,7 @@ extends LOG -private static finalorg.apache.commons.logging.Log LOG +private static finalorg.apache.commons.logging.Log LOG @@ -757,7 +757,7 @@ extends SHARED_DATA_MAP -private static finalorg.apache.commons.collections4.map.ReferenceMaphttp://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String,http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/ConcurrentMap.html?is-external=true; title="class or interface in java.util.concurrent">ConcurrentMaphttp://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String,http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true; title="class or interface in java.lang">Object SHARED_DATA_MAP +private static finalorg.apache.commons.collections4.map.ReferenceMaphttp://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String,http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/ConcurrentMap.html?is-external=true; title="class or interface in java.util.concurrent">ConcurrentMaphttp://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String,http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true; title="class or interface in java.lang">Object SHARED_DATA_MAP @@ -766,7 +766,7 @@ extends hasCustomPostScannerFilterRow -private finalboolean hasCustomPostScannerFilterRow +private finalboolean hasCustomPostScannerFilterRow @@ -775,7 +775,7 @@ extends rsServices -RegionServerServices rsServices +RegionServerServices rsServices The region server services @@ -785,7 +785,7 @@ extends region -Region region +Region region The region @@ -803,7 +803,7 @@ extends RegionCoprocessorHost -publicRegionCoprocessorHost(Regionregion, +publicRegionCoprocessorHost(Regionregion, RegionServerServicesrsServices, org.apache.hadoop.conf.Configurationconf) Constructor @@ -829,7 +829,7 @@ extends getTableCoprocessorAttrsFromSchema -statichttp://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true; title="class or interface in java.util">ListRegionCoprocessorHost.TableCoprocessorAttributegetTableCoprocessorAttrsFromSchema(org.apache.hadoop.conf.Configurationconf, +statichttp://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true; title="class or interface in java.util">ListRegionCoprocessorHost.TableCoprocessorAttributegetTableCoprocessorAttrsFromSchema(org.apache.hadoop.conf.Configurationconf, TableDescriptorhtd) @@ -839,7 +839,7 @@ extends testTableCoprocessorAttrs -public staticvoidtestTableCoprocessorAttrs(org.apache.hadoop.conf.Configurationconf, +public staticvoidtestTableCoprocessorAttrs(org.apache.hadoop.conf.Configurationconf, TableDescriptorhtd) throws http://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true; title="class or interface in java.io">IOException Sanity check the table coprocessor attributes of the supplied schema.
[03/51] [partial] hbase-site git commit: Published site at .
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/fa7d6c0c/devapidocs/src-html/org/apache/hadoop/hbase/rsgroup/RSGroupAdminEndpoint.RSGroupAdminServiceImpl.html -- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/rsgroup/RSGroupAdminEndpoint.RSGroupAdminServiceImpl.html b/devapidocs/src-html/org/apache/hadoop/hbase/rsgroup/RSGroupAdminEndpoint.RSGroupAdminServiceImpl.html index a47d486..89f4de2 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/rsgroup/RSGroupAdminEndpoint.RSGroupAdminServiceImpl.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/rsgroup/RSGroupAdminEndpoint.RSGroupAdminServiceImpl.html @@ -30,336 +30,335 @@ 022import java.util.HashSet; 023import java.util.Set; 024 -025import org.apache.hadoop.hbase.shaded.com.google.common.collect.Sets; -026import com.google.protobuf.RpcCallback; -027import com.google.protobuf.RpcController; -028import com.google.protobuf.Service; -029import org.apache.commons.logging.Log; -030import org.apache.commons.logging.LogFactory; -031import org.apache.hadoop.hbase.CoprocessorEnvironment; -032import org.apache.hadoop.hbase.HConstants; -033import org.apache.hadoop.hbase.HRegionInfo; -034import org.apache.hadoop.hbase.HTableDescriptor; -035import org.apache.hadoop.hbase.NamespaceDescriptor; -036import org.apache.hadoop.hbase.TableName; -037import org.apache.yetus.audience.InterfaceAudience; -038import org.apache.hadoop.hbase.client.TableDescriptor; -039import org.apache.hadoop.hbase.constraint.ConstraintException; -040import org.apache.hadoop.hbase.coprocessor.CoprocessorService; -041import org.apache.hadoop.hbase.coprocessor.MasterCoprocessorEnvironment; -042import org.apache.hadoop.hbase.coprocessor.MasterObserver; -043import org.apache.hadoop.hbase.coprocessor.ObserverContext; -044import org.apache.hadoop.hbase.ipc.CoprocessorRpcUtils; -045import org.apache.hadoop.hbase.master.MasterServices; -046import org.apache.hadoop.hbase.net.Address; -047import org.apache.hadoop.hbase.protobuf.ProtobufUtil; -048import org.apache.hadoop.hbase.protobuf.generated.HBaseProtos; -049import org.apache.hadoop.hbase.protobuf.generated.RSGroupAdminProtos; -050import org.apache.hadoop.hbase.protobuf.generated.RSGroupAdminProtos.AddRSGroupRequest; -051import org.apache.hadoop.hbase.protobuf.generated.RSGroupAdminProtos.AddRSGroupResponse; -052import org.apache.hadoop.hbase.protobuf.generated.RSGroupAdminProtos.BalanceRSGroupRequest; -053import org.apache.hadoop.hbase.protobuf.generated.RSGroupAdminProtos.BalanceRSGroupResponse; -054import org.apache.hadoop.hbase.protobuf.generated.RSGroupAdminProtos.GetRSGroupInfoOfServerRequest; -055import org.apache.hadoop.hbase.protobuf.generated.RSGroupAdminProtos.GetRSGroupInfoOfServerResponse; -056import org.apache.hadoop.hbase.protobuf.generated.RSGroupAdminProtos.GetRSGroupInfoOfTableRequest; -057import org.apache.hadoop.hbase.protobuf.generated.RSGroupAdminProtos.GetRSGroupInfoOfTableResponse; -058import org.apache.hadoop.hbase.protobuf.generated.RSGroupAdminProtos.GetRSGroupInfoRequest; -059import org.apache.hadoop.hbase.protobuf.generated.RSGroupAdminProtos.GetRSGroupInfoResponse; -060import org.apache.hadoop.hbase.protobuf.generated.RSGroupAdminProtos.ListRSGroupInfosRequest; -061import org.apache.hadoop.hbase.protobuf.generated.RSGroupAdminProtos.ListRSGroupInfosResponse; -062import org.apache.hadoop.hbase.protobuf.generated.RSGroupAdminProtos.MoveServersAndTablesRequest; -063import org.apache.hadoop.hbase.protobuf.generated.RSGroupAdminProtos.MoveServersAndTablesResponse; -064import org.apache.hadoop.hbase.protobuf.generated.RSGroupAdminProtos.MoveServersRequest; -065import org.apache.hadoop.hbase.protobuf.generated.RSGroupAdminProtos.MoveServersResponse; -066import org.apache.hadoop.hbase.protobuf.generated.RSGroupAdminProtos.MoveTablesRequest; -067import org.apache.hadoop.hbase.protobuf.generated.RSGroupAdminProtos.MoveTablesResponse; -068import org.apache.hadoop.hbase.protobuf.generated.RSGroupAdminProtos.RSGroupAdminService; -069import org.apache.hadoop.hbase.protobuf.generated.RSGroupAdminProtos.RemoveRSGroupRequest; -070import org.apache.hadoop.hbase.protobuf.generated.RSGroupAdminProtos.RemoveRSGroupResponse; -071import org.apache.hadoop.hbase.shaded.protobuf.generated.SnapshotProtos.SnapshotDescription; -072 -073@InterfaceAudience.Private -074public class RSGroupAdminEndpoint implements MasterObserver, CoprocessorService { -075 private static final Log LOG = LogFactory.getLog(RSGroupAdminEndpoint.class); -076 -077 private MasterServices master = null; -078 // Only instance of RSGroupInfoManager. RSGroup aware load balancers ask for this instance on -079 // their setup. -080 private RSGroupInfoManager groupInfoManager; -081 private RSGroupAdminServer groupAdminServer; -082 private final RSGroupAdminService groupAdminService = new RSGroupAdminServiceImpl(); -083 -084 @Override
[04/51] [partial] hbase-site git commit: Published site at .
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/fa7d6c0c/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/wal/ProtobufLogReader.WALHdrContext.html -- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/wal/ProtobufLogReader.WALHdrContext.html b/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/wal/ProtobufLogReader.WALHdrContext.html index b407bcf..dcb6354 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/wal/ProtobufLogReader.WALHdrContext.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/wal/ProtobufLogReader.WALHdrContext.html @@ -47,7 +47,7 @@ 039import org.apache.hadoop.hbase.shaded.protobuf.ProtobufUtil; 040import org.apache.hadoop.hbase.shaded.protobuf.generated.WALProtos; 041import org.apache.hadoop.hbase.shaded.protobuf.generated.WALProtos.WALHeader.Builder; -042import org.apache.hadoop.hbase.shaded.protobuf.generated.WALProtos.WALEdit; +042import org.apache.hadoop.hbase.shaded.protobuf.generated.WALProtos.WALKey; 043import org.apache.hadoop.hbase.shaded.protobuf.generated.WALProtos.WALTrailer; 044import org.apache.hadoop.hbase.util.Bytes; 045import org.apache.hadoop.hbase.wal.WAL.Entry; @@ -341,7 +341,7 @@ 333} 334return false; 335 } -336 WALEdit.Builder builder = WALEdit.newBuilder(); +336 WALKey.Builder builder = WALKey.newBuilder(); 337 long size = 0; 338 try { 339long available = -1; @@ -371,87 +371,86 @@ 363 throw new EOFException("Partial PB while reading WAL, " + 364 "probably an unexpected EOF, ignoring. current offset=" + this.inputStream.getPos()); 365} -366WALEdit walKey = builder.build(); +366WALKey walKey = builder.build(); 367 entry.getKey().readFieldsFromPb(walKey, this.byteStringUncompressor); 368if (!walKey.hasFollowingKvCount() || 0 == walKey.getFollowingKvCount()) { 369 if (LOG.isTraceEnabled()) { -370LOG.trace("WALKey has no KVs that follow it; trying the next one. current offset=" + -371 this.inputStream.getPos()); -372 } -373 continue; -374} -375int expectedCells = walKey.getFollowingKvCount(); -376long posBefore = this.inputStream.getPos(); -377try { -378 int actualCells = entry.getEdit().readFromCells(cellDecoder, expectedCells); -379 if (expectedCells != actualCells) { -380throw new EOFException("Only read " + actualCells); // other info added in catch -381 } -382} catch (Exception ex) { -383 String posAfterStr = "unknown"; -384 try { -385posAfterStr = this.inputStream.getPos() + ""; -386 } catch (Throwable t) { -387if (LOG.isTraceEnabled()) { -388 LOG.trace("Error getting pos for error message - ignoring", t); -389} -390 } -391 String message = " while reading " + expectedCells + " WAL KVs; started reading at " -392 + posBefore + " and read up to " + posAfterStr; -393 IOException realEofEx = extractHiddenEof(ex); -394 throw (EOFException) new EOFException("EOF " + message). -395 initCause(realEofEx != null ? realEofEx : ex); -396} -397if (trailerPresent this.inputStream.getPos() this.walEditsStopOffset) { -398 LOG.error("Read WALTrailer while reading WALEdits. wal: " + this.path -399 + ", inputStream.getPos(): " + this.inputStream.getPos() + ", walEditsStopOffset: " -400 + this.walEditsStopOffset); -401 throw new EOFException("Read WALTrailer while reading WALEdits"); -402} -403 } catch (EOFException eof) { -404// If originalPosition is 0, it is rubbish and we cannot use it (probably local fs) -405if (originalPosition 0) { -406 if (LOG.isTraceEnabled()) { -407LOG.trace("Encountered a malformed edit, but can't seek back to last good position because originalPosition is negative. last offset=" + this.inputStream.getPos(), eof); -408 } -409 throw eof; -410} -411// Else restore our position to original location in hope that next time through we will -412// read successfully. -413if (LOG.isTraceEnabled()) { -414 LOG.trace("Encountered a malformed edit, seeking back to last good position in file, from "+ inputStream.getPos()+" to " + originalPosition, eof); -415} -416seekOnFs(originalPosition); -417return false; -418 } -419 return true; -420} -421 } -422 -423 private IOException extractHiddenEof(Exception ex) { -424// There are two problems we are dealing with here. Hadoop stream throws generic exception -425// for EOF, not EOFException; and scanner further hides it inside