hbase git commit: HBASE-20210 Note in refguide that RSGroups API is private, not for public consumption; shell is only access
Repository: hbase Updated Branches: refs/heads/master c200bf8f7 -> 22f4def94 HBASE-20210 Note in refguide that RSGroups API is private, not for public consumption; shell is only access Project: http://git-wip-us.apache.org/repos/asf/hbase/repo Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/22f4def9 Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/22f4def9 Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/22f4def9 Branch: refs/heads/master Commit: 22f4def942f8a3367d0ca6598317e9b9a7d0cfcd Parents: c200bf8 Author: Michael StackAuthored: Thu Mar 15 09:59:07 2018 -0700 Committer: Michael Stack Committed: Thu Mar 15 14:48:09 2018 -0700 -- src/main/asciidoc/_chapters/ops_mgt.adoc | 6 -- 1 file changed, 4 insertions(+), 2 deletions(-) -- http://git-wip-us.apache.org/repos/asf/hbase/blob/22f4def9/src/main/asciidoc/_chapters/ops_mgt.adoc -- diff --git a/src/main/asciidoc/_chapters/ops_mgt.adoc b/src/main/asciidoc/_chapters/ops_mgt.adoc index 22047c6..0f7922a 100644 --- a/src/main/asciidoc/_chapters/ops_mgt.adoc +++ b/src/main/asciidoc/_chapters/ops_mgt.adoc @@ -2528,8 +2528,10 @@ full implications and have a sufficient background in managing HBase clusters. It was developed by Yahoo! and they run it at scale on their large grid cluster. See link:http://www.slideshare.net/HBaseCon/keynote-apache-hbase-at-yahoo-scale[HBase at Yahoo! Scale]. -RSGroups can be defined and managed with shell commands or corresponding Java -APIs. A server can be added to a group with hostname and port pair and tables +RSGroups are defined and managed with shell commands. The shell drives a +Coprocessor Endpoint whose API is marked private given this is an evolving +feature; the Coprocessor API is not for public consumption. +A server can be added to a group with hostname and port pair and tables can be moved to this group so that only regionservers in the same rsgroup can host the regions of the table. RegionServers and tables can only belong to one rsgroup at a time. By default, all tables and regionservers belong to the
hbase git commit: HBASE-20190 Fix default for MIGRATE_TABLE_STATE_FROM_ZK_KEY
Repository: hbase Updated Branches: refs/heads/branch-2.0 cb42585a1 -> a2fccc36e HBASE-20190 Fix default for MIGRATE_TABLE_STATE_FROM_ZK_KEY Project: http://git-wip-us.apache.org/repos/asf/hbase/repo Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/a2fccc36 Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/a2fccc36 Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/a2fccc36 Branch: refs/heads/branch-2.0 Commit: a2fccc36e199fa54a05b9bf300d1e10013a98214 Parents: cb42585 Author: Michael StackAuthored: Tue Mar 13 17:52:44 2018 -0700 Committer: Michael Stack Committed: Thu Mar 15 10:34:58 2018 -0700 -- .../java/org/apache/hadoop/hbase/master/TableStateManager.java| 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) -- http://git-wip-us.apache.org/repos/asf/hbase/blob/a2fccc36/hbase-server/src/main/java/org/apache/hadoop/hbase/master/TableStateManager.java -- diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/master/TableStateManager.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/master/TableStateManager.java index 8a33de6..ce76b05 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/master/TableStateManager.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/master/TableStateManager.java @@ -270,7 +270,8 @@ public class TableStateManager { */ @Deprecated private void migrateZooKeeper() throws IOException { -if (this.master.getConfiguration().getBoolean(MIGRATE_TABLE_STATE_FROM_ZK_KEY, false)) { +if (!this.master.getConfiguration().getBoolean(MIGRATE_TABLE_STATE_FROM_ZK_KEY, +true)) { return; } try {
hbase git commit: HBASE-20190 Fix default for MIGRATE_TABLE_STATE_FROM_ZK_KEY
Repository: hbase Updated Branches: refs/heads/branch-2 95596e8ba -> e0bdc87b2 HBASE-20190 Fix default for MIGRATE_TABLE_STATE_FROM_ZK_KEY Project: http://git-wip-us.apache.org/repos/asf/hbase/repo Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/e0bdc87b Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/e0bdc87b Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/e0bdc87b Branch: refs/heads/branch-2 Commit: e0bdc87b27a046b217990f1789cfd25c126c6963 Parents: 95596e8 Author: Michael StackAuthored: Tue Mar 13 17:52:44 2018 -0700 Committer: Michael Stack Committed: Thu Mar 15 10:34:31 2018 -0700 -- .../java/org/apache/hadoop/hbase/master/TableStateManager.java| 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) -- http://git-wip-us.apache.org/repos/asf/hbase/blob/e0bdc87b/hbase-server/src/main/java/org/apache/hadoop/hbase/master/TableStateManager.java -- diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/master/TableStateManager.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/master/TableStateManager.java index 8a33de6..ce76b05 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/master/TableStateManager.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/master/TableStateManager.java @@ -270,7 +270,8 @@ public class TableStateManager { */ @Deprecated private void migrateZooKeeper() throws IOException { -if (this.master.getConfiguration().getBoolean(MIGRATE_TABLE_STATE_FROM_ZK_KEY, false)) { +if (!this.master.getConfiguration().getBoolean(MIGRATE_TABLE_STATE_FROM_ZK_KEY, +true)) { return; } try {
hbase git commit: HBASE-20190 Fix default for MIGRATE_TABLE_STATE_FROM_ZK_KEY
Repository: hbase Updated Branches: refs/heads/master 4f2133ee3 -> c200bf8f7 HBASE-20190 Fix default for MIGRATE_TABLE_STATE_FROM_ZK_KEY Project: http://git-wip-us.apache.org/repos/asf/hbase/repo Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/c200bf8f Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/c200bf8f Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/c200bf8f Branch: refs/heads/master Commit: c200bf8f78ee0698cc063235ffe1eb396bad3962 Parents: 4f2133e Author: Michael StackAuthored: Tue Mar 13 17:52:44 2018 -0700 Committer: Michael Stack Committed: Thu Mar 15 10:34:02 2018 -0700 -- .../java/org/apache/hadoop/hbase/master/TableStateManager.java| 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) -- http://git-wip-us.apache.org/repos/asf/hbase/blob/c200bf8f/hbase-server/src/main/java/org/apache/hadoop/hbase/master/TableStateManager.java -- diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/master/TableStateManager.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/master/TableStateManager.java index 8a33de6..ce76b05 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/master/TableStateManager.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/master/TableStateManager.java @@ -270,7 +270,8 @@ public class TableStateManager { */ @Deprecated private void migrateZooKeeper() throws IOException { -if (this.master.getConfiguration().getBoolean(MIGRATE_TABLE_STATE_FROM_ZK_KEY, false)) { +if (!this.master.getConfiguration().getBoolean(MIGRATE_TABLE_STATE_FROM_ZK_KEY, +true)) { return; } try {
[2/3] hbase git commit: HBASE-20119 Introduce a pojo class to carry coprocessor information in order to make TableDescriptorBuilder accept multiple cp at once
http://git-wip-us.apache.org/repos/asf/hbase/blob/95596e8b/hbase-server/src/main/java/org/apache/hadoop/hbase/security/access/CoprocessorWhitelistMasterObserver.java -- diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/security/access/CoprocessorWhitelistMasterObserver.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/security/access/CoprocessorWhitelistMasterObserver.java index 44a4f57..44f736b 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/security/access/CoprocessorWhitelistMasterObserver.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/security/access/CoprocessorWhitelistMasterObserver.java @@ -21,21 +21,17 @@ package org.apache.hadoop.hbase.security.access; import java.io.IOException; import java.util.Collection; import java.util.Optional; -import java.util.regex.Matcher; - import org.apache.commons.io.FilenameUtils; -import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.fs.Path; import org.apache.hadoop.hbase.HBaseInterfaceAudience; -import org.apache.hadoop.hbase.HConstants; import org.apache.hadoop.hbase.TableName; +import org.apache.hadoop.hbase.client.CoprocessorDescriptor; import org.apache.hadoop.hbase.client.RegionInfo; import org.apache.hadoop.hbase.client.TableDescriptor; import org.apache.hadoop.hbase.coprocessor.MasterCoprocessor; import org.apache.hadoop.hbase.coprocessor.MasterCoprocessorEnvironment; import org.apache.hadoop.hbase.coprocessor.MasterObserver; import org.apache.hadoop.hbase.coprocessor.ObserverContext; -import org.apache.hadoop.hbase.util.Bytes; import org.apache.yetus.audience.InterfaceAudience; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -81,10 +77,8 @@ public class CoprocessorWhitelistMasterObserver implements MasterCoprocessor, Ma * "file:///usr/hbase/coprocessors" or for all * filesystems "/usr/hbase/coprocessors") * @return if the path was found under the wlPath - * @throws IOException if a failure occurs in getting the path file system */ - private static boolean validatePath(Path coprocPath, Path wlPath, - Configuration conf) throws IOException { + private static boolean validatePath(Path coprocPath, Path wlPath) { // verify if all are allowed if (wlPath.toString().equals("*")) { return(true); @@ -143,58 +137,26 @@ public class CoprocessorWhitelistMasterObserver implements MasterCoprocessor, Ma * @param ctx as passed in from the coprocessor * @param htd as passed in from the coprocessor */ - private void verifyCoprocessors(ObserverContext ctx, + private static void verifyCoprocessors(ObserverContext ctx, TableDescriptor htd) throws IOException { - -Configuration conf = ctx.getEnvironment().getConfiguration(); - Collection paths = -conf.getStringCollection( + ctx.getEnvironment().getConfiguration().getStringCollection( CP_COPROCESSOR_WHITELIST_PATHS_KEY); - -Collection coprocs = htd.getCoprocessors(); -for (int i = 0; i < coprocs.size(); i++) { - - String coprocSpec = Bytes.toString(htd.getValue( - Bytes.toBytes("coprocessor$" + (i + 1; - if (coprocSpec == null) { -continue; - } - - // File path is the 1st field of the coprocessor spec - Matcher matcher = - HConstants.CP_HTD_ATTR_VALUE_PATTERN.matcher(coprocSpec); - if (matcher == null || !matcher.matches()) { -continue; - } - - String coprocPathStr = matcher.group(1).trim(); - // Check if coprocessor is being loaded via the classpath (i.e. no file path) - if (coprocPathStr.equals("")) { -break; - } - Path coprocPath = new Path(coprocPathStr); - String coprocessorClass = matcher.group(2).trim(); - - boolean foundPathMatch = false; - for (String pathStr : paths) { -Path wlPath = new Path(pathStr); -try { - foundPathMatch = validatePath(coprocPath, wlPath, conf); - if (foundPathMatch == true) { +for (CoprocessorDescriptor cp : htd.getCoprocessorDescriptors()) { + if (cp.getJarPath().isPresent()) { +if (paths.stream().noneMatch(p -> { + Path wlPath = new Path(p); + if (validatePath(new Path(cp.getJarPath().get()), wlPath)) { LOG.debug(String.format("Coprocessor %s found in directory %s", -coprocessorClass, pathStr)); -break; + cp.getClassName(), p)); +return true; } -} catch (IOException e) { - LOG.warn(String.format("Failed to validate white list path %s for coprocessor path %s", - pathStr, coprocPathStr)); + return false; +})) { + throw new IOException(String.format("Loading %s DENIED in %s", +cp.getClassName(),
[3/3] hbase git commit: HBASE-20119 Introduce a pojo class to carry coprocessor information in order to make TableDescriptorBuilder accept multiple cp at once
HBASE-20119 Introduce a pojo class to carry coprocessor information in order to make TableDescriptorBuilder accept multiple cp at once Signed-off-by: Ted YuSigned-off-by: Michael Stack Project: http://git-wip-us.apache.org/repos/asf/hbase/repo Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/95596e8b Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/95596e8b Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/95596e8b Branch: refs/heads/branch-2 Commit: 95596e8ba7569d131573ebc7ab679ce9ef3fe655 Parents: 5ea0db0 Author: Chia-Ping Tsai Authored: Fri Mar 16 01:17:06 2018 +0800 Committer: Chia-Ping Tsai Committed: Fri Mar 16 01:26:08 2018 +0800 -- .../archetypes/exemplars/client/HelloHBase.java | 2 +- .../apache/hadoop/hbase/HTableDescriptor.java | 25 +- .../hbase/client/CoprocessorDescriptor.java | 51 .../client/CoprocessorDescriptorBuilder.java| 118 + .../hadoop/hbase/client/TableDescriptor.java| 7 +- .../hbase/client/TableDescriptorBuilder.java| 244 ++- .../hbase/shaded/protobuf/ProtobufUtil.java | 2 +- .../hbase/client/TestCoprocessorDescriptor.java | 100 .../client/TestTableDescriptorBuilder.java | 82 ++- .../org/apache/hadoop/hbase/HConstants.java | 19 +- .../hbase/coprocessor/TestClassLoading.java | 2 +- .../hbase/coprocessor/TestSecureExport.java | 6 +- .../client/example/ExportEndpointExample.java | 4 +- .../example/TestScanModifyingObserver.java | 4 +- .../example/TestValueReplacingCompaction.java | 4 +- .../TestWriteHeavyIncrementObserver.java| 4 +- ...IncrementObserverWithMemStoreCompaction.java | 4 +- .../TestZooKeeperScanPolicyObserver.java| 4 +- .../hbase/IntegrationTestDDLMasterFailover.java | 2 +- .../hbase/chaos/actions/AddColumnAction.java| 2 +- .../actions/TestChangeSplitPolicyAction.java| 2 +- .../mapreduce/IntegrationTestBulkLoad.java | 2 +- .../hadoop/hbase/mttr/IntegrationTestMTTR.java | 2 +- .../mapreduce/TestCellBasedImportExport2.java | 14 +- .../hbase/mapreduce/TestImportExport.java | 14 +- .../replication/TestVerifyReplication.java | 2 +- .../hbase/rsgroup/TestRSGroupsWithACL.java | 2 +- .../hadoop/hbase/coprocessor/package-info.java | 2 +- .../org/apache/hadoop/hbase/master/HMaster.java | 2 +- .../regionserver/RegionCoprocessorHost.java | 71 +- .../hbase/security/access/AccessController.java | 2 +- .../CoprocessorWhitelistMasterObserver.java | 68 ++ .../hbase/tool/LoadIncrementalHFiles.java | 2 +- .../hadoop/hbase/util/FSTableDescriptors.java | 46 ++-- .../org/apache/hadoop/hbase/util/HBaseFsck.java | 2 +- .../hadoop/hbase/util/RegionSplitter.java | 2 +- .../hadoop/hbase/AcidGuaranteesTestBase.java| 2 +- .../hadoop/hbase/AcidGuaranteesTestTool.java| 2 +- .../hadoop/hbase/HBaseTestingUtility.java | 6 +- .../org/apache/hadoop/hbase/TestZooKeeper.java | 6 +- .../client/AbstractTestCIOperationTimeout.java | 4 +- .../hbase/client/AbstractTestCIRpcTimeout.java | 4 +- .../hadoop/hbase/client/TestAsyncAdminBase.java | 2 +- .../hbase/client/TestAsyncClusterAdminApi.java | 2 +- .../hbase/client/TestAsyncRegionAdminApi.java | 5 +- ...estAsyncReplicationAdminApiWithClusters.java | 4 +- .../hbase/client/TestAsyncTableAdminApi.java| 10 +- .../hbase/client/TestAsyncTableAdminApi2.java | 16 +- .../hbase/client/TestAsyncTableAdminApi3.java | 2 +- .../hbase/client/TestAsyncTableBatch.java | 2 +- .../apache/hadoop/hbase/client/TestCISleep.java | 9 +- .../hbase/client/TestDropTimeoutRequest.java| 4 +- .../hbase/client/TestFromClientSide3.java | 4 +- .../client/TestMalformedCellFromClient.java | 2 +- .../hbase/client/TestReplicaWithCluster.java| 6 +- .../hbase/client/TestResultFromCoprocessor.java | 4 +- .../hbase/client/TestServerLoadDurability.java | 2 +- .../coprocessor/TestCoreRegionCoprocessor.java | 2 +- .../TestPassCustomCellViaRegionObserver.java| 4 +- .../hbase/coprocessor/TestWALObserver.java | 8 +- .../master/TestAssignmentManagerMetrics.java| 10 +- .../hadoop/hbase/master/TestCatalogJanitor.java | 2 +- .../master/assignment/MockMasterServices.java | 2 +- .../assignment/TestRogueRSAssignment.java | 2 +- .../TestFavoredStochasticBalancerPickers.java | 2 +- .../master/cleaner/TestSnapshotFromMaster.java | 3 +- .../MasterProcedureTestingUtility.java | 2 +- .../procedure/TestMasterObserverPostCalls.java | 12 +- .../master/procedure/TestProcedurePriority.java | 2 +- .../regionserver/TestCacheOnWriteInSchema.java | 2 +- .../TestCompactionArchiveConcurrentClose.java | 2 +-
[1/3] hbase git commit: HBASE-20119 Introduce a pojo class to carry coprocessor information in order to make TableDescriptorBuilder accept multiple cp at once
Repository: hbase Updated Branches: refs/heads/branch-2 5ea0db0b1 -> 95596e8ba http://git-wip-us.apache.org/repos/asf/hbase/blob/95596e8b/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/wal/AbstractTestFSWAL.java -- diff --git a/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/wal/AbstractTestFSWAL.java b/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/wal/AbstractTestFSWAL.java index 1cdb6e5..5336963 100644 --- a/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/wal/AbstractTestFSWAL.java +++ b/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/wal/AbstractTestFSWAL.java @@ -252,9 +252,9 @@ public abstract class AbstractTestFSWAL { AbstractFSWAL wal = newWAL(FS, CommonFSUtils.getWALRootDir(conf1), DIR.toString(), HConstants.HREGION_OLDLOGDIR_NAME, conf1, null, true, null, null); TableDescriptor t1 = TableDescriptorBuilder.newBuilder(TableName.valueOf("t1")) - .addColumnFamily(ColumnFamilyDescriptorBuilder.of("row")).build(); + .setColumnFamily(ColumnFamilyDescriptorBuilder.of("row")).build(); TableDescriptor t2 = TableDescriptorBuilder.newBuilder(TableName.valueOf("t2")) - .addColumnFamily(ColumnFamilyDescriptorBuilder.of("row")).build(); + .setColumnFamily(ColumnFamilyDescriptorBuilder.of("row")).build(); RegionInfo hri1 = RegionInfoBuilder.newBuilder(t1.getTableName()).build(); RegionInfo hri2 = RegionInfoBuilder.newBuilder(t2.getTableName()).build(); // add edits and roll the wal @@ -361,7 +361,7 @@ public abstract class AbstractTestFSWAL { final RegionInfo hri = RegionInfoBuilder.newBuilder(tableName).build(); final byte[] rowName = tableName.getName(); final TableDescriptor htd = TableDescriptorBuilder.newBuilder(tableName) - .addColumnFamily(ColumnFamilyDescriptorBuilder.of("f")).build(); + .setColumnFamily(ColumnFamilyDescriptorBuilder.of("f")).build(); HRegion r = HBaseTestingUtility.createRegionAndWAL(hri, TEST_UTIL.getDefaultRootDirPath(), TEST_UTIL.getConfiguration(), htd); HBaseTestingUtility.closeRegionAndWAL(r); @@ -449,7 +449,7 @@ public abstract class AbstractTestFSWAL { CONF, null, true, null, null); wal.close(); TableDescriptor td = TableDescriptorBuilder.newBuilder(TableName.valueOf("table")) - .addColumnFamily(ColumnFamilyDescriptorBuilder.of("row")).build(); + .setColumnFamily(ColumnFamilyDescriptorBuilder.of("row")).build(); RegionInfo ri = RegionInfoBuilder.newBuilder(td.getTableName()).build(); MultiVersionConcurrencyControl mvcc = new MultiVersionConcurrencyControl(); NavigableMapscopes = new TreeMap<>(Bytes.BYTES_COMPARATOR); http://git-wip-us.apache.org/repos/asf/hbase/blob/95596e8b/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/wal/AbstractTestLogRolling.java -- diff --git a/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/wal/AbstractTestLogRolling.java b/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/wal/AbstractTestLogRolling.java index c6059b1..610af61 100644 --- a/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/wal/AbstractTestLogRolling.java +++ b/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/wal/AbstractTestLogRolling.java @@ -305,7 +305,7 @@ public abstract class AbstractTestLogRolling { protected Table createTestTable(String tableName) throws IOException { // Create the test table and open it TableDescriptor desc = TableDescriptorBuilder.newBuilder(TableName.valueOf(getName())) - .addColumnFamily(ColumnFamilyDescriptorBuilder.of(HConstants.CATALOG_FAMILY)).build(); + .setColumnFamily(ColumnFamilyDescriptorBuilder.of(HConstants.CATALOG_FAMILY)).build(); admin.createTable(desc); return TEST_UTIL.getConnection().getTable(desc.getTableName()); } http://git-wip-us.apache.org/repos/asf/hbase/blob/95596e8b/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/wal/TestDurability.java -- diff --git a/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/wal/TestDurability.java b/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/wal/TestDurability.java index f5fabbc..4effa6d 100644 --- a/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/wal/TestDurability.java +++ b/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/wal/TestDurability.java @@ -291,7 +291,7 @@ public class TestDurability { private HRegion createHRegion(WALFactory wals, Durability durability) throws IOException { TableName tableName = TableName.valueOf(name.getMethodName().replaceAll("[^A-Za-z0-9-_]", "_")); TableDescriptor htd =
[2/3] hbase git commit: HBASE-20119 Introduce a pojo class to carry coprocessor information in order to make TableDescriptorBuilder accept multiple cp at once
http://git-wip-us.apache.org/repos/asf/hbase/blob/4f2133ee/hbase-server/src/main/java/org/apache/hadoop/hbase/security/access/CoprocessorWhitelistMasterObserver.java -- diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/security/access/CoprocessorWhitelistMasterObserver.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/security/access/CoprocessorWhitelistMasterObserver.java index 44a4f57..44f736b 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/security/access/CoprocessorWhitelistMasterObserver.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/security/access/CoprocessorWhitelistMasterObserver.java @@ -21,21 +21,17 @@ package org.apache.hadoop.hbase.security.access; import java.io.IOException; import java.util.Collection; import java.util.Optional; -import java.util.regex.Matcher; - import org.apache.commons.io.FilenameUtils; -import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.fs.Path; import org.apache.hadoop.hbase.HBaseInterfaceAudience; -import org.apache.hadoop.hbase.HConstants; import org.apache.hadoop.hbase.TableName; +import org.apache.hadoop.hbase.client.CoprocessorDescriptor; import org.apache.hadoop.hbase.client.RegionInfo; import org.apache.hadoop.hbase.client.TableDescriptor; import org.apache.hadoop.hbase.coprocessor.MasterCoprocessor; import org.apache.hadoop.hbase.coprocessor.MasterCoprocessorEnvironment; import org.apache.hadoop.hbase.coprocessor.MasterObserver; import org.apache.hadoop.hbase.coprocessor.ObserverContext; -import org.apache.hadoop.hbase.util.Bytes; import org.apache.yetus.audience.InterfaceAudience; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -81,10 +77,8 @@ public class CoprocessorWhitelistMasterObserver implements MasterCoprocessor, Ma * "file:///usr/hbase/coprocessors" or for all * filesystems "/usr/hbase/coprocessors") * @return if the path was found under the wlPath - * @throws IOException if a failure occurs in getting the path file system */ - private static boolean validatePath(Path coprocPath, Path wlPath, - Configuration conf) throws IOException { + private static boolean validatePath(Path coprocPath, Path wlPath) { // verify if all are allowed if (wlPath.toString().equals("*")) { return(true); @@ -143,58 +137,26 @@ public class CoprocessorWhitelistMasterObserver implements MasterCoprocessor, Ma * @param ctx as passed in from the coprocessor * @param htd as passed in from the coprocessor */ - private void verifyCoprocessors(ObserverContext ctx, + private static void verifyCoprocessors(ObserverContext ctx, TableDescriptor htd) throws IOException { - -Configuration conf = ctx.getEnvironment().getConfiguration(); - Collection paths = -conf.getStringCollection( + ctx.getEnvironment().getConfiguration().getStringCollection( CP_COPROCESSOR_WHITELIST_PATHS_KEY); - -Collection coprocs = htd.getCoprocessors(); -for (int i = 0; i < coprocs.size(); i++) { - - String coprocSpec = Bytes.toString(htd.getValue( - Bytes.toBytes("coprocessor$" + (i + 1; - if (coprocSpec == null) { -continue; - } - - // File path is the 1st field of the coprocessor spec - Matcher matcher = - HConstants.CP_HTD_ATTR_VALUE_PATTERN.matcher(coprocSpec); - if (matcher == null || !matcher.matches()) { -continue; - } - - String coprocPathStr = matcher.group(1).trim(); - // Check if coprocessor is being loaded via the classpath (i.e. no file path) - if (coprocPathStr.equals("")) { -break; - } - Path coprocPath = new Path(coprocPathStr); - String coprocessorClass = matcher.group(2).trim(); - - boolean foundPathMatch = false; - for (String pathStr : paths) { -Path wlPath = new Path(pathStr); -try { - foundPathMatch = validatePath(coprocPath, wlPath, conf); - if (foundPathMatch == true) { +for (CoprocessorDescriptor cp : htd.getCoprocessorDescriptors()) { + if (cp.getJarPath().isPresent()) { +if (paths.stream().noneMatch(p -> { + Path wlPath = new Path(p); + if (validatePath(new Path(cp.getJarPath().get()), wlPath)) { LOG.debug(String.format("Coprocessor %s found in directory %s", -coprocessorClass, pathStr)); -break; + cp.getClassName(), p)); +return true; } -} catch (IOException e) { - LOG.warn(String.format("Failed to validate white list path %s for coprocessor path %s", - pathStr, coprocPathStr)); + return false; +})) { + throw new IOException(String.format("Loading %s DENIED in %s", +cp.getClassName(),
[1/3] hbase git commit: HBASE-20119 Introduce a pojo class to carry coprocessor information in order to make TableDescriptorBuilder accept multiple cp at once
Repository: hbase Updated Branches: refs/heads/master 31da4d0bc -> 4f2133ee3 http://git-wip-us.apache.org/repos/asf/hbase/blob/4f2133ee/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/compactions/TestFIFOCompactionPolicy.java -- diff --git a/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/compactions/TestFIFOCompactionPolicy.java b/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/compactions/TestFIFOCompactionPolicy.java index 7ea879e..e5a4f0c 100644 --- a/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/compactions/TestFIFOCompactionPolicy.java +++ b/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/compactions/TestFIFOCompactionPolicy.java @@ -93,7 +93,7 @@ public class TestFIFOCompactionPolicy { FIFOCompactionPolicy.class.getName()) .setValue(HConstants.HBASE_REGION_SPLIT_POLICY_KEY, DisabledRegionSplitPolicy.class.getName()) - .addColumnFamily(ColumnFamilyDescriptorBuilder.newBuilder(family).setTimeToLive(1).build()) + .setColumnFamily(ColumnFamilyDescriptorBuilder.newBuilder(family).setTimeToLive(1).build()) .build(); admin.createTable(desc); Table table = TEST_UTIL.getConnection().getTable(tableName); @@ -155,7 +155,7 @@ public class TestFIFOCompactionPolicy { FIFOCompactionPolicy.class.getName()) .setValue(HConstants.HBASE_REGION_SPLIT_POLICY_KEY, DisabledRegionSplitPolicy.class.getName()) -.addColumnFamily(ColumnFamilyDescriptorBuilder.of(family)).build(); +.setColumnFamily(ColumnFamilyDescriptorBuilder.of(family)).build(); TEST_UTIL.getAdmin().createTable(desc); } @@ -169,7 +169,7 @@ public class TestFIFOCompactionPolicy { FIFOCompactionPolicy.class.getName()) .setValue(HConstants.HBASE_REGION_SPLIT_POLICY_KEY, DisabledRegionSplitPolicy.class.getName()) - .addColumnFamily(ColumnFamilyDescriptorBuilder.newBuilder(family).setTimeToLive(1) + .setColumnFamily(ColumnFamilyDescriptorBuilder.newBuilder(family).setTimeToLive(1) .setMinVersions(1).build()) .build(); TEST_UTIL.getAdmin().createTable(desc); @@ -187,7 +187,7 @@ public class TestFIFOCompactionPolicy { .setValue(HConstants.HBASE_REGION_SPLIT_POLICY_KEY, DisabledRegionSplitPolicy.class.getName()) .setValue(HStore.BLOCKING_STOREFILES_KEY, "10") - .addColumnFamily(ColumnFamilyDescriptorBuilder.newBuilder(family).setTimeToLive(1).build()) + .setColumnFamily(ColumnFamilyDescriptorBuilder.newBuilder(family).setTimeToLive(1).build()) .build(); TEST_UTIL.getAdmin().createTable(desc); } http://git-wip-us.apache.org/repos/asf/hbase/blob/4f2133ee/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/throttle/TestCompactionWithThroughputController.java -- diff --git a/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/throttle/TestCompactionWithThroughputController.java b/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/throttle/TestCompactionWithThroughputController.java index a7cdfa5..5319d30 100644 --- a/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/throttle/TestCompactionWithThroughputController.java +++ b/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/throttle/TestCompactionWithThroughputController.java @@ -203,7 +203,7 @@ public class TestCompactionWithThroughputController { try { TEST_UTIL.getAdmin() .createTable(TableDescriptorBuilder.newBuilder(tableName) - .addColumnFamily(ColumnFamilyDescriptorBuilder.of(family)).setCompactionEnabled(false) + .setColumnFamily(ColumnFamilyDescriptorBuilder.of(family)).setCompactionEnabled(false) .build()); TEST_UTIL.waitTableAvailable(tableName); HRegionServer regionServer = TEST_UTIL.getRSForFirstRegionInTable(tableName); @@ -260,7 +260,7 @@ public class TestCompactionWithThroughputController { try { TEST_UTIL.getAdmin() .createTable(TableDescriptorBuilder.newBuilder(tableName) - .addColumnFamily(ColumnFamilyDescriptorBuilder.of(family)).setCompactionEnabled(false) + .setColumnFamily(ColumnFamilyDescriptorBuilder.of(family)).setCompactionEnabled(false) .build()); TEST_UTIL.waitTableAvailable(tableName); HStore store = getStoreWithName(tableName); http://git-wip-us.apache.org/repos/asf/hbase/blob/4f2133ee/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/throttle/TestFlushWithThroughputController.java -- diff --git
[3/3] hbase git commit: HBASE-20119 Introduce a pojo class to carry coprocessor information in order to make TableDescriptorBuilder accept multiple cp at once
HBASE-20119 Introduce a pojo class to carry coprocessor information in order to make TableDescriptorBuilder accept multiple cp at once Signed-off-by: Ted YuSigned-off-by: Michael Stack Project: http://git-wip-us.apache.org/repos/asf/hbase/repo Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/4f2133ee Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/4f2133ee Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/4f2133ee Branch: refs/heads/master Commit: 4f2133ee328890e1200b8618b5eac2bb8322f5e7 Parents: 31da4d0 Author: Chia-Ping Tsai Authored: Thu Mar 15 09:49:02 2018 +0800 Committer: Chia-Ping Tsai Committed: Fri Mar 16 01:21:38 2018 +0800 -- .../archetypes/exemplars/client/HelloHBase.java | 2 +- .../hbase/backup/impl/BackupSystemTable.java| 8 +- .../hadoop/hbase/backup/util/RestoreTool.java | 2 +- .../apache/hadoop/hbase/HTableDescriptor.java | 25 +- .../hbase/client/CoprocessorDescriptor.java | 51 .../client/CoprocessorDescriptorBuilder.java| 118 + .../hadoop/hbase/client/TableDescriptor.java| 7 +- .../hbase/client/TableDescriptorBuilder.java| 244 ++- .../hbase/shaded/protobuf/ProtobufUtil.java | 2 +- .../hbase/client/TestCoprocessorDescriptor.java | 100 .../client/TestTableDescriptorBuilder.java | 82 ++- .../org/apache/hadoop/hbase/HConstants.java | 19 +- .../hbase/coprocessor/TestClassLoading.java | 2 +- .../hbase/coprocessor/TestSecureExport.java | 6 +- .../client/example/ExportEndpointExample.java | 4 +- .../example/TestScanModifyingObserver.java | 4 +- .../example/TestValueReplacingCompaction.java | 4 +- .../TestWriteHeavyIncrementObserver.java| 4 +- ...IncrementObserverWithMemStoreCompaction.java | 4 +- .../TestZooKeeperScanPolicyObserver.java| 4 +- .../hbase/IntegrationTestDDLMasterFailover.java | 2 +- .../hbase/chaos/actions/AddColumnAction.java| 2 +- .../actions/TestChangeSplitPolicyAction.java| 2 +- .../mapreduce/IntegrationTestBulkLoad.java | 2 +- .../hadoop/hbase/mttr/IntegrationTestMTTR.java | 2 +- .../hbase/mapreduce/TestImportExport.java | 14 +- .../replication/TestVerifyReplication.java | 2 +- .../TableReplicationStorageBase.java| 12 +- .../hbase/rsgroup/TestRSGroupsWithACL.java | 2 +- .../hadoop/hbase/coprocessor/package-info.java | 2 +- .../org/apache/hadoop/hbase/master/HMaster.java | 2 +- .../regionserver/RegionCoprocessorHost.java | 71 +- .../hbase/security/access/AccessController.java | 2 +- .../CoprocessorWhitelistMasterObserver.java | 68 ++ .../hbase/tool/LoadIncrementalHFiles.java | 2 +- .../hadoop/hbase/util/FSTableDescriptors.java | 61 ++--- .../org/apache/hadoop/hbase/util/HBaseFsck.java | 2 +- .../hadoop/hbase/util/RegionSplitter.java | 2 +- .../hadoop/hbase/AcidGuaranteesTestBase.java| 2 +- .../hadoop/hbase/AcidGuaranteesTestTool.java| 2 +- .../hadoop/hbase/HBaseTestingUtility.java | 6 +- .../org/apache/hadoop/hbase/TestZooKeeper.java | 6 +- .../client/AbstractTestCIOperationTimeout.java | 4 +- .../hbase/client/AbstractTestCIRpcTimeout.java | 4 +- .../hadoop/hbase/client/TestAsyncAdminBase.java | 2 +- .../hbase/client/TestAsyncClusterAdminApi.java | 2 +- .../hbase/client/TestAsyncRegionAdminApi.java | 5 +- ...estAsyncReplicationAdminApiWithClusters.java | 4 +- .../hbase/client/TestAsyncTableAdminApi.java| 10 +- .../hbase/client/TestAsyncTableAdminApi2.java | 16 +- .../hbase/client/TestAsyncTableAdminApi3.java | 2 +- .../hbase/client/TestAsyncTableBatch.java | 2 +- .../apache/hadoop/hbase/client/TestCISleep.java | 9 +- .../hbase/client/TestDropTimeoutRequest.java| 4 +- .../hbase/client/TestFromClientSide3.java | 4 +- .../client/TestMalformedCellFromClient.java | 2 +- .../hbase/client/TestReplicaWithCluster.java| 6 +- .../hbase/client/TestResultFromCoprocessor.java | 4 +- .../hbase/client/TestServerLoadDurability.java | 2 +- .../coprocessor/TestCoreRegionCoprocessor.java | 2 +- .../TestPassCustomCellViaRegionObserver.java| 4 +- .../hbase/coprocessor/TestWALObserver.java | 8 +- .../master/TestAssignmentManagerMetrics.java| 10 +- .../hadoop/hbase/master/TestCatalogJanitor.java | 2 +- .../master/assignment/MockMasterServices.java | 2 +- .../assignment/TestRogueRSAssignment.java | 2 +- .../TestFavoredStochasticBalancerPickers.java | 2 +- .../master/cleaner/TestSnapshotFromMaster.java | 3 +- .../MasterProcedureTestingUtility.java | 2 +- .../procedure/TestMasterObserverPostCalls.java | 12 +- .../master/procedure/TestProcedurePriority.java | 2 +-
[3/3] hbase git commit: HBASE-20119 Introduce a pojo class to carry coprocessor information in order to make TableDescriptorBuilder accept multiple cp at once
HBASE-20119 Introduce a pojo class to carry coprocessor information in order to make TableDescriptorBuilder accept multiple cp at once Signed-off-by: Ted YuSigned-off-by: Michael Stack Project: http://git-wip-us.apache.org/repos/asf/hbase/repo Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/cb42585a Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/cb42585a Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/cb42585a Branch: refs/heads/branch-2.0 Commit: cb42585a1104e121d0faf9b324a07487807c0095 Parents: 907ec67 Author: Chia-Ping Tsai Authored: Fri Mar 16 01:16:16 2018 +0800 Committer: Chia-Ping Tsai Committed: Fri Mar 16 01:19:03 2018 +0800 -- .../archetypes/exemplars/client/HelloHBase.java | 2 +- .../apache/hadoop/hbase/HTableDescriptor.java | 25 +- .../hbase/client/CoprocessorDescriptor.java | 51 .../client/CoprocessorDescriptorBuilder.java| 118 + .../hadoop/hbase/client/TableDescriptor.java| 7 +- .../hbase/client/TableDescriptorBuilder.java| 244 ++- .../hbase/shaded/protobuf/ProtobufUtil.java | 2 +- .../hbase/client/TestCoprocessorDescriptor.java | 100 .../client/TestTableDescriptorBuilder.java | 82 ++- .../org/apache/hadoop/hbase/HConstants.java | 19 +- .../hbase/coprocessor/TestClassLoading.java | 2 +- .../hbase/coprocessor/TestSecureExport.java | 6 +- .../client/example/ExportEndpointExample.java | 4 +- .../example/TestScanModifyingObserver.java | 4 +- .../example/TestValueReplacingCompaction.java | 4 +- .../TestWriteHeavyIncrementObserver.java| 4 +- ...IncrementObserverWithMemStoreCompaction.java | 4 +- .../TestZooKeeperScanPolicyObserver.java| 4 +- .../hbase/IntegrationTestDDLMasterFailover.java | 2 +- .../hbase/chaos/actions/AddColumnAction.java| 2 +- .../actions/TestChangeSplitPolicyAction.java| 2 +- .../mapreduce/IntegrationTestBulkLoad.java | 2 +- .../hadoop/hbase/mttr/IntegrationTestMTTR.java | 2 +- .../mapreduce/TestCellBasedImportExport2.java | 14 +- .../hbase/mapreduce/TestImportExport.java | 14 +- .../replication/TestVerifyReplication.java | 2 +- .../hbase/rsgroup/TestRSGroupsWithACL.java | 2 +- .../hadoop/hbase/coprocessor/package-info.java | 2 +- .../org/apache/hadoop/hbase/master/HMaster.java | 2 +- .../regionserver/RegionCoprocessorHost.java | 71 +- .../hbase/security/access/AccessController.java | 2 +- .../CoprocessorWhitelistMasterObserver.java | 68 ++ .../hbase/tool/LoadIncrementalHFiles.java | 2 +- .../hadoop/hbase/util/FSTableDescriptors.java | 46 ++-- .../org/apache/hadoop/hbase/util/HBaseFsck.java | 2 +- .../hadoop/hbase/util/RegionSplitter.java | 2 +- .../hadoop/hbase/AcidGuaranteesTestBase.java| 2 +- .../hadoop/hbase/AcidGuaranteesTestTool.java| 2 +- .../hadoop/hbase/HBaseTestingUtility.java | 6 +- .../org/apache/hadoop/hbase/TestZooKeeper.java | 6 +- .../client/AbstractTestCIOperationTimeout.java | 4 +- .../hbase/client/AbstractTestCIRpcTimeout.java | 4 +- .../hadoop/hbase/client/TestAsyncAdminBase.java | 2 +- .../hbase/client/TestAsyncClusterAdminApi.java | 2 +- .../hbase/client/TestAsyncRegionAdminApi.java | 5 +- ...estAsyncReplicationAdminApiWithClusters.java | 4 +- .../hbase/client/TestAsyncTableAdminApi.java| 10 +- .../hbase/client/TestAsyncTableAdminApi2.java | 16 +- .../hbase/client/TestAsyncTableAdminApi3.java | 2 +- .../hbase/client/TestAsyncTableBatch.java | 2 +- .../apache/hadoop/hbase/client/TestCISleep.java | 9 +- .../hbase/client/TestDropTimeoutRequest.java| 4 +- .../hbase/client/TestFromClientSide3.java | 4 +- .../client/TestMalformedCellFromClient.java | 2 +- .../hbase/client/TestReplicaWithCluster.java| 6 +- .../hbase/client/TestResultFromCoprocessor.java | 4 +- .../hbase/client/TestServerLoadDurability.java | 2 +- .../coprocessor/TestCoreRegionCoprocessor.java | 2 +- .../TestPassCustomCellViaRegionObserver.java| 4 +- .../hbase/coprocessor/TestWALObserver.java | 8 +- .../master/TestAssignmentManagerMetrics.java| 10 +- .../hadoop/hbase/master/TestCatalogJanitor.java | 2 +- .../master/assignment/MockMasterServices.java | 2 +- .../assignment/TestRogueRSAssignment.java | 2 +- .../TestFavoredStochasticBalancerPickers.java | 2 +- .../master/cleaner/TestSnapshotFromMaster.java | 3 +- .../MasterProcedureTestingUtility.java | 2 +- .../procedure/TestMasterObserverPostCalls.java | 12 +- .../master/procedure/TestProcedurePriority.java | 2 +- .../regionserver/TestCacheOnWriteInSchema.java | 2 +- .../TestCompactionArchiveConcurrentClose.java | 2 +-
[1/3] hbase git commit: HBASE-20119 Introduce a pojo class to carry coprocessor information in order to make TableDescriptorBuilder accept multiple cp at once
Repository: hbase Updated Branches: refs/heads/branch-2.0 907ec6775 -> cb42585a1 http://git-wip-us.apache.org/repos/asf/hbase/blob/cb42585a/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/wal/AbstractTestFSWAL.java -- diff --git a/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/wal/AbstractTestFSWAL.java b/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/wal/AbstractTestFSWAL.java index 1cdb6e5..5336963 100644 --- a/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/wal/AbstractTestFSWAL.java +++ b/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/wal/AbstractTestFSWAL.java @@ -252,9 +252,9 @@ public abstract class AbstractTestFSWAL { AbstractFSWAL wal = newWAL(FS, CommonFSUtils.getWALRootDir(conf1), DIR.toString(), HConstants.HREGION_OLDLOGDIR_NAME, conf1, null, true, null, null); TableDescriptor t1 = TableDescriptorBuilder.newBuilder(TableName.valueOf("t1")) - .addColumnFamily(ColumnFamilyDescriptorBuilder.of("row")).build(); + .setColumnFamily(ColumnFamilyDescriptorBuilder.of("row")).build(); TableDescriptor t2 = TableDescriptorBuilder.newBuilder(TableName.valueOf("t2")) - .addColumnFamily(ColumnFamilyDescriptorBuilder.of("row")).build(); + .setColumnFamily(ColumnFamilyDescriptorBuilder.of("row")).build(); RegionInfo hri1 = RegionInfoBuilder.newBuilder(t1.getTableName()).build(); RegionInfo hri2 = RegionInfoBuilder.newBuilder(t2.getTableName()).build(); // add edits and roll the wal @@ -361,7 +361,7 @@ public abstract class AbstractTestFSWAL { final RegionInfo hri = RegionInfoBuilder.newBuilder(tableName).build(); final byte[] rowName = tableName.getName(); final TableDescriptor htd = TableDescriptorBuilder.newBuilder(tableName) - .addColumnFamily(ColumnFamilyDescriptorBuilder.of("f")).build(); + .setColumnFamily(ColumnFamilyDescriptorBuilder.of("f")).build(); HRegion r = HBaseTestingUtility.createRegionAndWAL(hri, TEST_UTIL.getDefaultRootDirPath(), TEST_UTIL.getConfiguration(), htd); HBaseTestingUtility.closeRegionAndWAL(r); @@ -449,7 +449,7 @@ public abstract class AbstractTestFSWAL { CONF, null, true, null, null); wal.close(); TableDescriptor td = TableDescriptorBuilder.newBuilder(TableName.valueOf("table")) - .addColumnFamily(ColumnFamilyDescriptorBuilder.of("row")).build(); + .setColumnFamily(ColumnFamilyDescriptorBuilder.of("row")).build(); RegionInfo ri = RegionInfoBuilder.newBuilder(td.getTableName()).build(); MultiVersionConcurrencyControl mvcc = new MultiVersionConcurrencyControl(); NavigableMapscopes = new TreeMap<>(Bytes.BYTES_COMPARATOR); http://git-wip-us.apache.org/repos/asf/hbase/blob/cb42585a/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/wal/AbstractTestLogRolling.java -- diff --git a/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/wal/AbstractTestLogRolling.java b/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/wal/AbstractTestLogRolling.java index c6059b1..610af61 100644 --- a/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/wal/AbstractTestLogRolling.java +++ b/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/wal/AbstractTestLogRolling.java @@ -305,7 +305,7 @@ public abstract class AbstractTestLogRolling { protected Table createTestTable(String tableName) throws IOException { // Create the test table and open it TableDescriptor desc = TableDescriptorBuilder.newBuilder(TableName.valueOf(getName())) - .addColumnFamily(ColumnFamilyDescriptorBuilder.of(HConstants.CATALOG_FAMILY)).build(); + .setColumnFamily(ColumnFamilyDescriptorBuilder.of(HConstants.CATALOG_FAMILY)).build(); admin.createTable(desc); return TEST_UTIL.getConnection().getTable(desc.getTableName()); } http://git-wip-us.apache.org/repos/asf/hbase/blob/cb42585a/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/wal/TestDurability.java -- diff --git a/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/wal/TestDurability.java b/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/wal/TestDurability.java index f5fabbc..4effa6d 100644 --- a/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/wal/TestDurability.java +++ b/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/wal/TestDurability.java @@ -291,7 +291,7 @@ public class TestDurability { private HRegion createHRegion(WALFactory wals, Durability durability) throws IOException { TableName tableName = TableName.valueOf(name.getMethodName().replaceAll("[^A-Za-z0-9-_]", "_")); TableDescriptor htd =
[2/3] hbase git commit: HBASE-20119 Introduce a pojo class to carry coprocessor information in order to make TableDescriptorBuilder accept multiple cp at once
http://git-wip-us.apache.org/repos/asf/hbase/blob/cb42585a/hbase-server/src/main/java/org/apache/hadoop/hbase/security/access/CoprocessorWhitelistMasterObserver.java -- diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/security/access/CoprocessorWhitelistMasterObserver.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/security/access/CoprocessorWhitelistMasterObserver.java index 44a4f57..44f736b 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/security/access/CoprocessorWhitelistMasterObserver.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/security/access/CoprocessorWhitelistMasterObserver.java @@ -21,21 +21,17 @@ package org.apache.hadoop.hbase.security.access; import java.io.IOException; import java.util.Collection; import java.util.Optional; -import java.util.regex.Matcher; - import org.apache.commons.io.FilenameUtils; -import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.fs.Path; import org.apache.hadoop.hbase.HBaseInterfaceAudience; -import org.apache.hadoop.hbase.HConstants; import org.apache.hadoop.hbase.TableName; +import org.apache.hadoop.hbase.client.CoprocessorDescriptor; import org.apache.hadoop.hbase.client.RegionInfo; import org.apache.hadoop.hbase.client.TableDescriptor; import org.apache.hadoop.hbase.coprocessor.MasterCoprocessor; import org.apache.hadoop.hbase.coprocessor.MasterCoprocessorEnvironment; import org.apache.hadoop.hbase.coprocessor.MasterObserver; import org.apache.hadoop.hbase.coprocessor.ObserverContext; -import org.apache.hadoop.hbase.util.Bytes; import org.apache.yetus.audience.InterfaceAudience; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -81,10 +77,8 @@ public class CoprocessorWhitelistMasterObserver implements MasterCoprocessor, Ma * "file:///usr/hbase/coprocessors" or for all * filesystems "/usr/hbase/coprocessors") * @return if the path was found under the wlPath - * @throws IOException if a failure occurs in getting the path file system */ - private static boolean validatePath(Path coprocPath, Path wlPath, - Configuration conf) throws IOException { + private static boolean validatePath(Path coprocPath, Path wlPath) { // verify if all are allowed if (wlPath.toString().equals("*")) { return(true); @@ -143,58 +137,26 @@ public class CoprocessorWhitelistMasterObserver implements MasterCoprocessor, Ma * @param ctx as passed in from the coprocessor * @param htd as passed in from the coprocessor */ - private void verifyCoprocessors(ObserverContext ctx, + private static void verifyCoprocessors(ObserverContext ctx, TableDescriptor htd) throws IOException { - -Configuration conf = ctx.getEnvironment().getConfiguration(); - Collection paths = -conf.getStringCollection( + ctx.getEnvironment().getConfiguration().getStringCollection( CP_COPROCESSOR_WHITELIST_PATHS_KEY); - -Collection coprocs = htd.getCoprocessors(); -for (int i = 0; i < coprocs.size(); i++) { - - String coprocSpec = Bytes.toString(htd.getValue( - Bytes.toBytes("coprocessor$" + (i + 1; - if (coprocSpec == null) { -continue; - } - - // File path is the 1st field of the coprocessor spec - Matcher matcher = - HConstants.CP_HTD_ATTR_VALUE_PATTERN.matcher(coprocSpec); - if (matcher == null || !matcher.matches()) { -continue; - } - - String coprocPathStr = matcher.group(1).trim(); - // Check if coprocessor is being loaded via the classpath (i.e. no file path) - if (coprocPathStr.equals("")) { -break; - } - Path coprocPath = new Path(coprocPathStr); - String coprocessorClass = matcher.group(2).trim(); - - boolean foundPathMatch = false; - for (String pathStr : paths) { -Path wlPath = new Path(pathStr); -try { - foundPathMatch = validatePath(coprocPath, wlPath, conf); - if (foundPathMatch == true) { +for (CoprocessorDescriptor cp : htd.getCoprocessorDescriptors()) { + if (cp.getJarPath().isPresent()) { +if (paths.stream().noneMatch(p -> { + Path wlPath = new Path(p); + if (validatePath(new Path(cp.getJarPath().get()), wlPath)) { LOG.debug(String.format("Coprocessor %s found in directory %s", -coprocessorClass, pathStr)); -break; + cp.getClassName(), p)); +return true; } -} catch (IOException e) { - LOG.warn(String.format("Failed to validate white list path %s for coprocessor path %s", - pathStr, coprocPathStr)); + return false; +})) { + throw new IOException(String.format("Loading %s DENIED in %s", +cp.getClassName(),
[49/51] [partial] hbase-site git commit: Published site at 31da4d0bce69b3a47066a5df675756087ce4dc60.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/a754d895/apidocs/src-html/org/apache/hadoop/hbase/HConstants.html -- diff --git a/apidocs/src-html/org/apache/hadoop/hbase/HConstants.html b/apidocs/src-html/org/apache/hadoop/hbase/HConstants.html index 1d357b9..26b9cc0 100644 --- a/apidocs/src-html/org/apache/hadoop/hbase/HConstants.html +++ b/apidocs/src-html/org/apache/hadoop/hbase/HConstants.html @@ -97,1245 +97,1246 @@ 089NOT_RUN, 090SUCCESS, 091BAD_FAMILY, -092SANITY_CHECK_FAILURE, -093FAILURE -094 } -095 -096 /** long constant for zero */ -097 public static final Long ZERO_L = Long.valueOf(0L); -098 public static final String NINES = "99"; -099 public static final String ZEROES = "00"; -100 -101 // For migration -102 -103 /** name of version file */ -104 public static final String VERSION_FILE_NAME = "hbase.version"; -105 -106 /** -107 * Current version of file system. -108 * Version 4 supports only one kind of bloom filter. -109 * Version 5 changes versions in catalog table regions. -110 * Version 6 enables blockcaching on catalog tables. -111 * Version 7 introduces hfile -- hbase 0.19 to 0.20.. -112 * Version 8 introduces namespace -113 */ -114 // public static final String FILE_SYSTEM_VERSION = "6"; -115 public static final String FILE_SYSTEM_VERSION = "8"; -116 -117 // Configuration parameters -118 -119 //TODO: Is having HBase homed on port 60k OK? -120 -121 /** Cluster is in distributed mode or not */ -122 public static final String CLUSTER_DISTRIBUTED = "hbase.cluster.distributed"; -123 -124 /** Config for pluggable load balancers */ -125 public static final String HBASE_MASTER_LOADBALANCER_CLASS = "hbase.master.loadbalancer.class"; -126 -127 /** Config for balancing the cluster by table */ -128 public static final String HBASE_MASTER_LOADBALANCE_BYTABLE = "hbase.master.loadbalance.bytable"; -129 -130 /** Config for the max percent of regions in transition */ -131 public static final String HBASE_MASTER_BALANCER_MAX_RIT_PERCENT = -132 "hbase.master.balancer.maxRitPercent"; -133 -134 /** Default value for the max percent of regions in transition */ -135 public static final double DEFAULT_HBASE_MASTER_BALANCER_MAX_RIT_PERCENT = 1.0; -136 -137 /** Config for the max balancing time */ -138 public static final String HBASE_BALANCER_MAX_BALANCING = "hbase.balancer.max.balancing"; -139 -140 /** Config for the balancer period */ -141 public static final String HBASE_BALANCER_PERIOD = "hbase.balancer.period"; -142 -143 /** Default value for the balancer period */ -144 public static final int DEFAULT_HBASE_BALANCER_PERIOD = 30; -145 -146 /** The name of the ensemble table */ -147 public static final TableName ENSEMBLE_TABLE_NAME = TableName.valueOf("hbase:ensemble"); -148 -149 /** Config for pluggable region normalizer */ -150 public static final String HBASE_MASTER_NORMALIZER_CLASS = -151"hbase.master.normalizer.class"; -152 -153 /** Cluster is standalone or pseudo-distributed */ -154 public static final boolean CLUSTER_IS_LOCAL = false; -155 -156 /** Default value for cluster distributed mode */ -157 public static final boolean DEFAULT_CLUSTER_DISTRIBUTED = CLUSTER_IS_LOCAL; -158 -159 /** default host address */ -160 public static final String DEFAULT_HOST = "0.0.0.0"; -161 -162 /** Parameter name for port master listens on. */ -163 public static final String MASTER_PORT = "hbase.master.port"; -164 -165 /** default port that the master listens on */ -166 public static final int DEFAULT_MASTER_PORT = 16000; -167 -168 /** default port for master web api */ -169 public static final int DEFAULT_MASTER_INFOPORT = 16010; -170 -171 /** Configuration key for master web API port */ -172 public static final String MASTER_INFO_PORT = "hbase.master.info.port"; -173 -174 /** Parameter name for the master type being backup (waits for primary to go inactive). */ -175 public static final String MASTER_TYPE_BACKUP = "hbase.master.backup"; -176 -177 /** -178 * by default every master is a possible primary master unless the conf explicitly overrides it -179 */ -180 public static final boolean DEFAULT_MASTER_TYPE_BACKUP = false; -181 -182 /** Name of ZooKeeper quorum configuration parameter. */ -183 public static final String ZOOKEEPER_QUORUM = "hbase.zookeeper.quorum"; -184 -185 /** Common prefix of ZooKeeper configuration properties */ -186 public static final String ZK_CFG_PROPERTY_PREFIX = -187 "hbase.zookeeper.property."; -188 -189 public static final int ZK_CFG_PROPERTY_PREFIX_LEN = -190 ZK_CFG_PROPERTY_PREFIX.length(); -191 -192 /** -193 * The ZK client port key in the ZK properties map. The name reflects the -194 * fact that this is not an HBase configuration key. -195 */ -196 public static final String CLIENT_PORT_STR = "clientPort";
[31/51] [partial] hbase-site git commit: Published site at 31da4d0bce69b3a47066a5df675756087ce4dc60.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/a754d895/devapidocs/org/apache/hadoop/hbase/master/MasterRpcServices.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/master/MasterRpcServices.html b/devapidocs/org/apache/hadoop/hbase/master/MasterRpcServices.html index 5f0d8e8..a7531a8 100644 --- a/devapidocs/org/apache/hadoop/hbase/master/MasterRpcServices.html +++ b/devapidocs/org/apache/hadoop/hbase/master/MasterRpcServices.html @@ -119,7 +119,7 @@ var activeTableTab = "activeTableTab"; @InterfaceAudience.Private -public class MasterRpcServices +public class MasterRpcServices extends RSRpcServices implements org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.MasterService.BlockingInterface, org.apache.hadoop.hbase.shaded.protobuf.generated.RegionServerStatusProtos.RegionServerStatusService.BlockingInterface, org.apache.hadoop.hbase.shaded.protobuf.generated.LockServiceProtos.LockService.BlockingInterface Implements the master RPC services. @@ -174,7 +174,7 @@ implements org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.Master Fields inherited from classorg.apache.hadoop.hbase.regionserver.RSRpcServices -REGION_SERVER_RPC_SCHEDULER_FACTORY_CLASS, REGIONSERVER_ADMIN_SERVICE_CONFIG, REGIONSERVER_CLIENT_SERVICE_CONFIG, RESERVOIR_ENABLED_KEY +accessChecker, REGION_SERVER_RPC_SCHEDULER_FACTORY_CLASS, REGIONSERVER_ADMIN_SERVICE_CONFIG, REGIONSERVER_CLIENT_SERVICE_CONFIG, RESERVOIR_ENABLED_KEY @@ -793,7 +793,7 @@ implements org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.Master LOG -private static finalorg.slf4j.Logger LOG +private static finalorg.slf4j.Logger LOG @@ -802,7 +802,7 @@ implements org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.Master master -private finalHMaster master +private finalHMaster master @@ -819,7 +819,7 @@ implements org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.Master MasterRpcServices -publicMasterRpcServices(HMasterm) +publicMasterRpcServices(HMasterm) throws https://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true; title="class or interface in java.io">IOException Throws: @@ -841,7 +841,7 @@ implements org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.Master createConfigurationSubset -privateorg.apache.hadoop.hbase.shaded.protobuf.generated.RegionServerStatusProtos.RegionServerStartupResponse.BuildercreateConfigurationSubset() +privateorg.apache.hadoop.hbase.shaded.protobuf.generated.RegionServerStatusProtos.RegionServerStartupResponse.BuildercreateConfigurationSubset() Returns: Subset of configuration to pass initializing regionservers: e.g. @@ -855,7 +855,7 @@ implements org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.Master addConfig -privateorg.apache.hadoop.hbase.shaded.protobuf.generated.RegionServerStatusProtos.RegionServerStartupResponse.BuilderaddConfig(org.apache.hadoop.hbase.shaded.protobuf.generated.RegionServerStatusProtos.RegionServerStartupResponse.Builderresp, +privateorg.apache.hadoop.hbase.shaded.protobuf.generated.RegionServerStatusProtos.RegionServerStartupResponse.BuilderaddConfig(org.apache.hadoop.hbase.shaded.protobuf.generated.RegionServerStatusProtos.RegionServerStartupResponse.Builderresp, https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">Stringkey) @@ -865,7 +865,7 @@ implements org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.Master createRpcServer -protectedRpcServerInterfacecreateRpcServer(Serverserver, +protectedRpcServerInterfacecreateRpcServer(Serverserver, org.apache.hadoop.conf.Configurationconf, RpcSchedulerFactoryrpcSchedulerFactory, https://docs.oracle.com/javase/8/docs/api/java/net/InetSocketAddress.html?is-external=true; title="class or interface in java.net">InetSocketAddressbindAddress, @@ -885,7 +885,7 @@ implements org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.Master createPriority -protectedPriorityFunctioncreatePriority() +protectedPriorityFunctioncreatePriority() Overrides: createPriorityin classRSRpcServices @@ -898,7 +898,7 @@ implements org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.Master rpcPreCheck -privatevoidrpcPreCheck(https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">StringrequestName) +privatevoidrpcPreCheck(https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in
[41/51] [partial] hbase-site git commit: Published site at 31da4d0bce69b3a47066a5df675756087ce4dc60.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/a754d895/devapidocs/org/apache/hadoop/hbase/MetaTableAccessor.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/MetaTableAccessor.html b/devapidocs/org/apache/hadoop/hbase/MetaTableAccessor.html index 998311f..4c72218 100644 --- a/devapidocs/org/apache/hadoop/hbase/MetaTableAccessor.html +++ b/devapidocs/org/apache/hadoop/hbase/MetaTableAccessor.html @@ -667,7 +667,7 @@ extends https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html getReplicationBarrierResult(Resultresult) -private static long[] +static long[] getReplicationBarriers(Resultresult) @@ -2096,7 +2096,7 @@ public static getTableStates -public statichttps://docs.oracle.com/javase/8/docs/api/java/util/Map.html?is-external=true; title="class or interface in java.util">MapTableName,TableStategetTableStates(Connectionconn) +public statichttps://docs.oracle.com/javase/8/docs/api/java/util/Map.html?is-external=true; title="class or interface in java.util">MapTableName,TableStategetTableStates(Connectionconn) throws https://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true; title="class or interface in java.io">IOException Fetch table states from META table @@ -2115,7 +2115,7 @@ public static updateTableState -public staticvoidupdateTableState(Connectionconn, +public staticvoidupdateTableState(Connectionconn, TableNametableName, TableState.Stateactual) throws https://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true; title="class or interface in java.io">IOException @@ -2136,7 +2136,7 @@ public static getTableState @Nullable -public staticTableStategetTableState(Resultr) +public staticTableStategetTableState(Resultr) throws https://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true; title="class or interface in java.io">IOException Decode table state from META Result. Should contain cell from HConstants.TABLE_FAMILY @@ -2156,7 +2156,7 @@ public static getRegionCount -public staticintgetRegionCount(org.apache.hadoop.conf.Configurationc, +public staticintgetRegionCount(org.apache.hadoop.conf.Configurationc, TableNametableName) throws https://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true; title="class or interface in java.io">IOException Count regions in hbase:meta for passed table. @@ -2177,7 +2177,7 @@ public static getRegionCount -public staticintgetRegionCount(Connectionconnection, +public staticintgetRegionCount(Connectionconnection, TableNametableName) throws https://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true; title="class or interface in java.io">IOException Count regions in hbase:meta for passed table. @@ -2198,7 +2198,7 @@ public static makePutFromRegionInfo -public staticPutmakePutFromRegionInfo(RegionInforegionInfo, +public staticPutmakePutFromRegionInfo(RegionInforegionInfo, longts) throws https://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true; title="class or interface in java.io">IOException Generates and returns a Put containing the region into for the catalog table @@ -2214,7 +2214,7 @@ public static makeDeleteFromRegionInfo -private staticDeletemakeDeleteFromRegionInfo(RegionInforegionInfo, +private staticDeletemakeDeleteFromRegionInfo(RegionInforegionInfo, longts) Generates and returns a Delete containing the region info for the catalog table @@ -2226,7 +2226,7 @@ public static addDaughtersToPut -public staticPutaddDaughtersToPut(Putput, +public staticPutaddDaughtersToPut(Putput, RegionInfosplitA, RegionInfosplitB) throws https://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true; title="class or interface in java.io">IOException @@ -2243,7 +2243,7 @@ public static putToMetaTable -private staticvoidputToMetaTable(Connectionconnection, +private staticvoidputToMetaTable(Connectionconnection, Putp) throws https://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true; title="class or interface in java.io">IOException Put the passed p to the hbase:meta table. @@ -2262,7 +2262,7 @@ public static put -private staticvoidput(Tablet, +private staticvoidput(Tablet, Putp) throws
[51/51] [partial] hbase-site git commit: Published site at 31da4d0bce69b3a47066a5df675756087ce4dc60.
Published site at 31da4d0bce69b3a47066a5df675756087ce4dc60. Project: http://git-wip-us.apache.org/repos/asf/hbase-site/repo Commit: http://git-wip-us.apache.org/repos/asf/hbase-site/commit/a754d895 Tree: http://git-wip-us.apache.org/repos/asf/hbase-site/tree/a754d895 Diff: http://git-wip-us.apache.org/repos/asf/hbase-site/diff/a754d895 Branch: refs/heads/asf-site Commit: a754d89566af24e55f540db6415aab07e07c8e6c Parents: 291a8cf Author: jenkinsAuthored: Thu Mar 15 14:53:40 2018 + Committer: jenkins Committed: Thu Mar 15 14:53:40 2018 + -- acid-semantics.html | 4 +- apache_hbase_reference_guide.pdf| 4 +- apidocs/org/apache/hadoop/hbase/HConstants.html | 622 +- .../org/apache/hadoop/hbase/HConstants.html | 2471 +-- book.html | 2 +- bulk-loads.html | 4 +- checkstyle-aggregate.html | 16786 - checkstyle.rss | 258 +- coc.html| 4 +- cygwin.html | 4 +- dependencies.html | 4 +- dependency-convergence.html | 4 +- dependency-info.html| 4 +- dependency-management.html | 4 +- devapidocs/allclasses-frame.html| 6 + devapidocs/allclasses-noframe.html | 6 + devapidocs/constant-values.html | 114 +- devapidocs/index-all.html | 282 +- .../hbase/HConstants.OperationStatusCode.html |16 +- .../org/apache/hadoop/hbase/HConstants.html | 624 +- .../MetaTableAccessor.CloseableVisitor.html | 2 +- .../MetaTableAccessor.CollectAllVisitor.html| 6 +- .../MetaTableAccessor.CollectingVisitor.html|12 +- .../MetaTableAccessor.DefaultVisitorBase.html | 8 +- ...aTableAccessor.ReplicationBarrierResult.html |18 +- .../MetaTableAccessor.TableVisitorBase.html | 8 +- .../hadoop/hbase/MetaTableAccessor.Visitor.html | 4 +- .../apache/hadoop/hbase/MetaTableAccessor.html | 104 +- .../org/apache/hadoop/hbase/ScheduledChore.html | 2 +- .../hbase/backup/master/BackupLogCleaner.html |20 +- .../master/LogRollMasterProcedureManager.html |86 +- .../hbase/backup/master/package-summary.html| 2 +- .../hadoop/hbase/backup/package-tree.html | 4 +- .../org/apache/hadoop/hbase/class-use/Cell.html |54 +- .../hbase/class-use/HBaseIOException.html |92 + .../hbase/class-use/RegionTooBusyException.html |22 + .../hadoop/hbase/class-use/ScheduledChore.html |20 + .../hadoop/hbase/class-use/ServerName.html | 110 +- .../hadoop/hbase/class-use/Stoppable.html | 8 +- .../hadoop/hbase/class-use/TableName.html |41 +- .../apache/hadoop/hbase/client/TableState.html | 107 +- .../hbase/client/class-use/Connection.html |66 +- .../hadoop/hbase/client/class-use/Mutation.html |34 +- .../hadoop/hbase/client/class-use/Result.html |40 +- .../hadoop/hbase/client/class-use/Table.html|66 +- .../class-use/TableDescriptorBuilder.html |24 + .../client/class-use/TableState.State.html |42 +- .../hbase/client/class-use/TableState.html |17 + .../hadoop/hbase/client/package-tree.html |20 +- .../apache/hadoop/hbase/client/package-use.html |83 +- .../hadoop/hbase/constraint/Constraints.html|72 +- .../coprocessor/AggregateImplementation.html|30 +- .../class-use/MergeRegionException.html |19 - .../hadoop/hbase/filter/package-tree.html |10 +- .../hadoop/hbase/io/hfile/package-tree.html | 6 +- .../org/apache/hadoop/hbase/ipc/CallRunner.html | 2 +- .../apache/hadoop/hbase/ipc/package-tree.html | 2 +- .../MultithreadedTableMapper.MapRunner.html | 2 +- ...TableSnapshotInputFormatImpl.InputSplit.html |34 +- ...bleSnapshotInputFormatImpl.RecordReader.html |30 +- .../mapreduce/TableSnapshotInputFormatImpl.html |48 +- .../hadoop/hbase/mapreduce/package-tree.html| 4 +- .../master/HMaster.InitializationMonitor.html |20 +- .../master/HMaster.MasterStoppedException.html | 4 +- .../hbase/master/HMaster.RedirectServlet.html |12 +- .../org/apache/hadoop/hbase/master/HMaster.html | 848 +- .../master/HMasterCommandLine.LocalHMaster.html | 4 +- ...MasterCoprocessorHost.MasterEnvironment.html |18 +- ...st.MasterEnvironmentForCoreCoprocessors.html | 8 +- ...CoprocessorHost.MasterObserverOperation.html |10 +- .../hbase/master/MasterCoprocessorHost.html | 292 +- .../MasterRpcServices.BalanceSwitchMode.html| 6 +-
[47/51] [partial] hbase-site git commit: Published site at 31da4d0bce69b3a47066a5df675756087ce4dc60.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/a754d895/checkstyle-aggregate.html -- diff --git a/checkstyle-aggregate.html b/checkstyle-aggregate.html index fae1ab8..17e0b65 100644 --- a/checkstyle-aggregate.html +++ b/checkstyle-aggregate.html @@ -7,7 +7,7 @@ - + Apache HBase Checkstyle Results @@ -274,10 +274,10 @@ Warnings Errors -3577 +3586 0 0 -16120 +16104 Files @@ -1640,7 +1640,7 @@ org/apache/hadoop/hbase/client/TableState.java 0 0 -36 +35 org/apache/hadoop/hbase/client/TestAdmin1.java 0 @@ -2417,7841 +2417,7836 @@ 0 4 -org/apache/hadoop/hbase/coprocessor/TestCoprocessorHost.java -0 -0 -7 - org/apache/hadoop/hbase/coprocessor/TestCoprocessorInterface.java 0 0 2 - + org/apache/hadoop/hbase/coprocessor/TestCoprocessorMetrics.java 0 0 1 - + org/apache/hadoop/hbase/coprocessor/TestCoprocessorServiceBackwardCompatibility.java 0 0 1 - + org/apache/hadoop/hbase/coprocessor/TestCoprocessorStop.java 0 0 1 - + org/apache/hadoop/hbase/coprocessor/TestCoprocessorTableEndpoint.java 0 0 3 - + org/apache/hadoop/hbase/coprocessor/TestCoreMasterCoprocessor.java 0 0 1 - + org/apache/hadoop/hbase/coprocessor/TestCoreRegionCoprocessor.java 0 0 2 - + org/apache/hadoop/hbase/coprocessor/TestCoreRegionServerCoprocessor.java 0 0 1 - + org/apache/hadoop/hbase/coprocessor/TestMasterCoprocessorExceptionWithAbort.java 0 0 9 - + org/apache/hadoop/hbase/coprocessor/TestMasterCoprocessorExceptionWithRemove.java 0 0 7 - + org/apache/hadoop/hbase/coprocessor/TestMasterObserver.java 0 0 2 - + org/apache/hadoop/hbase/coprocessor/TestOpenTableInCoprocessor.java 0 0 2 - + org/apache/hadoop/hbase/coprocessor/TestRegionObserverBypass.java 0 0 2 - + org/apache/hadoop/hbase/coprocessor/TestRegionObserverForAddingMutationsFromCoprocessors.java 0 0 3 - + org/apache/hadoop/hbase/coprocessor/TestRegionObserverInterface.java 0 0 26 - + org/apache/hadoop/hbase/coprocessor/TestRegionObserverScannerOpenHook.java 0 0 7 - + org/apache/hadoop/hbase/coprocessor/TestRegionObserverStacking.java 0 0 1 - + org/apache/hadoop/hbase/coprocessor/TestRowProcessorEndpoint.java 0 0 2 - + org/apache/hadoop/hbase/coprocessor/TestSecureExport.java 0 0 18 - + org/apache/hadoop/hbase/coprocessor/WALCoprocessor.java 0 0 1 - + org/apache/hadoop/hbase/coprocessor/WALCoprocessorEnvironment.java 0 0 1 - + org/apache/hadoop/hbase/coprocessor/WALObserver.java 0 0 2 - + org/apache/hadoop/hbase/coprocessor/example/BulkDeleteEndpoint.java 0 0 3 - + org/apache/hadoop/hbase/coprocessor/example/ExampleMasterObserverWithMetrics.java 0 0 1 - + org/apache/hadoop/hbase/coprocessor/example/RefreshHFilesEndpoint.java 0 0 2 - + org/apache/hadoop/hbase/coprocessor/example/RowCountEndpoint.java 0 0 1 - + org/apache/hadoop/hbase/coprocessor/example/TestRefreshHFilesEndpoint.java 0 0 5 - + org/apache/hadoop/hbase/coprocessor/package-info.java 0 0 1 - + org/apache/hadoop/hbase/errorhandling/ForeignException.java 0 0 7 - + org/apache/hadoop/hbase/errorhandling/ForeignExceptionDispatcher.java 0 0 1 - + org/apache/hadoop/hbase/errorhandling/TestForeignExceptionDispatcher.java 0 0 2 - + org/apache/hadoop/hbase/errorhandling/TestForeignExceptionSerialization.java 0 0 1 - + org/apache/hadoop/hbase/errorhandling/TimeoutExceptionInjector.java 0 0 2 - + org/apache/hadoop/hbase/exceptions/ClientExceptionsUtil.java 0 0 2 - + org/apache/hadoop/hbase/exceptions/FailedSanityCheckException.java 0 0 3 - + org/apache/hadoop/hbase/exceptions/MergeRegionException.java 0 0 1 - + org/apache/hadoop/hbase/exceptions/TestClientExceptionsUtil.java 0 0 1 - + org/apache/hadoop/hbase/executor/EventHandler.java 0 0 1 - + org/apache/hadoop/hbase/executor/EventType.java 0 0 39 - + org/apache/hadoop/hbase/executor/ExecutorService.java 0 0 5 - + org/apache/hadoop/hbase/executor/ExecutorType.java 0 0 19 - + org/apache/hadoop/hbase/favored/FavoredNodeAssignmentHelper.java 0 0 25 - + org/apache/hadoop/hbase/favored/FavoredNodeLoadBalancer.java 0 0 4 - + org/apache/hadoop/hbase/favored/FavoredNodesPlan.java 0 0 6 - + org/apache/hadoop/hbase/favored/FavoredNodesPromoter.java 0 0 2 - + org/apache/hadoop/hbase/favored/StartcodeAgnosticServerName.java 0 0 5 - + org/apache/hadoop/hbase/favored/TestFavoredNodeAssignmentHelper.java 0 0 2 - + org/apache/hadoop/hbase/filter/BigDecimalComparator.java 0 0 1 - + org/apache/hadoop/hbase/filter/BinaryComparator.java 0 0 7 - + org/apache/hadoop/hbase/filter/BinaryPrefixComparator.java 0 0 7 - + org/apache/hadoop/hbase/filter/BitComparator.java 0 0 9 - + org/apache/hadoop/hbase/filter/ByteArrayComparable.java 0 0 4 - + org/apache/hadoop/hbase/filter/ColumnCountGetFilter.java 0 0 8 - + org/apache/hadoop/hbase/filter/ColumnPaginationFilter.java
[34/51] [partial] hbase-site git commit: Published site at 31da4d0bce69b3a47066a5df675756087ce4dc60.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/a754d895/devapidocs/org/apache/hadoop/hbase/master/HMasterCommandLine.LocalHMaster.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/master/HMasterCommandLine.LocalHMaster.html b/devapidocs/org/apache/hadoop/hbase/master/HMasterCommandLine.LocalHMaster.html index 8b1c4bd..0b237ab 100644 --- a/devapidocs/org/apache/hadoop/hbase/master/HMasterCommandLine.LocalHMaster.html +++ b/devapidocs/org/apache/hadoop/hbase/master/HMasterCommandLine.LocalHMaster.html @@ -254,7 +254,7 @@ extends Methods inherited from classorg.apache.hadoop.hbase.regionserver.HRegionServer -abort, addRegion, addToMovedRegions, checkFileSystem, cleanMovedRegions, clearRegionBlockCache, closeAllRegions, href="../../../../../org/apache/hadoop/hbase/regionserver/HRegionServer.html#closeAndOfflineRegionForSplitOrMerge-java.util.List-">closeAndOfflineRegionForSplitOrMerge, > href="../../../../../org/apache/hadoop/hbase/regionserver/HRegionServer.html#closeRegion-java.lang.String-boolean-org.apache.hadoop.hbase.ServerName-">closeRegion, > href="../../../../../org/apache/hadoop/hbase/regionserver/HRegionServer.html#constructRegionServer-java.lang.Class-org.apache.hadoop.conf.Configuration-">constructRegionServer, > href="../../../../../org/apache/hadoop/hbase/regionserver/HRegionServer.html#convertThrowableToIOE-java.lang.Throwable-java.lang.String-">convertThrowableToIOE, > href="../../../../../org/apache/hadoop/hbase/regionserver/HRegionServer.html#createClusterConnection--">createClusterConnection, > href="../../../../../org/apache/hadoop/hbase/regionserver/HRegionServer.html#createConnection-org.apache.hadoop.conf.Configuration-">createConnection, > < a href="../../../../../org/apache/hadoop/hbase/regionserver/HRegionServer.html#createRegionLoad-java.lang.String-">createRegionLoad, createRegionServerStatusStub, createRegionServerStatusStub, execRegionServerService, executeProcedure, getCacheConfig, getChoreService, getClusterConnection, getClusterId, getCompactionPressure, getCompactionRequestor, getCompactSplitThread, getConfiguration, getConfigurationManager, getConnection, getCoordinatedStateManager, getEventLoopGroupConfig, getExecutorService, getFavoredNodesForRegion, getFileSystem, getFlushPressure, getFlushRequester, getFlushThroughputController, getFsTableDescriptors, getHeapMemoryManager, getInfoServer, getLastSequenceId, getLeases, getMasterAddressTracker, getMetaTableLocator, getMetrics, getMostLoadedRegions, getNonceManager, getNumberOfOnlineRegions, getOnlineRegion, getOnlineRegionsLocalContext, getOnlineTabl es, getRegion, getRegion, getRegionBlockLocations, getRegionByEncodedName, getRegionByEncodedName, getRegions, getRegions, getRegionServerAccounting, getRegionServerCoprocessorHost, getRegionServerCoprocessors, getRegionServerMetrics, getRegionServerRpcQuotaManager, getRegionServerSpaceQuotaManager, getRegionsInTransitionInRS, getReplicationSourceService, getRootDir, getRpcServer, getRSRpcServices, getSecureBulkLoadManager, getStartcode, getThreadWakeFrequency, getWAL, getWALFileSystem, getWalRoller, getWALRootDir, getWALs, handleReportForDutyResponse, initializeMemStoreChunkCreator, isAborted, isOnline, isStopped, isStopping, kill, movedRegionCleanerPeriod, onConfigurationChange, postOpenDeployTasks, regionLock, remoteProcedureComplete, removeRegion, reportFileArchivalForQuotas, reportRegionSizesForQuotas, reportRegionStateTransition, sendShutdownInterrupt, setupClusterConnection, stop, toString, tryRegionServerReport, unassign, updateConfiguration, updateRegionFavoredNodesMapping, waitForServerOnline, walRollRequestFinished +abort, addRegion, addToMovedRegions, checkFileSystem, cleanMovedRegions, clearRegionBlockCache, closeAllRegions, href="../../../../../org/apache/hadoop/hbase/regionserver/HRegionServer.html#closeAndOfflineRegionForSplitOrMerge-java.util.List-">closeAndOfflineRegionForSplitOrMerge, > href="../../../../../org/apache/hadoop/hbase/regionserver/HRegionServer.html#closeRegion-java.lang.String-boolean-org.apache.hadoop.hbase.ServerName-">closeRegion, > href="../../../../../org/apache/hadoop/hbase/regionserver/HRegionServer.html#constructRegionServer-java.lang.Class-org.apache.hadoop.conf.Configuration-">constructRegionServer, > href="../../../../../org/apache/hadoop/hbase/regionserver/HRegionServer.html#convertThrowableToIOE-java.lang.Throwable-java.lang.String-">convertThrowableToIOE, > href="../../../../../org/apache/hadoop/hbase/regionserver/HRegionServer.html#createClusterConnection--">createClusterConnection, > href="../../../../../org/apache/hadoop/hbase/regionserver/HRegionServer.html#createConnection-org.apache.hadoop.conf.Configuration-">createConnection, > < a
[46/51] [partial] hbase-site git commit: Published site at 31da4d0bce69b3a47066a5df675756087ce4dc60.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/a754d895/checkstyle.rss -- diff --git a/checkstyle.rss b/checkstyle.rss index dee56cd..6fdf162 100644 --- a/checkstyle.rss +++ b/checkstyle.rss @@ -25,8 +25,8 @@ under the License. en-us 2007 - 2018 The Apache Software Foundation - File: 3577, - Errors: 16120, + File: 3586, + Errors: 16104, Warnings: 0, Infos: 0 @@ -2006,6 +2006,20 @@ under the License. + http://hbase.apache.org/checkstyle.html#org.apache.hadoop.hbase.master.cleaner.TestReplicationBarrierCleaner.java;>org/apache/hadoop/hbase/master/cleaner/TestReplicationBarrierCleaner.java + + + 0 + + + 0 + + + 0 + + + + http://hbase.apache.org/checkstyle.html#org.apache.hadoop.hbase.io.MetricsIOWrapperImpl.java;>org/apache/hadoop/hbase/io/MetricsIOWrapperImpl.java @@ -6038,6 +6052,20 @@ under the License. + http://hbase.apache.org/checkstyle.html#org.apache.hadoop.hbase.replication.storage.TestZKReplicationQueueStorage.java;>org/apache/hadoop/hbase/replication/storage/TestZKReplicationQueueStorage.java + + + 0 + + + 0 + + + 0 + + + + http://hbase.apache.org/checkstyle.html#org.apache.hadoop.hbase.spark.example.hbasecontext.JavaHBaseDistributedScan.java;>org/apache/hadoop/hbase/spark/example/hbasecontext/JavaHBaseDistributedScan.java @@ -6803,7 +6831,7 @@ under the License. 0 - 8 + 9 @@ -9370,6 +9398,20 @@ under the License. + http://hbase.apache.org/checkstyle.html#org.apache.hadoop.hbase.replication.storage.TestReplicationStateBasic.java;>org/apache/hadoop/hbase/replication/storage/TestReplicationStateBasic.java + + + 0 + + + 0 + + + 0 + + + + http://hbase.apache.org/checkstyle.html#org.apache.hadoop.hbase.filter.TestNullComparator.java;>org/apache/hadoop/hbase/filter/TestNullComparator.java @@ -15511,7 +15553,7 @@ under the License. 0 - 1 + 2 @@ -19086,6 +19128,20 @@ under the License. + http://hbase.apache.org/checkstyle.html#org.apache.hadoop.hbase.regionserver.TestRegionMove.java;>org/apache/hadoop/hbase/regionserver/TestRegionMove.java + + + 0 + + + 0 + + + 0 + + + + http://hbase.apache.org/checkstyle.html#org.apache.hadoop.hbase.security.access.TestCellACLWithMultipleVersions.java;>org/apache/hadoop/hbase/security/access/TestCellACLWithMultipleVersions.java @@ -19982,6 +20038,20 @@ under the License. + http://hbase.apache.org/checkstyle.html#org.apache.hadoop.hbase.replication.TableReplicationStorageBase.java;>org/apache/hadoop/hbase/replication/TableReplicationStorageBase.java + + + 0 + + + 0 + + + 0 + + + + http://hbase.apache.org/checkstyle.html#org.apache.hadoop.hbase.io.TestByteBufferOutputStream.java;>org/apache/hadoop/hbase/io/TestByteBufferOutputStream.java @@ -20444,6 +20514,20 @@ under the License. +
[23/51] [partial] hbase-site git commit: Published site at 31da4d0bce69b3a47066a5df675756087ce4dc60.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/a754d895/devapidocs/org/apache/hadoop/hbase/master/procedure/ModifyTableProcedure.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/master/procedure/ModifyTableProcedure.html b/devapidocs/org/apache/hadoop/hbase/master/procedure/ModifyTableProcedure.html index 9ae4f41..5950b5e 100644 --- a/devapidocs/org/apache/hadoop/hbase/master/procedure/ModifyTableProcedure.html +++ b/devapidocs/org/apache/hadoop/hbase/master/procedure/ModifyTableProcedure.html @@ -129,7 +129,7 @@ var activeTableTab = "activeTableTab"; @InterfaceAudience.Private -public class ModifyTableProcedure +public class ModifyTableProcedure extends AbstractStateMachineTableProcedureorg.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.ModifyTableState @@ -400,7 +400,7 @@ extends AbstractStateMachineTableProcedure -acquireLock, checkTableModifiable, getRegionDir, getUser, releaseLock, < a href="../../../../../../org/apache/hadoop/hbase/master/procedure/AbstractStateMachineTableProcedure.html#releaseSyncLatch--">releaseSyncLatch, setUser, toStringClassDetails +acquireLock, checkTableModifiable, getRegionDir, getUser, preflightChecks, releaseLock, releaseSyncLatch, setUser, toStringClassDetails @@ -443,7 +443,7 @@ extends LOG -private static finalorg.slf4j.Logger LOG +private static finalorg.slf4j.Logger LOG @@ -452,7 +452,7 @@ extends unmodifiedTableDescriptor -privateTableDescriptor unmodifiedTableDescriptor +privateTableDescriptor unmodifiedTableDescriptor @@ -461,7 +461,7 @@ extends modifiedTableDescriptor -privateTableDescriptor modifiedTableDescriptor +privateTableDescriptor modifiedTableDescriptor @@ -470,7 +470,7 @@ extends deleteColumnFamilyInModify -privateboolean deleteColumnFamilyInModify +privateboolean deleteColumnFamilyInModify @@ -479,7 +479,7 @@ extends regionInfoList -privatehttps://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true; title="class or interface in java.util">ListRegionInfo regionInfoList +privatehttps://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true; title="class or interface in java.util">ListRegionInfo regionInfoList @@ -488,7 +488,7 @@ extends traceEnabled -privatehttps://docs.oracle.com/javase/8/docs/api/java/lang/Boolean.html?is-external=true; title="class or interface in java.lang">Boolean traceEnabled +privatehttps://docs.oracle.com/javase/8/docs/api/java/lang/Boolean.html?is-external=true; title="class or interface in java.lang">Boolean traceEnabled @@ -505,7 +505,7 @@ extends ModifyTableProcedure -publicModifyTableProcedure() +publicModifyTableProcedure() @@ -514,8 +514,13 @@ extends ModifyTableProcedure -publicModifyTableProcedure(MasterProcedureEnvenv, -TableDescriptorhtd) +publicModifyTableProcedure(MasterProcedureEnvenv, +TableDescriptorhtd) + throws HBaseIOException + +Throws: +HBaseIOException + @@ -524,9 +529,14 @@ extends ModifyTableProcedure -publicModifyTableProcedure(MasterProcedureEnvenv, +publicModifyTableProcedure(MasterProcedureEnvenv, TableDescriptorhtd, -ProcedurePrepareLatchlatch) +ProcedurePrepareLatchlatch) + throws HBaseIOException + +Throws: +HBaseIOException + @@ -543,7 +553,7 @@ extends initilize -privatevoidinitilize() +privatevoidinitilize() @@ -552,7 +562,7 @@ extends executeFromState -protectedStateMachineProcedure.FlowexecuteFromState(MasterProcedureEnvenv, +protectedStateMachineProcedure.FlowexecuteFromState(MasterProcedureEnvenv, org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.ModifyTableStatestate) throws https://docs.oracle.com/javase/8/docs/api/java/lang/InterruptedException.html?is-external=true; title="class or interface in java.lang">InterruptedException Description copied from class:StateMachineProcedure @@ -575,7 +585,7 @@ extends rollbackState -protectedvoidrollbackState(MasterProcedureEnvenv, +protectedvoidrollbackState(MasterProcedureEnvenv, org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.ModifyTableStatestate) throws https://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true; title="class or interface in java.io">IOException Description copied from class:StateMachineProcedure @@ -595,7 +605,7 @@ extends isRollbackSupported -protectedbooleanisRollbackSupported(org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.ModifyTableStatestate)
[32/51] [partial] hbase-site git commit: Published site at 31da4d0bce69b3a47066a5df675756087ce4dc60.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/a754d895/devapidocs/org/apache/hadoop/hbase/master/MasterRpcServices.BalanceSwitchMode.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/master/MasterRpcServices.BalanceSwitchMode.html b/devapidocs/org/apache/hadoop/hbase/master/MasterRpcServices.BalanceSwitchMode.html index 48da12a..89ff005 100644 --- a/devapidocs/org/apache/hadoop/hbase/master/MasterRpcServices.BalanceSwitchMode.html +++ b/devapidocs/org/apache/hadoop/hbase/master/MasterRpcServices.BalanceSwitchMode.html @@ -122,7 +122,7 @@ var activeTableTab = "activeTableTab"; -static enum MasterRpcServices.BalanceSwitchMode +static enum MasterRpcServices.BalanceSwitchMode extends https://docs.oracle.com/javase/8/docs/api/java/lang/Enum.html?is-external=true; title="class or interface in java.lang">EnumMasterRpcServices.BalanceSwitchMode @@ -210,7 +210,7 @@ the order they are declared. SYNC -public static finalMasterRpcServices.BalanceSwitchMode SYNC +public static finalMasterRpcServices.BalanceSwitchMode SYNC @@ -219,7 +219,7 @@ the order they are declared. ASYNC -public static finalMasterRpcServices.BalanceSwitchMode ASYNC +public static finalMasterRpcServices.BalanceSwitchMode ASYNC
[33/51] [partial] hbase-site git commit: Published site at 31da4d0bce69b3a47066a5df675756087ce4dc60.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/a754d895/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 2393a78..51a2cee 100644 --- a/devapidocs/org/apache/hadoop/hbase/master/MasterCoprocessorHost.html +++ b/devapidocs/org/apache/hadoop/hbase/master/MasterCoprocessorHost.html @@ -115,7 +115,7 @@ var activeTableTab = "activeTableTab"; @InterfaceAudience.Private -public class MasterCoprocessorHost +public class MasterCoprocessorHost extends CoprocessorHostMasterCoprocessor,MasterCoprocessorEnvironment Provides the coprocessor framework and environment for master oriented operations. HMaster interacts with the loaded coprocessors @@ -956,7 +956,7 @@ extends LOG -private static finalorg.slf4j.Logger LOG +private static finalorg.slf4j.Logger LOG @@ -965,7 +965,7 @@ extends masterServices -privateMasterServices masterServices +privateMasterServices masterServices @@ -974,7 +974,7 @@ extends masterObserverGetter -privateCoprocessorHost.ObserverGetterMasterCoprocessor,MasterObserver masterObserverGetter +privateCoprocessorHost.ObserverGetterMasterCoprocessor,MasterObserver masterObserverGetter @@ -991,7 +991,7 @@ extends MasterCoprocessorHost -publicMasterCoprocessorHost(MasterServicesservices, +publicMasterCoprocessorHost(MasterServicesservices, org.apache.hadoop.conf.Configurationconf) @@ -1009,7 +1009,7 @@ extends createEnvironment -publicMasterCoprocessorHost.MasterEnvironmentcreateEnvironment(MasterCoprocessorinstance, +publicMasterCoprocessorHost.MasterEnvironmentcreateEnvironment(MasterCoprocessorinstance, intpriority, intseq, org.apache.hadoop.conf.Configurationconf) @@ -1027,7 +1027,7 @@ extends checkAndGetInstance -publicMasterCoprocessorcheckAndGetInstance(https://docs.oracle.com/javase/8/docs/api/java/lang/Class.html?is-external=true; title="class or interface in java.lang">Class?implClass) +publicMasterCoprocessorcheckAndGetInstance(https://docs.oracle.com/javase/8/docs/api/java/lang/Class.html?is-external=true; title="class or interface in java.lang">Class?implClass) throws https://docs.oracle.com/javase/8/docs/api/java/lang/InstantiationException.html?is-external=true; title="class or interface in java.lang">InstantiationException, https://docs.oracle.com/javase/8/docs/api/java/lang/IllegalAccessException.html?is-external=true; title="class or interface in java.lang">IllegalAccessException Description copied from class:CoprocessorHost @@ -1051,7 +1051,7 @@ extends preCreateNamespace -publicvoidpreCreateNamespace(NamespaceDescriptorns) +publicvoidpreCreateNamespace(NamespaceDescriptorns) throws https://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true; title="class or interface in java.io">IOException Throws: @@ -1065,7 +1065,7 @@ extends postCreateNamespace -publicvoidpostCreateNamespace(NamespaceDescriptorns) +publicvoidpostCreateNamespace(NamespaceDescriptorns) throws https://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true; title="class or interface in java.io">IOException Throws: @@ -1079,7 +1079,7 @@ extends preDeleteNamespace -publicvoidpreDeleteNamespace(https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">StringnamespaceName) +publicvoidpreDeleteNamespace(https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">StringnamespaceName) throws https://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true; title="class or interface in java.io">IOException Throws: @@ -1093,7 +1093,7 @@ extends postDeleteNamespace -publicvoidpostDeleteNamespace(https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">StringnamespaceName) +publicvoidpostDeleteNamespace(https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">StringnamespaceName) throws https://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true; title="class or interface in java.io">IOException Throws: @@ -1107,7 +1107,7 @@ extends preModifyNamespace -publicvoidpreModifyNamespace(NamespaceDescriptorns)
[26/51] [partial] hbase-site git commit: Published site at 31da4d0bce69b3a47066a5df675756087ce4dc60.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/a754d895/devapidocs/org/apache/hadoop/hbase/master/assignment/MoveRegionProcedure.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/master/assignment/MoveRegionProcedure.html b/devapidocs/org/apache/hadoop/hbase/master/assignment/MoveRegionProcedure.html index 5d49f63..561fb67 100644 --- a/devapidocs/org/apache/hadoop/hbase/master/assignment/MoveRegionProcedure.html +++ b/devapidocs/org/apache/hadoop/hbase/master/assignment/MoveRegionProcedure.html @@ -134,12 +134,15 @@ var activeTableTab = "activeTableTab"; @InterfaceAudience.Private -public class MoveRegionProcedure +public class MoveRegionProcedure extends AbstractStateMachineRegionProcedureorg.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.MoveRegionState Procedure that implements a RegionPlan. It first runs an unassign subprocedure followed by an assign subprocedure. It takes a lock on the region being moved. - It holds the lock for the life of the procedure. + It holds the lock for the life of the procedure. + + Throws exception on construction if determines context hostile to move (cluster going + down or master is shutting down or table is disabled). @@ -321,7 +324,7 @@ extends AbstractStateMachineTableProcedure -getRegionDir, getUser, releaseSyncLatch, setUser +getRegionDir, getUser, preflightChecks, releaseSyncLatch, setUser @@ -364,7 +367,7 @@ extends LOG -private static finalorg.slf4j.Logger LOG +private static finalorg.slf4j.Logger LOG @@ -373,7 +376,7 @@ extends plan -privateRegionPlan plan +privateRegionPlan plan @@ -390,7 +393,7 @@ extends MoveRegionProcedure -publicMoveRegionProcedure() +publicMoveRegionProcedure() @@ -399,8 +402,15 @@ extends MoveRegionProcedure -publicMoveRegionProcedure(MasterProcedureEnvenv, - RegionPlanplan) +publicMoveRegionProcedure(MasterProcedureEnvenv, + RegionPlanplan) +throws HBaseIOException + +Throws: +https://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true; title="class or interface in java.io">IOException - If the cluster is offline or master is stopping or if table is disabled + or non-existent. +HBaseIOException + @@ -417,7 +427,7 @@ extends executeFromState -protectedStateMachineProcedure.FlowexecuteFromState(MasterProcedureEnvenv, +protectedStateMachineProcedure.FlowexecuteFromState(MasterProcedureEnvenv, org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.MoveRegionStatestate) throws https://docs.oracle.com/javase/8/docs/api/java/lang/InterruptedException.html?is-external=true; title="class or interface in java.lang">InterruptedException Description copied from class:StateMachineProcedure @@ -440,7 +450,7 @@ extends rollbackState -protectedvoidrollbackState(MasterProcedureEnvenv, +protectedvoidrollbackState(MasterProcedureEnvenv, org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.MoveRegionStatestate) throws https://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true; title="class or interface in java.io">IOException Description copied from class:StateMachineProcedure @@ -460,7 +470,7 @@ extends abort -publicbooleanabort(MasterProcedureEnvenv) +publicbooleanabort(MasterProcedureEnvenv) Description copied from class:Procedure The abort() call is asynchronous and each procedure must decide how to deal with it, if they want to be abortable. The simplest implementation @@ -483,7 +493,7 @@ extends toStringClassDetails -publicvoidtoStringClassDetails(https://docs.oracle.com/javase/8/docs/api/java/lang/StringBuilder.html?is-external=true; title="class or interface in java.lang">StringBuildersb) +publicvoidtoStringClassDetails(https://docs.oracle.com/javase/8/docs/api/java/lang/StringBuilder.html?is-external=true; title="class or interface in java.lang">StringBuildersb) Description copied from class:Procedure Extend the toString() information with the procedure details e.g. className and parameters @@ -501,7 +511,7 @@ extends getInitialState -protectedorg.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.MoveRegionStategetInitialState() +protectedorg.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.MoveRegionStategetInitialState() Description copied from class:StateMachineProcedure Return the initial state object that will be used for the first call to executeFromState(). @@ -518,7 +528,7 @@ extends getStateId -protectedintgetStateId(org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.MoveRegionStatestate)
[29/51] [partial] hbase-site git commit: Published site at 31da4d0bce69b3a47066a5df675756087ce4dc60.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/a754d895/devapidocs/org/apache/hadoop/hbase/master/assignment/AssignmentManager.RegionInTransitionStat.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/master/assignment/AssignmentManager.RegionInTransitionStat.html b/devapidocs/org/apache/hadoop/hbase/master/assignment/AssignmentManager.RegionInTransitionStat.html index 61b92e6..a6a4db7 100644 --- a/devapidocs/org/apache/hadoop/hbase/master/assignment/AssignmentManager.RegionInTransitionStat.html +++ b/devapidocs/org/apache/hadoop/hbase/master/assignment/AssignmentManager.RegionInTransitionStat.html @@ -113,7 +113,7 @@ var activeTableTab = "activeTableTab"; -public static class AssignmentManager.RegionInTransitionStat +public static class AssignmentManager.RegionInTransitionStat extends https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true; title="class or interface in java.lang">Object @@ -266,7 +266,7 @@ extends https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html ritThreshold -private finalint ritThreshold +private finalint ritThreshold @@ -275,7 +275,7 @@ extends https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html ritsOverThreshold -privatehttps://docs.oracle.com/javase/8/docs/api/java/util/HashMap.html?is-external=true; title="class or interface in java.util">HashMaphttps://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String,RegionState ritsOverThreshold +privatehttps://docs.oracle.com/javase/8/docs/api/java/util/HashMap.html?is-external=true; title="class or interface in java.util">HashMaphttps://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String,RegionState ritsOverThreshold @@ -284,7 +284,7 @@ extends https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html statTimestamp -privatelong statTimestamp +privatelong statTimestamp @@ -293,7 +293,7 @@ extends https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html oldestRITTime -privatelong oldestRITTime +privatelong oldestRITTime @@ -302,7 +302,7 @@ extends https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html totalRITsTwiceThreshold -privateint totalRITsTwiceThreshold +privateint totalRITsTwiceThreshold @@ -311,7 +311,7 @@ extends https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html totalRITs -privateint totalRITs +privateint totalRITs @@ -328,7 +328,7 @@ extends https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html RegionInTransitionStat -publicRegionInTransitionStat(org.apache.hadoop.conf.Configurationconf) +publicRegionInTransitionStat(org.apache.hadoop.conf.Configurationconf) @@ -345,7 +345,7 @@ extends https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html getRITThreshold -publicintgetRITThreshold() +publicintgetRITThreshold() @@ -354,7 +354,7 @@ extends https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html getTimestamp -publiclonggetTimestamp() +publiclonggetTimestamp() @@ -363,7 +363,7 @@ extends https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html getTotalRITs -publicintgetTotalRITs() +publicintgetTotalRITs() @@ -372,7 +372,7 @@ extends https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html getOldestRITTime -publiclonggetOldestRITTime() +publiclonggetOldestRITTime() @@ -381,7 +381,7 @@ extends https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html getTotalRITsOverThreshold -publicintgetTotalRITsOverThreshold() +publicintgetTotalRITsOverThreshold() @@ -390,7 +390,7 @@ extends https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html hasRegionsTwiceOverThreshold -publicbooleanhasRegionsTwiceOverThreshold() +publicbooleanhasRegionsTwiceOverThreshold() @@ -399,7 +399,7 @@ extends https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html hasRegionsOverThreshold -publicbooleanhasRegionsOverThreshold() +publicbooleanhasRegionsOverThreshold() @@ -408,7 +408,7 @@ extends https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html getRegionOverThreshold -publichttps://docs.oracle.com/javase/8/docs/api/java/util/Collection.html?is-external=true; title="class or interface in java.util">CollectionRegionStategetRegionOverThreshold() +publichttps://docs.oracle.com/javase/8/docs/api/java/util/Collection.html?is-external=true; title="class or interface in java.util">CollectionRegionStategetRegionOverThreshold() @@ -417,7 +417,7 @@ extends https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html isRegionOverThreshold -publicbooleanisRegionOverThreshold(RegionInforegionInfo) +publicbooleanisRegionOverThreshold(RegionInforegionInfo) @@ -426,7 +426,7 @@ extends
[30/51] [partial] hbase-site git commit: Published site at 31da4d0bce69b3a47066a5df675756087ce4dc60.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/a754d895/devapidocs/org/apache/hadoop/hbase/master/MasterServices.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/master/MasterServices.html b/devapidocs/org/apache/hadoop/hbase/master/MasterServices.html index 091cc10..e5b6270 100644 --- a/devapidocs/org/apache/hadoop/hbase/master/MasterServices.html +++ b/devapidocs/org/apache/hadoop/hbase/master/MasterServices.html @@ -18,7 +18,7 @@ catch(err) { } //--> -var methods = {"i0":6,"i1":6,"i2":6,"i3":6,"i4":6,"i5":6,"i6":6,"i7":6,"i8":6,"i9":6,"i10":6,"i11":6,"i12":6,"i13":6,"i14":6,"i15":6,"i16":6,"i17":6,"i18":6,"i19":6,"i20":6,"i21":6,"i22":6,"i23":6,"i24":6,"i25":6,"i26":6,"i27":6,"i28":6,"i29":6,"i30":6,"i31":6,"i32":6,"i33":6,"i34":6,"i35":6,"i36":6,"i37":6,"i38":6,"i39":6,"i40":6,"i41":6,"i42":6,"i43":6,"i44":6,"i45":6,"i46":6,"i47":6,"i48":6,"i49":6,"i50":6,"i51":6,"i52":6,"i53":6,"i54":6,"i55":6,"i56":6,"i57":6}; +var methods = {"i0":6,"i1":6,"i2":6,"i3":6,"i4":6,"i5":6,"i6":6,"i7":6,"i8":6,"i9":6,"i10":6,"i11":6,"i12":6,"i13":6,"i14":6,"i15":6,"i16":6,"i17":6,"i18":6,"i19":6,"i20":6,"i21":6,"i22":6,"i23":6,"i24":6,"i25":6,"i26":6,"i27":6,"i28":6,"i29":6,"i30":6,"i31":6,"i32":6,"i33":6,"i34":6,"i35":6,"i36":6,"i37":6,"i38":6,"i39":6,"i40":6,"i41":6,"i42":6,"i43":6,"i44":6,"i45":6,"i46":6,"i47":6,"i48":6,"i49":6,"i50":6,"i51":6,"i52":6,"i53":6,"i54":6,"i55":6,"i56":6,"i57":6,"i58":6}; var tabs = {65535:["t0","All Methods"],2:["t2","Instance Methods"],4:["t3","Abstract Methods"]}; var altColor = "altColor"; var rowColor = "rowColor"; @@ -356,39 +356,43 @@ extends boolean -isInitialized() +isClusterUp() boolean -isInMaintenanceMode() +isInitialized() boolean -isServerCrashProcessingEnabled() +isInMaintenanceMode() boolean -isSplitOrMergeEnabled(MasterSwitchTypeswitchType) +isServerCrashProcessingEnabled() +boolean +isSplitOrMergeEnabled(MasterSwitchTypeswitchType) + + https://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true; title="class or interface in java.util">ListReplicationPeerDescription listReplicationPeers(https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">Stringregex) Return a list of replication peers. - + https://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true; title="class or interface in java.util">ListTableDescriptor listTableDescriptorsByNamespace(https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">Stringname) Get list of table descriptors by namespace - + https://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true; title="class or interface in java.util">ListTableName listTableNamesByNamespace(https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">Stringname) Get list of table names by namespace - + long mergeRegions(RegionInfo[]regionsToMerge, booleanforcible, @@ -397,7 +401,7 @@ extends Merge regions in a table. - + long modifyColumn(TableNametableName, ColumnFamilyDescriptordescriptor, @@ -406,7 +410,7 @@ extends Modify the column descriptor of an existing column in an existing table - + long modifyTable(TableNametableName, TableDescriptordescriptor, @@ -415,25 +419,25 @@ extends Modify the descriptor of an existing table - + boolean recoverMeta() Recover meta table. - + boolean registerService(com.google.protobuf.Serviceinstance) Registers a new protocol buffer Service subclass as a master coprocessor endpoint. - + long removeReplicationPeer(https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">StringpeerId) Removes a peer and stops the replication - + long splitRegion(RegionInforegionInfo, byte[]splitRow, @@ -442,7 +446,7 @@ extends Split a region. - + long truncateTable(TableNametableName, booleanpreserveSplits, @@ -451,7 +455,7 @@ extends Truncate a table - + long updateReplicationPeerConfig(https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">StringpeerId, ReplicationPeerConfigpeerConfig) @@ -1454,12 +1458,25 @@ extends - + getClientIdAuditPrefix https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">StringgetClientIdAuditPrefix() + + + + + +isClusterUp +booleanisClusterUp() + +Returns: +True if cluster is up; false if cluster is not up (we are shutting down). + + + http://git-wip-us.apache.org/repos/asf/hbase-site/blob/a754d895/devapidocs/org/apache/hadoop/hbase/master/TableNamespaceManager.html
[24/51] [partial] hbase-site git commit: Published site at 31da4d0bce69b3a47066a5df675756087ce4dc60.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/a754d895/devapidocs/org/apache/hadoop/hbase/master/procedure/DeleteNamespaceProcedure.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/master/procedure/DeleteNamespaceProcedure.html b/devapidocs/org/apache/hadoop/hbase/master/procedure/DeleteNamespaceProcedure.html index c29e663..0ab7f22 100644 --- a/devapidocs/org/apache/hadoop/hbase/master/procedure/DeleteNamespaceProcedure.html +++ b/devapidocs/org/apache/hadoop/hbase/master/procedure/DeleteNamespaceProcedure.html @@ -528,7 +528,7 @@ extends rollbackState -protectedvoidrollbackState(MasterProcedureEnvenv, +protectedvoidrollbackState(MasterProcedureEnvenv, org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.DeleteNamespaceStatestate) throws https://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true; title="class or interface in java.io">IOException Description copied from class:StateMachineProcedure @@ -548,7 +548,7 @@ extends isRollbackSupported -protectedbooleanisRollbackSupported(org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.DeleteNamespaceStatestate) +protectedbooleanisRollbackSupported(org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.DeleteNamespaceStatestate) Description copied from class:StateMachineProcedure Used by the default implementation of abort() to know if the current state can be aborted and rollback can be triggered. @@ -564,7 +564,7 @@ extends getState -protectedorg.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.DeleteNamespaceStategetState(intstateId) +protectedorg.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.DeleteNamespaceStategetState(intstateId) Description copied from class:StateMachineProcedure Convert an ordinal (or state id) to an Enum (or more descriptive) state object. @@ -583,7 +583,7 @@ extends getStateId -protectedintgetStateId(org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.DeleteNamespaceStatestate) +protectedintgetStateId(org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.DeleteNamespaceStatestate) Description copied from class:StateMachineProcedure Convert the Enum (or more descriptive) state object to an ordinal (or state id). @@ -602,7 +602,7 @@ extends getInitialState -protectedorg.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.DeleteNamespaceStategetInitialState() +protectedorg.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.DeleteNamespaceStategetInitialState() Description copied from class:StateMachineProcedure Return the initial state object that will be used for the first call to executeFromState(). @@ -619,7 +619,7 @@ extends serializeStateData -protectedvoidserializeStateData(ProcedureStateSerializerserializer) +protectedvoidserializeStateData(ProcedureStateSerializerserializer) throws https://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true; title="class or interface in java.io">IOException Description copied from class:Procedure The user-level code of the procedure may have some state to @@ -641,7 +641,7 @@ extends deserializeStateData -protectedvoiddeserializeStateData(ProcedureStateSerializerserializer) +protectedvoiddeserializeStateData(ProcedureStateSerializerserializer) throws https://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true; title="class or interface in java.io">IOException Description copied from class:Procedure Called on store load to allow the user to decode the previously serialized @@ -662,7 +662,7 @@ extends getTableOperationType -publicTableProcedureInterface.TableOperationTypegetTableOperationType() +publicTableProcedureInterface.TableOperationTypegetTableOperationType() Description copied from interface:TableProcedureInterface Given an operation type we can take decisions about what to do with pending operations. e.g. if we get a delete and we have some table operation pending (e.g. add column) @@ -683,7 +683,7 @@ extends getNamespaceName -protectedhttps://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">StringgetNamespaceName() +protectedhttps://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">StringgetNamespaceName() Specified by: getNamespaceNamein classAbstractStateMachineNamespaceProcedureorg.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.DeleteNamespaceState @@ -696,7 +696,7 @@ extends prepareDelete -privatebooleanprepareDelete(MasterProcedureEnvenv) +privatebooleanprepareDelete(MasterProcedureEnvenv)
[04/51] [partial] hbase-site git commit: Published site at 31da4d0bce69b3a47066a5df675756087ce4dc60.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/a754d895/devapidocs/org/apache/hadoop/hbase/regionserver/RegionServerCoprocessorHost.RegionServerEnvironment.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/regionserver/RegionServerCoprocessorHost.RegionServerEnvironment.html b/devapidocs/org/apache/hadoop/hbase/regionserver/RegionServerCoprocessorHost.RegionServerEnvironment.html index 3a60d1e..f2ada44 100644 --- a/devapidocs/org/apache/hadoop/hbase/regionserver/RegionServerCoprocessorHost.RegionServerEnvironment.html +++ b/devapidocs/org/apache/hadoop/hbase/regionserver/RegionServerCoprocessorHost.RegionServerEnvironment.html @@ -126,7 +126,7 @@ var activeTableTab = "activeTableTab"; -private static class RegionServerCoprocessorHost.RegionServerEnvironment +private static class RegionServerCoprocessorHost.RegionServerEnvironment extends BaseEnvironmentRegionServerCoprocessor implements RegionServerCoprocessorEnvironment Coprocessor environment extension providing access to region server @@ -274,7 +274,7 @@ implements metricRegistry -private finalMetricRegistry metricRegistry +private finalMetricRegistry metricRegistry @@ -283,7 +283,7 @@ implements services -private finalRegionServerServices services +private finalRegionServerServices services @@ -300,7 +300,7 @@ implements RegionServerEnvironment -publicRegionServerEnvironment(RegionServerCoprocessorimpl, +publicRegionServerEnvironment(RegionServerCoprocessorimpl, intpriority, intseq, org.apache.hadoop.conf.Configurationconf, @@ -321,7 +321,7 @@ implements getOnlineRegions -publicOnlineRegionsgetOnlineRegions() +publicOnlineRegionsgetOnlineRegions() Specified by: getOnlineRegionsin interfaceRegionServerCoprocessorEnvironment @@ -336,7 +336,7 @@ implements getServerName -publicServerNamegetServerName() +publicServerNamegetServerName() Specified by: getServerNamein interfaceRegionServerCoprocessorEnvironment @@ -351,7 +351,7 @@ implements getConnection -publicConnectiongetConnection() +publicConnectiongetConnection() Description copied from interface:RegionServerCoprocessorEnvironment Returns the hosts' Connection to the Cluster. Do not close! This is a shared connection with the hosting server. Throws https://docs.oracle.com/javase/8/docs/api/java/lang/UnsupportedOperationException.html?is-external=true; title="class or interface in java.lang">UnsupportedOperationException if you try to close @@ -390,7 +390,7 @@ implements createConnection -publicConnectioncreateConnection(org.apache.hadoop.conf.Configurationconf) +publicConnectioncreateConnection(org.apache.hadoop.conf.Configurationconf) throws https://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true; title="class or interface in java.io">IOException Description copied from interface:RegionServerCoprocessorEnvironment Creates a cluster connection using the passed Configuration. @@ -426,7 +426,7 @@ implements getMetricRegistryForRegionServer -publicMetricRegistrygetMetricRegistryForRegionServer() +publicMetricRegistrygetMetricRegistryForRegionServer() Description copied from interface:RegionServerCoprocessorEnvironment Returns a MetricRegistry that can be used to track metrics at the region server level. @@ -446,7 +446,7 @@ implements shutdown -publicvoidshutdown() +publicvoidshutdown() Description copied from class:BaseEnvironment Clean up the environment http://git-wip-us.apache.org/repos/asf/hbase-site/blob/a754d895/devapidocs/org/apache/hadoop/hbase/regionserver/RegionServerCoprocessorHost.RegionServerEnvironmentForCoreCoprocessors.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/regionserver/RegionServerCoprocessorHost.RegionServerEnvironmentForCoreCoprocessors.html b/devapidocs/org/apache/hadoop/hbase/regionserver/RegionServerCoprocessorHost.RegionServerEnvironmentForCoreCoprocessors.html index a070751..5d82f45 100644 --- a/devapidocs/org/apache/hadoop/hbase/regionserver/RegionServerCoprocessorHost.RegionServerEnvironmentForCoreCoprocessors.html +++ b/devapidocs/org/apache/hadoop/hbase/regionserver/RegionServerCoprocessorHost.RegionServerEnvironmentForCoreCoprocessors.html @@ -127,7 +127,7 @@ var activeTableTab = "activeTableTab"; -private static class RegionServerCoprocessorHost.RegionServerEnvironmentForCoreCoprocessors +private static class RegionServerCoprocessorHost.RegionServerEnvironmentForCoreCoprocessors extends RegionServerCoprocessorHost.RegionServerEnvironment implements HasRegionServerServices Special version of RegionServerEnvironment that exposes RegionServerServices for Core @@ -250,7 +250,7 @@ implements regionServerServices -finalRegionServerServices
[18/51] [partial] hbase-site git commit: Published site at 31da4d0bce69b3a47066a5df675756087ce4dc60.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/a754d895/devapidocs/org/apache/hadoop/hbase/procedure/flush/MasterFlushTableProcedureManager.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/procedure/flush/MasterFlushTableProcedureManager.html b/devapidocs/org/apache/hadoop/hbase/procedure/flush/MasterFlushTableProcedureManager.html index 202ef3a..e8092b6 100644 --- a/devapidocs/org/apache/hadoop/hbase/procedure/flush/MasterFlushTableProcedureManager.html +++ b/devapidocs/org/apache/hadoop/hbase/procedure/flush/MasterFlushTableProcedureManager.html @@ -18,7 +18,7 @@ catch(err) { } //--> -var methods = {"i0":10,"i1":10,"i2":10,"i3":10,"i4":10,"i5":10}; +var methods = {"i0":10,"i1":10,"i2":10,"i3":10,"i4":10,"i5":10,"i6":10}; var tabs = {65535:["t0","All Methods"],2:["t2","Instance Methods"],8:["t4","Concrete Methods"]}; var altColor = "altColor"; var rowColor = "rowColor"; @@ -124,7 +124,7 @@ var activeTableTab = "activeTableTab"; @InterfaceAudience.LimitedPrivate(value="Configuration") -public class MasterFlushTableProcedureManager +public class MasterFlushTableProcedureManager extends MasterProcedureManager @@ -226,34 +226,42 @@ extends void +checkPermissions(org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.ProcedureDescriptiondesc, +AccessCheckeraccessChecker, +Useruser) +Check for required permissions before executing the procedure. + + + +void execProcedure(org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.ProcedureDescriptiondesc) Execute a distributed procedure on cluster - + https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String getProcedureSignature() Return the unique signature of the procedure. - + void initialize(MasterServicesmaster, MetricsMastermetricsMaster) Initialize a globally barriered procedure for master. - + boolean isProcedureDone(org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.ProcedureDescriptiondesc) Check if the procedure is finished successfully - + boolean isStopped() - + void stop(https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">Stringwhy) Stop this service. @@ -301,7 +309,7 @@ extends FLUSH_TABLE_PROCEDURE_SIGNATURE -public static finalhttps://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String FLUSH_TABLE_PROCEDURE_SIGNATURE +public static finalhttps://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String FLUSH_TABLE_PROCEDURE_SIGNATURE See Also: Constant Field Values @@ -314,7 +322,7 @@ extends FLUSH_TIMEOUT_MILLIS_KEY -private static finalhttps://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String FLUSH_TIMEOUT_MILLIS_KEY +private static finalhttps://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String FLUSH_TIMEOUT_MILLIS_KEY See Also: Constant Field Values @@ -327,7 +335,7 @@ extends FLUSH_TIMEOUT_MILLIS_DEFAULT -private static finalint FLUSH_TIMEOUT_MILLIS_DEFAULT +private static finalint FLUSH_TIMEOUT_MILLIS_DEFAULT See Also: Constant Field Values @@ -340,7 +348,7 @@ extends FLUSH_WAKE_MILLIS_KEY -private static finalhttps://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String FLUSH_WAKE_MILLIS_KEY +private static finalhttps://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String FLUSH_WAKE_MILLIS_KEY See Also: Constant Field Values @@ -353,7 +361,7 @@ extends FLUSH_WAKE_MILLIS_DEFAULT -private static finalint FLUSH_WAKE_MILLIS_DEFAULT +private static finalint FLUSH_WAKE_MILLIS_DEFAULT See Also: Constant Field Values @@ -366,7 +374,7 @@ extends FLUSH_PROC_POOL_THREADS_KEY -private static finalhttps://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String FLUSH_PROC_POOL_THREADS_KEY +private static finalhttps://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String FLUSH_PROC_POOL_THREADS_KEY See Also: Constant Field Values @@ -379,7 +387,7 @@ extends FLUSH_PROC_POOL_THREADS_DEFAULT -private static finalint FLUSH_PROC_POOL_THREADS_DEFAULT +private static finalint FLUSH_PROC_POOL_THREADS_DEFAULT See Also: Constant Field Values @@ -392,7 +400,7 @@ extends LOG -private static finalorg.slf4j.Logger LOG +private static finalorg.slf4j.Logger LOG @@ -401,7 +409,7 @@ extends master
[15/51] [partial] hbase-site git commit: Published site at 31da4d0bce69b3a47066a5df675756087ce4dc60.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/a754d895/devapidocs/org/apache/hadoop/hbase/regionserver/HRegion.RegionScannerImpl.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/regionserver/HRegion.RegionScannerImpl.html b/devapidocs/org/apache/hadoop/hbase/regionserver/HRegion.RegionScannerImpl.html index d363e3a..5066d3e 100644 --- a/devapidocs/org/apache/hadoop/hbase/regionserver/HRegion.RegionScannerImpl.html +++ b/devapidocs/org/apache/hadoop/hbase/regionserver/HRegion.RegionScannerImpl.html @@ -121,7 +121,7 @@ var activeTableTab = "activeTableTab"; -class HRegion.RegionScannerImpl +class HRegion.RegionScannerImpl extends https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true; title="class or interface in java.lang">Object implements RegionScanner, Shipper, RpcCallback RegionScannerImpl is used to combine scanners from multiple Stores (aka column families). @@ -425,7 +425,7 @@ implements storeHeap -KeyValueHeap storeHeap +KeyValueHeap storeHeap @@ -434,7 +434,7 @@ implements joinedHeap -KeyValueHeap joinedHeap +KeyValueHeap joinedHeap Heap of key-values that are not essential for the provided filters and are thus read on demand, if on-demand column family loading is enabled. @@ -445,7 +445,7 @@ implements joinedContinuationRow -protectedCell joinedContinuationRow +protectedCell joinedContinuationRow If the joined heap data gathering is interrupted due to scan limits, this will contain the row for which we are populating the values. @@ -456,7 +456,7 @@ implements filterClosed -privateboolean filterClosed +privateboolean filterClosed @@ -465,7 +465,7 @@ implements stopRow -protected finalbyte[] stopRow +protected finalbyte[] stopRow @@ -474,7 +474,7 @@ implements includeStopRow -protected finalboolean includeStopRow +protected finalboolean includeStopRow @@ -483,7 +483,7 @@ implements region -protected finalHRegion region +protected finalHRegion region @@ -492,7 +492,7 @@ implements comparator -protected finalCellComparator comparator +protected finalCellComparator comparator @@ -501,7 +501,7 @@ implements readPt -private finallong readPt +private finallong readPt @@ -510,7 +510,7 @@ implements maxResultSize -private finallong maxResultSize +private finallong maxResultSize @@ -519,7 +519,7 @@ implements defaultScannerContext -private finalScannerContext defaultScannerContext +private finalScannerContext defaultScannerContext @@ -528,7 +528,7 @@ implements filter -private finalFilterWrapper filter +private finalFilterWrapper filter @@ -545,7 +545,7 @@ implements RegionScannerImpl -RegionScannerImpl(Scanscan, +RegionScannerImpl(Scanscan, https://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true; title="class or interface in java.util">ListKeyValueScanneradditionalScanners, HRegionregion) throws https://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true; title="class or interface in java.io">IOException @@ -561,7 +561,7 @@ implements RegionScannerImpl -RegionScannerImpl(Scanscan, +RegionScannerImpl(Scanscan, https://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true; title="class or interface in java.util">ListKeyValueScanneradditionalScanners, HRegionregion, longnonceGroup, @@ -587,7 +587,7 @@ implements getRegionInfo -publicRegionInfogetRegionInfo() +publicRegionInfogetRegionInfo() Specified by: getRegionInfoin interfaceRegionScanner @@ -602,7 +602,7 @@ implements initializeScanners -protectedvoidinitializeScanners(Scanscan, +protectedvoidinitializeScanners(Scanscan, https://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true; title="class or interface in java.util">ListKeyValueScanneradditionalScanners) throws https://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true; title="class or interface in java.io">IOException @@ -617,7 +617,7 @@ implements initializeKVHeap -protectedvoidinitializeKVHeap(https://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true; title="class or interface in java.util">ListKeyValueScannerscanners, +protectedvoidinitializeKVHeap(https://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true; title="class or interface in java.util">ListKeyValueScannerscanners, https://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true; title="class or interface in java.util">ListKeyValueScannerjoinedScanners, HRegionregion) throws
[17/51] [partial] hbase-site git commit: Published site at 31da4d0bce69b3a47066a5df675756087ce4dc60.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/a754d895/devapidocs/org/apache/hadoop/hbase/regionserver/HRegion.BatchOperation.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/regionserver/HRegion.BatchOperation.html b/devapidocs/org/apache/hadoop/hbase/regionserver/HRegion.BatchOperation.html index 3da1e22..74d6ab8 100644 --- a/devapidocs/org/apache/hadoop/hbase/regionserver/HRegion.BatchOperation.html +++ b/devapidocs/org/apache/hadoop/hbase/regionserver/HRegion.BatchOperation.html @@ -18,7 +18,7 @@ catch(err) { } //--> -var methods = {"i0":10,"i1":10,"i2":10,"i3":6,"i4":10,"i5":10,"i6":6,"i7":6,"i8":10,"i9":10,"i10":10,"i11":10,"i12":6,"i13":6,"i14":6,"i15":6,"i16":6,"i17":10,"i18":10,"i19":6,"i20":10,"i21":10,"i22":6,"i23":10,"i24":6,"i25":10,"i26":10,"i27":6}; +var methods = {"i0":10,"i1":10,"i2":10,"i3":6,"i4":10,"i5":10,"i6":6,"i7":6,"i8":10,"i9":10,"i10":10,"i11":10,"i12":10,"i13":6,"i14":6,"i15":6,"i16":6,"i17":6,"i18":10,"i19":10,"i20":6,"i21":10,"i22":10,"i23":6,"i24":10,"i25":6,"i26":10,"i27":10,"i28":6}; var tabs = {65535:["t0","All Methods"],2:["t2","Instance Methods"],4:["t3","Abstract Methods"],8:["t4","Concrete Methods"]}; var altColor = "altColor"; var rowColor = "rowColor"; @@ -117,7 +117,7 @@ var activeTableTab = "activeTableTab"; -private abstract static class HRegion.BatchOperationT +private abstract static class HRegion.BatchOperationT extends https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true; title="class or interface in java.lang">Object Class that tracks the progress of a batch operations, accumulating status codes and tracking the index at which processing is proceeding. These batch operations may get split into @@ -292,61 +292,65 @@ extends https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html intreadyToWriteCount) +private void +doFinishHotnessProtector(MiniBatchOperationInProgressMutationminiBatchOp) + + void doPostOpCleanupForMiniBatch(MiniBatchOperationInProgressMutationminiBatchOp, WALEditwalEdit, booleansuccess) - + https://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true; title="class or interface in java.util">Listhttps://docs.oracle.com/javase/8/docs/api/java/util/UUID.html?is-external=true; title="class or interface in java.util">UUID getClusterIds() - + abstract Mutation getMutation(intindex) - + abstract Mutation[] getMutationsForCoprocs() This method is potentially expensive and useful mostly for non-replay CP path. - + abstract long getNonce(intindex) - + abstract long getNonceGroup(intindex) - + abstract long getOrigLogSeqNum() - + (package private) boolean isAtomic() - + boolean isDone() - + abstract boolean isInReplay() - + boolean isOperationPending(intindex) - + MiniBatchOperationInProgressMutation lockRowsAndBuildMiniBatch(https://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true; title="class or interface in java.util">ListRegion.RowLockacquiredRowLocks) Creates Mini-batch of all operations [nextIndexToProcess, lastIndexExclusive) for which a row lock can be acquired. - + abstract void prepareMiniBatchOperations(MiniBatchOperationInProgressMutationminiBatchOp, longtimestamp, @@ -355,15 +359,15 @@ extends https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html count, tags and timestamp for all cells of all operations in a mini-batch. - + int size() - + abstract void startRegionOperation() - + void visitBatchOperations(booleanpendingOnly, intlastIndexExclusive, @@ -371,12 +375,12 @@ extends https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html Helper method for visiting pending/ all batch operations - + protected void writeMiniBatchOperationsToMemStore(MiniBatchOperationInProgressMutationminiBatchOp, longwriteNumber) - + abstract MultiVersionConcurrencyControl.WriteEntry writeMiniBatchOperationsToMemStore(MiniBatchOperationInProgressMutationminiBatchOp, MultiVersionConcurrencyControl.WriteEntrywriteEntry) @@ -411,7 +415,7 @@ extends https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html operations -protected finalT[] operations +protected finalT[] operations @@ -420,7 +424,7 @@ extends https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html retCodeDetails -protected finalOperationStatus[] retCodeDetails +protected finalOperationStatus[] retCodeDetails @@ -429,7 +433,7 @@ extends https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html walEditsFromCoprocessors -protected finalWALEdit[] walEditsFromCoprocessors +protected finalWALEdit[] walEditsFromCoprocessors @@ -438,7 +442,7 @@ extends
[14/51] [partial] hbase-site git commit: Published site at 31da4d0bce69b3a47066a5df675756087ce4dc60.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/a754d895/devapidocs/org/apache/hadoop/hbase/regionserver/HRegion.WriteState.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/regionserver/HRegion.WriteState.html b/devapidocs/org/apache/hadoop/hbase/regionserver/HRegion.WriteState.html index 90150e6..36ebb94 100644 --- a/devapidocs/org/apache/hadoop/hbase/regionserver/HRegion.WriteState.html +++ b/devapidocs/org/apache/hadoop/hbase/regionserver/HRegion.WriteState.html @@ -113,7 +113,7 @@ var activeTableTab = "activeTableTab"; -static class HRegion.WriteState +static class HRegion.WriteState extends https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true; title="class or interface in java.lang">Object @@ -239,7 +239,7 @@ extends https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html flushing -volatileboolean flushing +volatileboolean flushing @@ -248,7 +248,7 @@ extends https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html flushRequested -volatileboolean flushRequested +volatileboolean flushRequested @@ -257,7 +257,7 @@ extends https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html compacting -https://docs.oracle.com/javase/8/docs/api/java/util/concurrent/atomic/AtomicInteger.html?is-external=true; title="class or interface in java.util.concurrent.atomic">AtomicInteger compacting +https://docs.oracle.com/javase/8/docs/api/java/util/concurrent/atomic/AtomicInteger.html?is-external=true; title="class or interface in java.util.concurrent.atomic">AtomicInteger compacting @@ -266,7 +266,7 @@ extends https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html writesEnabled -volatileboolean writesEnabled +volatileboolean writesEnabled @@ -275,7 +275,7 @@ extends https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html readOnly -volatileboolean readOnly +volatileboolean readOnly @@ -284,7 +284,7 @@ extends https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html readsEnabled -volatileboolean readsEnabled +volatileboolean readsEnabled @@ -293,7 +293,7 @@ extends https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html HEAP_SIZE -static finallong HEAP_SIZE +static finallong HEAP_SIZE @@ -310,7 +310,7 @@ extends https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html WriteState -WriteState() +WriteState() @@ -327,7 +327,7 @@ extends https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html setReadOnly -voidsetReadOnly(booleanonOff) +voidsetReadOnly(booleanonOff) Set flags that make this region read-only. Parameters: @@ -341,7 +341,7 @@ extends https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html isReadOnly -booleanisReadOnly() +booleanisReadOnly() @@ -350,7 +350,7 @@ extends https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html isFlushRequested -booleanisFlushRequested() +booleanisFlushRequested() @@ -359,7 +359,7 @@ extends https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html setReadsEnabled -voidsetReadsEnabled(booleanreadsEnabled) +voidsetReadsEnabled(booleanreadsEnabled)
[19/51] [partial] hbase-site git commit: Published site at 31da4d0bce69b3a47066a5df675756087ce4dc60.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/a754d895/devapidocs/org/apache/hadoop/hbase/nio/MultiByteBuff.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/nio/MultiByteBuff.html b/devapidocs/org/apache/hadoop/hbase/nio/MultiByteBuff.html index e2c6511..b425534 100644 --- a/devapidocs/org/apache/hadoop/hbase/nio/MultiByteBuff.html +++ b/devapidocs/org/apache/hadoop/hbase/nio/MultiByteBuff.html @@ -912,7 +912,7 @@ extends getShort -privateshortgetShort(intindex, +privateshortgetShort(intindex, intitemIndex) @@ -922,7 +922,7 @@ extends getLong -privatelonggetLong(intindex, +privatelonggetLong(intindex, intitemIndex) @@ -932,7 +932,7 @@ extends getLong -publiclonggetLong(intindex) +publiclonggetLong(intindex) Fetches the long at the given index. Does not change position of the underlying ByteBuffers Specified by: @@ -950,7 +950,7 @@ extends getLongAfterPosition -publiclonggetLongAfterPosition(intoffset) +publiclonggetLongAfterPosition(intoffset) Description copied from class:ByteBuff Fetches the long value at the given offset from current position. Does not change position of the underlying ByteBuffers. @@ -968,7 +968,7 @@ extends position -publicintposition() +publicintposition() Specified by: positionin classByteBuff @@ -983,7 +983,7 @@ extends position -publicMultiByteBuffposition(intposition) +publicMultiByteBuffposition(intposition) Sets this MBB's position to the given value. Specified by: @@ -1001,7 +1001,7 @@ extends rewind -publicMultiByteBuffrewind() +publicMultiByteBuffrewind() Rewinds this MBB and the position is set to 0 Specified by: @@ -1017,7 +1017,7 @@ extends mark -publicMultiByteBuffmark() +publicMultiByteBuffmark() Marks the current position of the MBB Specified by: @@ -1033,7 +1033,7 @@ extends reset -publicMultiByteBuffreset() +publicMultiByteBuffreset() Similar to https://docs.oracle.com/javase/8/docs/api/java/nio/ByteBuffer.html?is-external=true; title="class or interface in java.nio">ByteBuffer.reset(), ensures that this MBB is reset back to last marked position. @@ -1050,7 +1050,7 @@ extends remaining -publicintremaining() +publicintremaining() Returns the number of elements between the current position and the limit. @@ -1067,7 +1067,7 @@ extends hasRemaining -public finalbooleanhasRemaining() +public finalbooleanhasRemaining() Returns true if there are elements between the current position and the limt Specified by: @@ -1083,7 +1083,7 @@ extends get -publicbyteget() +publicbyteget() A relative method that returns byte at the current position. Increments the current position by the size of a byte. @@ -1100,7 +1100,7 @@ extends getShort -publicshortgetShort() +publicshortgetShort() Returns the short value at the current position. Also advances the position by the size of short @@ -1117,7 +1117,7 @@ extends getInt -publicintgetInt() +publicintgetInt() Returns the int value at the current position. Also advances the position by the size of int Specified by: @@ -1133,7 +1133,7 @@ extends getLong -publiclonggetLong() +publiclonggetLong() Returns the long value at the current position. Also advances the position by the size of long Specified by: @@ -1149,7 +1149,7 @@ extends get -publicvoidget(byte[]dst) +publicvoidget(byte[]dst) Copies the content from this MBB's current position to the byte array and fills it. Also advances the position of the MBB by the length of the byte[]. @@ -1166,7 +1166,7 @@ extends get -publicvoidget(byte[]dst, +publicvoidget(byte[]dst, intoffset, intlength) Copies the specified number of bytes from this MBB's current position to the byte[]'s offset. @@ -1187,7 +1187,7 @@ extends get -publicvoidget(intsourceOffset, +publicvoidget(intsourceOffset, byte[]dst, intoffset, intlength) @@ -1211,7 +1211,7 @@ extends limit -publicMultiByteBufflimit(intlimit) +publicMultiByteBufflimit(intlimit) Marks the limit of this MBB. Specified by: @@ -1229,7 +1229,7 @@ extends limit -publicintlimit() +publicintlimit() Returns the limit of this MBB Specified by: @@ -1245,7 +1245,7 @@ extends slice -publicMultiByteBuffslice() +publicMultiByteBuffslice() Returns an MBB which is a sliced version of this MBB. The position, limit and mark of the new MBB will be independent than that of the original MBB. The content of the new MBB will start at this MBB's current position @@ -1263,7 +1263,7 @@ extends duplicate -publicMultiByteBuffduplicate() +publicMultiByteBuffduplicate() Returns an MBB which is a duplicate version of this MBB. The position, limit and mark of the new MBB will be independent than that of the original MBB. The content of the new MBB will start at this MBB's current
[02/51] [partial] hbase-site git commit: Published site at 31da4d0bce69b3a47066a5df675756087ce4dc60.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/a754d895/devapidocs/org/apache/hadoop/hbase/regionserver/wal/WALCoprocessorHost.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/regionserver/wal/WALCoprocessorHost.html b/devapidocs/org/apache/hadoop/hbase/regionserver/wal/WALCoprocessorHost.html index fd3f026..6bae4eb 100644 --- a/devapidocs/org/apache/hadoop/hbase/regionserver/wal/WALCoprocessorHost.html +++ b/devapidocs/org/apache/hadoop/hbase/regionserver/wal/WALCoprocessorHost.html @@ -115,7 +115,7 @@ var activeTableTab = "activeTableTab"; @InterfaceAudience.Private -public class WALCoprocessorHost +public class WALCoprocessorHost extends CoprocessorHostWALCoprocessor,WALCoprocessorEnvironment Implements the coprocessor environment and runtime support for coprocessors loaded within a WAL. @@ -299,7 +299,7 @@ extends LOG -private static finalorg.slf4j.Logger LOG +private static finalorg.slf4j.Logger LOG @@ -308,7 +308,7 @@ extends wal -private finalWAL wal +private finalWAL wal @@ -317,7 +317,7 @@ extends walObserverGetter -privateCoprocessorHost.ObserverGetterWALCoprocessor,WALObserver walObserverGetter +privateCoprocessorHost.ObserverGetterWALCoprocessor,WALObserver walObserverGetter @@ -334,7 +334,7 @@ extends WALCoprocessorHost -publicWALCoprocessorHost(WALlog, +publicWALCoprocessorHost(WALlog, org.apache.hadoop.conf.Configurationconf) Constructor @@ -358,7 +358,7 @@ extends createEnvironment -publicWALCoprocessorHost.WALEnvironmentcreateEnvironment(WALCoprocessorinstance, +publicWALCoprocessorHost.WALEnvironmentcreateEnvironment(WALCoprocessorinstance, intpriority, intseq, org.apache.hadoop.conf.Configurationconf) @@ -376,9 +376,9 @@ extends checkAndGetInstance -publicWALCoprocessorcheckAndGetInstance(https://docs.oracle.com/javase/8/docs/api/java/lang/Class.html?is-external=true; title="class or interface in java.lang">Class?implClass) - throws https://docs.oracle.com/javase/8/docs/api/java/lang/InstantiationException.html?is-external=true; title="class or interface in java.lang">InstantiationException, - https://docs.oracle.com/javase/8/docs/api/java/lang/IllegalAccessException.html?is-external=true; title="class or interface in java.lang">IllegalAccessException +publicWALCoprocessorcheckAndGetInstance(https://docs.oracle.com/javase/8/docs/api/java/lang/Class.html?is-external=true; title="class or interface in java.lang">Class?implClass) + throws https://docs.oracle.com/javase/8/docs/api/java/lang/IllegalAccessException.html?is-external=true; title="class or interface in java.lang">IllegalAccessException, + https://docs.oracle.com/javase/8/docs/api/java/lang/InstantiationException.html?is-external=true; title="class or interface in java.lang">InstantiationException Description copied from class:CoprocessorHost Called when a new Coprocessor class needs to be loaded. Checks if type of the given class is what the corresponding host implementation expects. If it is of correct type, returns an @@ -389,8 +389,8 @@ extends Specified by: checkAndGetInstancein classCoprocessorHostWALCoprocessor,WALCoprocessorEnvironment Throws: -https://docs.oracle.com/javase/8/docs/api/java/lang/InstantiationException.html?is-external=true; title="class or interface in java.lang">InstantiationException https://docs.oracle.com/javase/8/docs/api/java/lang/IllegalAccessException.html?is-external=true; title="class or interface in java.lang">IllegalAccessException +https://docs.oracle.com/javase/8/docs/api/java/lang/InstantiationException.html?is-external=true; title="class or interface in java.lang">InstantiationException @@ -400,7 +400,7 @@ extends preWALWrite -publicvoidpreWALWrite(RegionInfoinfo, +publicvoidpreWALWrite(RegionInfoinfo, WALKeylogKey, WALEditlogEdit) throws https://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true; title="class or interface in java.io">IOException @@ -416,7 +416,7 @@ extends postWALWrite -publicvoidpostWALWrite(RegionInfoinfo, +publicvoidpostWALWrite(RegionInfoinfo, WALKeylogKey, WALEditlogEdit) throws https://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true; title="class or interface in java.io">IOException @@ -432,7 +432,7 @@ extends preWALRoll -publicvoidpreWALRoll(org.apache.hadoop.fs.PatholdPath, +publicvoidpreWALRoll(org.apache.hadoop.fs.PatholdPath,
[38/51] [partial] hbase-site git commit: Published site at 31da4d0bce69b3a47066a5df675756087ce4dc60.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/a754d895/devapidocs/org/apache/hadoop/hbase/client/class-use/Mutation.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/client/class-use/Mutation.html b/devapidocs/org/apache/hadoop/hbase/client/class-use/Mutation.html index 58373f2..3d34f8c 100644 --- a/devapidocs/org/apache/hadoop/hbase/client/class-use/Mutation.html +++ b/devapidocs/org/apache/hadoop/hbase/client/class-use/Mutation.html @@ -1041,18 +1041,22 @@ Input/OutputFormats, a table indexing MapReduce job, and utility methods. MultiVersionConcurrencyControl.WriteEntrywriteEntry) +private void +HRegion.BatchOperation.doFinishHotnessProtector(MiniBatchOperationInProgressMutationminiBatchOp) + + void HRegion.BatchOperation.doPostOpCleanupForMiniBatch(MiniBatchOperationInProgressMutationminiBatchOp, WALEditwalEdit, booleansuccess) - + void HRegion.MutationBatchOperation.doPostOpCleanupForMiniBatch(MiniBatchOperationInProgressMutationminiBatchOp, WALEditwalEdit, booleansuccess) - + private void HRegion.doProcessRowWithTimeout(RowProcessor?,?processor, longnow, @@ -1061,7 +1065,7 @@ Input/OutputFormats, a table indexing MapReduce job, and utility methods. WALEditwalEdit, longtimeout) - + void Region.mutateRowsWithLocks(https://docs.oracle.com/javase/8/docs/api/java/util/Collection.html?is-external=true; title="class or interface in java.util">CollectionMutationmutations, https://docs.oracle.com/javase/8/docs/api/java/util/Collection.html?is-external=true; title="class or interface in java.util">Collectionbyte[]rowsToLock, @@ -1070,7 +1074,7 @@ Input/OutputFormats, a table indexing MapReduce job, and utility methods. Perform atomic mutations within the region. - + void HRegion.mutateRowsWithLocks(https://docs.oracle.com/javase/8/docs/api/java/util/Collection.html?is-external=true; title="class or interface in java.util">CollectionMutationmutations, https://docs.oracle.com/javase/8/docs/api/java/util/Collection.html?is-external=true; title="class or interface in java.util">Collectionbyte[]rowsToLock, @@ -1079,20 +1083,20 @@ Input/OutputFormats, a table indexing MapReduce job, and utility methods. Perform atomic (all or none) mutations within the region. - + void RegionCoprocessorHost.postBatchMutate(MiniBatchOperationInProgressMutationminiBatchOp) - + void RegionCoprocessorHost.postBatchMutateIndispensably(MiniBatchOperationInProgressMutationminiBatchOp, booleansuccess) - + void RegionCoprocessorHost.preBatchMutate(MiniBatchOperationInProgressMutationminiBatchOp) - + abstract void HRegion.BatchOperation.prepareMiniBatchOperations(MiniBatchOperationInProgressMutationminiBatchOp, longtimestamp, @@ -1101,19 +1105,19 @@ Input/OutputFormats, a table indexing MapReduce job, and utility methods. count, tags and timestamp for all cells of all operations in a mini-batch. - + void HRegion.MutationBatchOperation.prepareMiniBatchOperations(MiniBatchOperationInProgressMutationminiBatchOp, longtimestamp, https://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true; title="class or interface in java.util">ListRegion.RowLockacquiredRowLocks) - + void HRegion.ReplayBatchOperation.prepareMiniBatchOperations(MiniBatchOperationInProgressMutationminiBatchOp, longtimestamp, https://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true; title="class or interface in java.util">ListRegion.RowLockacquiredRowLocks) - + void RowProcessor.process(longnow, HRegionregion, @@ -1123,24 +1127,24 @@ Input/OutputFormats, a table indexing MapReduce job, and utility methods. HRegion handles the locks and MVCC and invokes this method properly. - + protected void HRegion.BatchOperation.writeMiniBatchOperationsToMemStore(MiniBatchOperationInProgressMutationminiBatchOp, longwriteNumber) - + abstract MultiVersionConcurrencyControl.WriteEntry HRegion.BatchOperation.writeMiniBatchOperationsToMemStore(MiniBatchOperationInProgressMutationminiBatchOp, MultiVersionConcurrencyControl.WriteEntrywriteEntry) Write mini-batch operations to MemStore - + MultiVersionConcurrencyControl.WriteEntry HRegion.MutationBatchOperation.writeMiniBatchOperationsToMemStore(MiniBatchOperationInProgressMutationminiBatchOp, MultiVersionConcurrencyControl.WriteEntrywriteEntry) - + MultiVersionConcurrencyControl.WriteEntry
[39/51] [partial] hbase-site git commit: Published site at 31da4d0bce69b3a47066a5df675756087ce4dc60.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/a754d895/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 c36dd6e..6b59211 100644 --- a/devapidocs/org/apache/hadoop/hbase/class-use/ServerName.html +++ b/devapidocs/org/apache/hadoop/hbase/class-use/ServerName.html @@ -5491,6 +5491,19 @@ Input/OutputFormats, a table indexing MapReduce job, and utility methods. Uses of ServerName in org.apache.hadoop.hbase.replication +Fields in org.apache.hadoop.hbase.replication declared as ServerName + +Modifier and Type +Field and Description + + + +(package private) ServerName +TableReplicationQueueStorage.WALCell.serverName + + + + Fields in org.apache.hadoop.hbase.replication with type parameters of type ServerName Modifier and Type @@ -5535,10 +5548,14 @@ Input/OutputFormats, a table indexing MapReduce job, and utility methods. ZKReplicationQueueStorage.getListOfReplicators() +https://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true; title="class or interface in java.util">ListServerName +TableReplicationQueueStorage.getListOfReplicators() + + private https://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true; title="class or interface in java.util">ListServerName ZKReplicationQueueStorage.getListOfReplicators0() - + https://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true; title="class or interface in java.util">ListServerName HBaseReplicationEndpoint.getRegionServers() Get a list of all the addresses of all the region servers @@ -5569,6 +5586,12 @@ Input/OutputFormats, a table indexing MapReduce job, and utility methods. https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">StringfileName) +void +TableReplicationQueueStorage.addWAL(ServerNameserverName, + https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">StringqueueId, + https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">StringfileName) + + Pairhttps://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String,https://docs.oracle.com/javase/8/docs/api/java/util/SortedSet.html?is-external=true; title="class or interface in java.util">SortedSethttps://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String ReplicationQueueStorage.claimQueue(ServerNamesourceServerName, https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">StringqueueId, @@ -5576,12 +5599,18 @@ Input/OutputFormats, a table indexing MapReduce job, and utility methods. Change ownership for the queue identified by queueId and belongs to a dead region server. - + Pairhttps://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String,https://docs.oracle.com/javase/8/docs/api/java/util/SortedSet.html?is-external=true; title="class or interface in java.util">SortedSethttps://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String ZKReplicationQueueStorage.claimQueue(ServerNamesourceServerName, https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">StringqueueId, ServerNamedestServerName) + +Pairhttps://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String,https://docs.oracle.com/javase/8/docs/api/java/util/SortedSet.html?is-external=true; title="class or interface in java.util">SortedSethttps://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String +TableReplicationQueueStorage.claimQueue(ServerNamesourceServerName, + https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">StringqueueId, + ServerNamedestServerName) + https://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true; title="class or interface in java.util">Listhttps://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String ReplicationQueueStorage.getAllQueues(ServerNameserverName) @@ -5593,24 +5622,32 @@ Input/OutputFormats, a table indexing MapReduce job, and utility methods. ZKReplicationQueueStorage.getAllQueues(ServerNameserverName)
[42/51] [partial] hbase-site git commit: Published site at 31da4d0bce69b3a47066a5df675756087ce4dc60.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/a754d895/devapidocs/org/apache/hadoop/hbase/MetaTableAccessor.CloseableVisitor.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/MetaTableAccessor.CloseableVisitor.html b/devapidocs/org/apache/hadoop/hbase/MetaTableAccessor.CloseableVisitor.html index d9dd212..a4c566e 100644 --- a/devapidocs/org/apache/hadoop/hbase/MetaTableAccessor.CloseableVisitor.html +++ b/devapidocs/org/apache/hadoop/hbase/MetaTableAccessor.CloseableVisitor.html @@ -103,7 +103,7 @@ -public static interface MetaTableAccessor.CloseableVisitor +public static interface MetaTableAccessor.CloseableVisitor extends MetaTableAccessor.Visitor, https://docs.oracle.com/javase/8/docs/api/java/io/Closeable.html?is-external=true; title="class or interface in java.io">Closeable Implementations 'visit' a catalog table row but with close() at the end. http://git-wip-us.apache.org/repos/asf/hbase-site/blob/a754d895/devapidocs/org/apache/hadoop/hbase/MetaTableAccessor.CollectAllVisitor.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/MetaTableAccessor.CollectAllVisitor.html b/devapidocs/org/apache/hadoop/hbase/MetaTableAccessor.CollectAllVisitor.html index bb96d7d..67a80a2 100644 --- a/devapidocs/org/apache/hadoop/hbase/MetaTableAccessor.CollectAllVisitor.html +++ b/devapidocs/org/apache/hadoop/hbase/MetaTableAccessor.CollectAllVisitor.html @@ -122,7 +122,7 @@ var activeTableTab = "activeTableTab"; -static class MetaTableAccessor.CollectAllVisitor +static class MetaTableAccessor.CollectAllVisitor extends MetaTableAccessor.CollectingVisitorResult Collects all returned. @@ -214,7 +214,7 @@ extends CollectAllVisitor -CollectAllVisitor() +CollectAllVisitor() @@ -231,7 +231,7 @@ extends add -voidadd(Resultr) +voidadd(Resultr) Specified by: addin classMetaTableAccessor.CollectingVisitorResult http://git-wip-us.apache.org/repos/asf/hbase-site/blob/a754d895/devapidocs/org/apache/hadoop/hbase/MetaTableAccessor.CollectingVisitor.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/MetaTableAccessor.CollectingVisitor.html b/devapidocs/org/apache/hadoop/hbase/MetaTableAccessor.CollectingVisitor.html index a97567b..21b24a9 100644 --- a/devapidocs/org/apache/hadoop/hbase/MetaTableAccessor.CollectingVisitor.html +++ b/devapidocs/org/apache/hadoop/hbase/MetaTableAccessor.CollectingVisitor.html @@ -121,7 +121,7 @@ var activeTableTab = "activeTableTab"; -abstract static class MetaTableAccessor.CollectingVisitorT +abstract static class MetaTableAccessor.CollectingVisitorT extends https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true; title="class or interface in java.lang">Object implements MetaTableAccessor.Visitor A MetaTableAccessor.Visitor that collects content out of passed Result. @@ -221,7 +221,7 @@ implements results -finalhttps://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true; title="class or interface in java.util">ListT results +finalhttps://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true; title="class or interface in java.util">ListT results @@ -238,7 +238,7 @@ implements CollectingVisitor -CollectingVisitor() +CollectingVisitor() @@ -255,7 +255,7 @@ implements visit -publicbooleanvisit(Resultr) +publicbooleanvisit(Resultr) throws https://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true; title="class or interface in java.io">IOException Description copied from interface:MetaTableAccessor.Visitor Visit the catalog table row. @@ -278,7 +278,7 @@ implements add -abstractvoidadd(Resultr) +abstractvoidadd(Resultr) @@ -287,7 +287,7 @@ implements getResults -https://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true; title="class or interface in java.util">ListTgetResults() +https://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true; title="class or interface in java.util">ListTgetResults() Returns: Collected results; wait till visits complete to collect all http://git-wip-us.apache.org/repos/asf/hbase-site/blob/a754d895/devapidocs/org/apache/hadoop/hbase/MetaTableAccessor.DefaultVisitorBase.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/MetaTableAccessor.DefaultVisitorBase.html b/devapidocs/org/apache/hadoop/hbase/MetaTableAccessor.DefaultVisitorBase.html index ea56639..a26f0b6 100644 --- a/devapidocs/org/apache/hadoop/hbase/MetaTableAccessor.DefaultVisitorBase.html +++ b/devapidocs/org/apache/hadoop/hbase/MetaTableAccessor.DefaultVisitorBase.html @@ -121,7 +121,7 @@ var activeTableTab = "activeTableTab"; -public abstract static class
[44/51] [partial] hbase-site git commit: Published site at 31da4d0bce69b3a47066a5df675756087ce4dc60.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/a754d895/devapidocs/org/apache/hadoop/hbase/HConstants.OperationStatusCode.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/HConstants.OperationStatusCode.html b/devapidocs/org/apache/hadoop/hbase/HConstants.OperationStatusCode.html index 140d873..48cd7b1 100644 --- a/devapidocs/org/apache/hadoop/hbase/HConstants.OperationStatusCode.html +++ b/devapidocs/org/apache/hadoop/hbase/HConstants.OperationStatusCode.html @@ -156,6 +156,9 @@ extends https://docs.oracle.com/javase/8/docs/api/java/lang/Enum.html?i SANITY_CHECK_FAILURE +STORE_TOO_BUSY + + SUCCESS @@ -242,13 +245,22 @@ the order they are declared. public static finalHConstants.OperationStatusCode BAD_FAMILY + + + + + +STORE_TOO_BUSY +public static finalHConstants.OperationStatusCode STORE_TOO_BUSY + + SANITY_CHECK_FAILURE -public static finalHConstants.OperationStatusCode SANITY_CHECK_FAILURE +public static finalHConstants.OperationStatusCode SANITY_CHECK_FAILURE @@ -257,7 +269,7 @@ the order they are declared. FAILURE -public static finalHConstants.OperationStatusCode FAILURE +public static finalHConstants.OperationStatusCode FAILURE
[36/51] [partial] hbase-site git commit: Published site at 31da4d0bce69b3a47066a5df675756087ce4dc60.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/a754d895/devapidocs/org/apache/hadoop/hbase/mapreduce/TableSnapshotInputFormatImpl.RecordReader.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/mapreduce/TableSnapshotInputFormatImpl.RecordReader.html b/devapidocs/org/apache/hadoop/hbase/mapreduce/TableSnapshotInputFormatImpl.RecordReader.html index 1071429..fbaffa5 100644 --- a/devapidocs/org/apache/hadoop/hbase/mapreduce/TableSnapshotInputFormatImpl.RecordReader.html +++ b/devapidocs/org/apache/hadoop/hbase/mapreduce/TableSnapshotInputFormatImpl.RecordReader.html @@ -113,7 +113,7 @@ var activeTableTab = "activeTableTab"; -public static class TableSnapshotInputFormatImpl.RecordReader +public static class TableSnapshotInputFormatImpl.RecordReader extends https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true; title="class or interface in java.lang">Object Implementation class for RecordReader logic common between mapred and mapreduce. @@ -247,7 +247,7 @@ extends https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html split -privateTableSnapshotInputFormatImpl.InputSplit split +privateTableSnapshotInputFormatImpl.InputSplit split @@ -256,7 +256,7 @@ extends https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html scan -privateScan scan +privateScan scan @@ -265,7 +265,7 @@ extends https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html result -privateResult result +privateResult result @@ -274,7 +274,7 @@ extends https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html row -privateImmutableBytesWritable row +privateImmutableBytesWritable row @@ -283,7 +283,7 @@ extends https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html scanner -privateClientSideRegionScanner scanner +privateClientSideRegionScanner scanner @@ -300,7 +300,7 @@ extends https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html RecordReader -publicRecordReader() +publicRecordReader() @@ -317,7 +317,7 @@ extends https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html getScanner -publicClientSideRegionScannergetScanner() +publicClientSideRegionScannergetScanner() @@ -326,7 +326,7 @@ extends https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html initialize -publicvoidinitialize(TableSnapshotInputFormatImpl.InputSplitsplit, +publicvoidinitialize(TableSnapshotInputFormatImpl.InputSplitsplit, org.apache.hadoop.conf.Configurationconf) throws https://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true; title="class or interface in java.io">IOException @@ -341,7 +341,7 @@ extends https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html nextKeyValue -publicbooleannextKeyValue() +publicbooleannextKeyValue() throws https://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true; title="class or interface in java.io">IOException Throws: @@ -355,7 +355,7 @@ extends https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html getCurrentKey -publicImmutableBytesWritablegetCurrentKey() +publicImmutableBytesWritablegetCurrentKey() @@ -364,7 +364,7 @@ extends https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html getCurrentValue -publicResultgetCurrentValue() +publicResultgetCurrentValue() @@ -373,7 +373,7 @@ extends https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html getPos -publiclonggetPos() +publiclonggetPos() @@ -382,7 +382,7 @@ extends https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html getProgress -publicfloatgetProgress() +publicfloatgetProgress() @@ -391,7 +391,7 @@ extends https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html close -publicvoidclose() +publicvoidclose() http://git-wip-us.apache.org/repos/asf/hbase-site/blob/a754d895/devapidocs/org/apache/hadoop/hbase/mapreduce/TableSnapshotInputFormatImpl.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/mapreduce/TableSnapshotInputFormatImpl.html b/devapidocs/org/apache/hadoop/hbase/mapreduce/TableSnapshotInputFormatImpl.html index 83e4648..7932341 100644 --- a/devapidocs/org/apache/hadoop/hbase/mapreduce/TableSnapshotInputFormatImpl.html +++ b/devapidocs/org/apache/hadoop/hbase/mapreduce/TableSnapshotInputFormatImpl.html @@ -110,7 +110,7 @@ var activeTableTab = "activeTableTab"; @InterfaceAudience.Private -public class TableSnapshotInputFormatImpl +public class TableSnapshotInputFormatImpl extends https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true; title="class or interface in java.lang">Object Hadoop MR API-agnostic implementation for mapreduce over table snapshots. @@ -351,7 +351,7 @@
[27/51] [partial] hbase-site git commit: Published site at 31da4d0bce69b3a47066a5df675756087ce4dc60.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/a754d895/devapidocs/org/apache/hadoop/hbase/master/assignment/GCMergedRegionsProcedure.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/master/assignment/GCMergedRegionsProcedure.html b/devapidocs/org/apache/hadoop/hbase/master/assignment/GCMergedRegionsProcedure.html index fa987ee..a13341f 100644 --- a/devapidocs/org/apache/hadoop/hbase/master/assignment/GCMergedRegionsProcedure.html +++ b/devapidocs/org/apache/hadoop/hbase/master/assignment/GCMergedRegionsProcedure.html @@ -317,7 +317,7 @@ extends AbstractStateMachineTableProcedure -acquireLock, checkTableModifiable, getRegionDir, getUser, releaseLock, < a href="../../../../../../org/apache/hadoop/hbase/master/procedure/AbstractStateMachineTableProcedure.html#releaseSyncLatch--">releaseSyncLatch, setUser +acquireLock, checkTableModifiable, getRegionDir, getUser, preflightChecks, releaseLock, releaseSyncLatch, setUser http://git-wip-us.apache.org/repos/asf/hbase-site/blob/a754d895/devapidocs/org/apache/hadoop/hbase/master/assignment/GCRegionProcedure.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/master/assignment/GCRegionProcedure.html b/devapidocs/org/apache/hadoop/hbase/master/assignment/GCRegionProcedure.html index 72ff612..671b283 100644 --- a/devapidocs/org/apache/hadoop/hbase/master/assignment/GCRegionProcedure.html +++ b/devapidocs/org/apache/hadoop/hbase/master/assignment/GCRegionProcedure.html @@ -305,7 +305,7 @@ extends AbstractStateMachineTableProcedure -getRegionDir, getUser, releaseSyncLatch, setUser +getRegionDir, getUser, preflightChecks, releaseSyncLatch, setUser http://git-wip-us.apache.org/repos/asf/hbase-site/blob/a754d895/devapidocs/org/apache/hadoop/hbase/master/assignment/MergeTableRegionsProcedure.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/master/assignment/MergeTableRegionsProcedure.html b/devapidocs/org/apache/hadoop/hbase/master/assignment/MergeTableRegionsProcedure.html index 347cea7..2881954 100644 --- a/devapidocs/org/apache/hadoop/hbase/master/assignment/MergeTableRegionsProcedure.html +++ b/devapidocs/org/apache/hadoop/hbase/master/assignment/MergeTableRegionsProcedure.html @@ -129,11 +129,13 @@ var activeTableTab = "activeTableTab"; @InterfaceAudience.Private -public class MergeTableRegionsProcedure +public class MergeTableRegionsProcedure extends AbstractStateMachineTableProcedureorg.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.MergeTableRegionsState The procedure to Merge a region in a table. This procedure takes an exclusive table lock since it is working over multiple regions. - It holds the lock for the life of the procedure. + It holds the lock for the life of the procedure. + Throws exception on construction if determines context hostile to merge (cluster going + down or master is shutting down or table is disabled). @@ -520,7 +522,7 @@ extends AbstractStateMachineTableProcedure -checkTableModifiable, getRegionDir, getUser, releaseSyncLatch, setUser +checkTableModifiable, getRegionDir, getUser, preflightChecks, releaseSyncLatch, setUser @@ -563,7 +565,7 @@ extends LOG -private static finalorg.slf4j.Logger LOG +private static finalorg.slf4j.Logger LOG @@ -572,7 +574,7 @@ extends traceEnabled -privatehttps://docs.oracle.com/javase/8/docs/api/java/lang/Boolean.html?is-external=true; title="class or interface in java.lang">Boolean traceEnabled +privatehttps://docs.oracle.com/javase/8/docs/api/java/lang/Boolean.html?is-external=true; title="class or interface in java.lang">Boolean traceEnabled @@ -581,7 +583,7 @@ extends lock -private volatileboolean lock +private volatileboolean lock @@ -590,7 +592,7 @@ extends regionLocation -privateServerName regionLocation +privateServerName regionLocation @@ -599,7 +601,7 @@ extends regionsToMerge -privateRegionInfo[] regionsToMerge +privateRegionInfo[] regionsToMerge @@ -608,7 +610,7 @@ extends mergedRegion -privateRegionInfo mergedRegion +privateRegionInfo mergedRegion @@ -617,7 +619,7 @@ extends forcible -privateboolean forcible +privateboolean forcible @@ -634,7 +636,7 @@ extends MergeTableRegionsProcedure -publicMergeTableRegionsProcedure() +publicMergeTableRegionsProcedure() @@ -643,7 +645,7 @@ extends MergeTableRegionsProcedure -publicMergeTableRegionsProcedure(MasterProcedureEnvenv, +publicMergeTableRegionsProcedure(MasterProcedureEnvenv, RegionInforegionToMergeA, RegionInforegionToMergeB) throws https://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true; title="class or interface in
[43/51] [partial] hbase-site git commit: Published site at 31da4d0bce69b3a47066a5df675756087ce4dc60.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/a754d895/devapidocs/org/apache/hadoop/hbase/HConstants.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/HConstants.html b/devapidocs/org/apache/hadoop/hbase/HConstants.html index 95d3dbf..feefcbf 100644 --- a/devapidocs/org/apache/hadoop/hbase/HConstants.html +++ b/devapidocs/org/apache/hadoop/hbase/HConstants.html @@ -2089,7 +2089,7 @@ extends https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html ZERO_L -public static finalhttps://docs.oracle.com/javase/8/docs/api/java/lang/Long.html?is-external=true; title="class or interface in java.lang">Long ZERO_L +public static finalhttps://docs.oracle.com/javase/8/docs/api/java/lang/Long.html?is-external=true; title="class or interface in java.lang">Long ZERO_L long constant for zero @@ -2099,7 +2099,7 @@ extends https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html NINES -public static finalhttps://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String NINES +public static finalhttps://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String NINES See Also: Constant Field Values @@ -2112,7 +2112,7 @@ extends https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html ZEROES -public static finalhttps://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String ZEROES +public static finalhttps://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String ZEROES See Also: Constant Field Values @@ -2125,7 +2125,7 @@ extends https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html VERSION_FILE_NAME -public static finalhttps://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String VERSION_FILE_NAME +public static finalhttps://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String VERSION_FILE_NAME name of version file See Also: @@ -2139,7 +2139,7 @@ extends https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html FILE_SYSTEM_VERSION -public static finalhttps://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String FILE_SYSTEM_VERSION +public static finalhttps://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String FILE_SYSTEM_VERSION Current version of file system. Version 4 supports only one kind of bloom filter. Version 5 changes versions in catalog table regions. @@ -2158,7 +2158,7 @@ extends https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html CLUSTER_DISTRIBUTED -public static finalhttps://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String CLUSTER_DISTRIBUTED +public static finalhttps://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String CLUSTER_DISTRIBUTED Cluster is in distributed mode or not See Also: @@ -2172,7 +2172,7 @@ extends https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html HBASE_MASTER_LOADBALANCER_CLASS -public static finalhttps://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String HBASE_MASTER_LOADBALANCER_CLASS +public static finalhttps://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String HBASE_MASTER_LOADBALANCER_CLASS Config for pluggable load balancers See Also: @@ -2186,7 +2186,7 @@ extends https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html HBASE_MASTER_LOADBALANCE_BYTABLE -public static finalhttps://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String HBASE_MASTER_LOADBALANCE_BYTABLE +public static finalhttps://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String HBASE_MASTER_LOADBALANCE_BYTABLE Config for balancing the cluster by table See Also: @@ -2200,7 +2200,7 @@ extends https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html HBASE_MASTER_BALANCER_MAX_RIT_PERCENT -public static finalhttps://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String HBASE_MASTER_BALANCER_MAX_RIT_PERCENT +public static finalhttps://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String
[50/51] [partial] hbase-site git commit: Published site at 31da4d0bce69b3a47066a5df675756087ce4dc60.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/a754d895/apidocs/org/apache/hadoop/hbase/HConstants.html -- diff --git a/apidocs/org/apache/hadoop/hbase/HConstants.html b/apidocs/org/apache/hadoop/hbase/HConstants.html index 4ef1eb8..66fd992 100644 --- a/apidocs/org/apache/hadoop/hbase/HConstants.html +++ b/apidocs/org/apache/hadoop/hbase/HConstants.html @@ -2049,7 +2049,7 @@ extends https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html ZERO_L -public static finalhttps://docs.oracle.com/javase/8/docs/api/java/lang/Long.html?is-external=true; title="class or interface in java.lang">Long ZERO_L +public static finalhttps://docs.oracle.com/javase/8/docs/api/java/lang/Long.html?is-external=true; title="class or interface in java.lang">Long ZERO_L long constant for zero @@ -2059,7 +2059,7 @@ extends https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html NINES -public static finalhttps://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String NINES +public static finalhttps://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String NINES See Also: Constant Field Values @@ -2072,7 +2072,7 @@ extends https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html ZEROES -public static finalhttps://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String ZEROES +public static finalhttps://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String ZEROES See Also: Constant Field Values @@ -2085,7 +2085,7 @@ extends https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html VERSION_FILE_NAME -public static finalhttps://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String VERSION_FILE_NAME +public static finalhttps://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String VERSION_FILE_NAME name of version file See Also: @@ -2099,7 +2099,7 @@ extends https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html FILE_SYSTEM_VERSION -public static finalhttps://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String FILE_SYSTEM_VERSION +public static finalhttps://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String FILE_SYSTEM_VERSION Current version of file system. Version 4 supports only one kind of bloom filter. Version 5 changes versions in catalog table regions. @@ -2118,7 +2118,7 @@ extends https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html CLUSTER_DISTRIBUTED -public static finalhttps://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String CLUSTER_DISTRIBUTED +public static finalhttps://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String CLUSTER_DISTRIBUTED Cluster is in distributed mode or not See Also: @@ -2132,7 +2132,7 @@ extends https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html HBASE_MASTER_LOADBALANCER_CLASS -public static finalhttps://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String HBASE_MASTER_LOADBALANCER_CLASS +public static finalhttps://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String HBASE_MASTER_LOADBALANCER_CLASS Config for pluggable load balancers See Also: @@ -2146,7 +2146,7 @@ extends https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html HBASE_MASTER_LOADBALANCE_BYTABLE -public static finalhttps://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String HBASE_MASTER_LOADBALANCE_BYTABLE +public static finalhttps://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String HBASE_MASTER_LOADBALANCE_BYTABLE Config for balancing the cluster by table See Also: @@ -2160,7 +2160,7 @@ extends https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html HBASE_MASTER_BALANCER_MAX_RIT_PERCENT -public static finalhttps://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String HBASE_MASTER_BALANCER_MAX_RIT_PERCENT +public static finalhttps://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String HBASE_MASTER_BALANCER_MAX_RIT_PERCENT
[40/51] [partial] hbase-site git commit: Published site at 31da4d0bce69b3a47066a5df675756087ce4dc60.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/a754d895/devapidocs/org/apache/hadoop/hbase/backup/master/LogRollMasterProcedureManager.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/backup/master/LogRollMasterProcedureManager.html b/devapidocs/org/apache/hadoop/hbase/backup/master/LogRollMasterProcedureManager.html index a560113..e00e6da 100644 --- a/devapidocs/org/apache/hadoop/hbase/backup/master/LogRollMasterProcedureManager.html +++ b/devapidocs/org/apache/hadoop/hbase/backup/master/LogRollMasterProcedureManager.html @@ -18,7 +18,7 @@ catch(err) { } //--> -var methods = {"i0":10,"i1":10,"i2":10,"i3":10,"i4":10,"i5":10,"i6":10}; +var methods = {"i0":10,"i1":10,"i2":10,"i3":10,"i4":10,"i5":10,"i6":10,"i7":10}; var tabs = {65535:["t0","All Methods"],2:["t2","Instance Methods"],8:["t4","Concrete Methods"]}; var altColor = "altColor"; var rowColor = "rowColor"; @@ -124,10 +124,10 @@ var activeTableTab = "activeTableTab"; @InterfaceAudience.Private -public class LogRollMasterProcedureManager +public class LogRollMasterProcedureManager extends MasterProcedureManager Master procedure manager for coordinated cluster-wide WAL roll operation, which is run during - backup operation, see MasterProcedureManager and and RegionServerProcedureManager + backup operation, see MasterProcedureManager and RegionServerProcedureManager @@ -228,38 +228,46 @@ extends void +checkPermissions(org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.ProcedureDescriptiondesc, +AccessCheckeraccessChecker, +Useruser) +Check for required permissions before executing the procedure. + + + +void execProcedure(org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.ProcedureDescriptiondesc) Execute a distributed procedure on cluster - + https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String getProcedureSignature() Return the unique signature of the procedure. - + void initialize(MasterServicesmaster, MetricsMastermetricsMaster) Initialize a globally barriered procedure for master. - + private boolean isBackupEnabled() - + boolean isProcedureDone(org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.ProcedureDescriptiondesc) Check if the procedure is finished successfully - + boolean isStopped() - + void stop(https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">Stringwhy) Stop this service. @@ -307,7 +315,7 @@ extends LOG -private static finalorg.slf4j.Logger LOG +private static finalorg.slf4j.Logger LOG @@ -316,7 +324,7 @@ extends ROLLLOG_PROCEDURE_SIGNATURE -public static finalhttps://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String ROLLLOG_PROCEDURE_SIGNATURE +public static finalhttps://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String ROLLLOG_PROCEDURE_SIGNATURE See Also: Constant Field Values @@ -329,7 +337,7 @@ extends ROLLLOG_PROCEDURE_NAME -public static finalhttps://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String ROLLLOG_PROCEDURE_NAME +public static finalhttps://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String ROLLLOG_PROCEDURE_NAME See Also: Constant Field Values @@ -342,7 +350,7 @@ extends BACKUP_WAKE_MILLIS_KEY -public static finalhttps://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String BACKUP_WAKE_MILLIS_KEY +public static finalhttps://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String BACKUP_WAKE_MILLIS_KEY See Also: Constant Field Values @@ -355,7 +363,7 @@ extends BACKUP_TIMEOUT_MILLIS_KEY -public static finalhttps://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String BACKUP_TIMEOUT_MILLIS_KEY +public static finalhttps://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String BACKUP_TIMEOUT_MILLIS_KEY See Also: Constant Field Values @@ -368,7 +376,7 @@ extends BACKUP_POOL_THREAD_NUMBER_KEY -public static finalhttps://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String BACKUP_POOL_THREAD_NUMBER_KEY +public static finalhttps://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String BACKUP_POOL_THREAD_NUMBER_KEY See
[21/51] [partial] hbase-site git commit: Published site at 31da4d0bce69b3a47066a5df675756087ce4dc60.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/a754d895/devapidocs/org/apache/hadoop/hbase/master/procedure/class-use/MasterProcedureEnv.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/master/procedure/class-use/MasterProcedureEnv.html b/devapidocs/org/apache/hadoop/hbase/master/procedure/class-use/MasterProcedureEnv.html index b75fbbe..159fa7e 100644 --- a/devapidocs/org/apache/hadoop/hbase/master/procedure/class-use/MasterProcedureEnv.html +++ b/devapidocs/org/apache/hadoop/hbase/master/procedure/class-use/MasterProcedureEnv.html @@ -1379,344 +1379,351 @@ +protected void +AbstractStateMachineTableProcedure.preflightChecks(MasterProcedureEnvenv, + https://docs.oracle.com/javase/8/docs/api/java/lang/Boolean.html?is-external=true; title="class or interface in java.lang">Booleanenabled) +Check that cluster is up and master is running. + + + private void ModifyTableProcedure.preModify(MasterProcedureEnvenv, org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.ModifyTableStatestate) Action before modifying table. - + private void RecoverMetaProcedure.prepare(MasterProcedureEnvenv) Prepare for execution - + private void CloneSnapshotProcedure.prepareClone(MasterProcedureEnvenv) Action before any real action of cloning from snapshot. - + private boolean CreateNamespaceProcedure.prepareCreate(MasterProcedureEnvenv) Action before any real action of creating namespace. - + private boolean CreateTableProcedure.prepareCreate(MasterProcedureEnvenv) - + private boolean DeleteTableProcedure.prepareDelete(MasterProcedureEnvenv) - + private boolean DeleteNamespaceProcedure.prepareDelete(MasterProcedureEnvenv) Action before any real action of deleting namespace. - + private boolean DisableTableProcedure.prepareDisable(MasterProcedureEnvenv) Action before any real action of disabling table. - + private boolean EnableTableProcedure.prepareEnable(MasterProcedureEnvenv) Action before any real action of enabling table. - + private boolean ModifyNamespaceProcedure.prepareModify(MasterProcedureEnvenv) Action before any real action of adding namespace. - + private void ModifyTableProcedure.prepareModify(MasterProcedureEnvenv) Check conditions before any real action of modifying a table. - + private void RestoreSnapshotProcedure.prepareRestore(MasterProcedureEnvenv) Action before any real action of restoring from snapshot. - + private boolean TruncateTableProcedure.prepareTruncate(MasterProcedureEnvenv) - + private boolean TruncateTableProcedure.preTruncate(MasterProcedureEnvenv) - + private void ServerCrashProcedure.processMeta(MasterProcedureEnvenv) - + protected void AbstractStateMachineNamespaceProcedure.releaseLock(MasterProcedureEnvenv) - + protected void AbstractStateMachineRegionProcedure.releaseLock(MasterProcedureEnvenv) - + protected void AbstractStateMachineTableProcedure.releaseLock(MasterProcedureEnvenv) - + protected void ServerCrashProcedure.releaseLock(MasterProcedureEnvenv) - + protected void RecoverMetaProcedure.releaseLock(MasterProcedureEnvenv) - + private void RSProcedureDispatcher.CloseRegionRemoteCall.remoteCallCompleted(MasterProcedureEnvenv, org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CloseRegionResponseresponse) - + private void RSProcedureDispatcher.ExecuteProceduresRemoteCall.remoteCallFailed(MasterProcedureEnvenv, https://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true; title="class or interface in java.io">IOExceptione) - + private void RSProcedureDispatcher.OpenRegionRemoteCall.remoteCallFailed(MasterProcedureEnvenv, https://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true; title="class or interface in java.io">IOExceptione) - + private void RSProcedureDispatcher.CloseRegionRemoteCall.remoteCallFailed(MasterProcedureEnvenv, https://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true; title="class or interface in java.io">IOExceptione) - + protected static void DeleteNamespaceProcedure.removeFromZKNamespaceManager(MasterProcedureEnvenv, https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">StringnamespaceName) remove from ZooKeeper. - + protected static void DeleteNamespaceProcedure.removeNamespaceQuota(MasterProcedureEnvenv, https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">StringnamespaceName) remove quota for the namespace - + private void RestoreSnapshotProcedure.restoreSnapshot(MasterProcedureEnvenv) Execute the on-disk Restore - + private void
[20/51] [partial] hbase-site git commit: Published site at 31da4d0bce69b3a47066a5df675756087ce4dc60.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/a754d895/devapidocs/org/apache/hadoop/hbase/master/snapshot/SnapshotManager.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/master/snapshot/SnapshotManager.html b/devapidocs/org/apache/hadoop/hbase/master/snapshot/SnapshotManager.html index 26333d9..cc6116d 100644 --- a/devapidocs/org/apache/hadoop/hbase/master/snapshot/SnapshotManager.html +++ b/devapidocs/org/apache/hadoop/hbase/master/snapshot/SnapshotManager.html @@ -18,7 +18,7 @@ catch(err) { } //--> -var methods = {"i0":10,"i1":10,"i2":10,"i3":10,"i4":10,"i5":10,"i6":10,"i7":10,"i8":10,"i9":10,"i10":10,"i11":10,"i12":10,"i13":10,"i14":10,"i15":10,"i16":10,"i17":10,"i18":10,"i19":10,"i20":10,"i21":10,"i22":10,"i23":10,"i24":10,"i25":10,"i26":10,"i27":10,"i28":10,"i29":10,"i30":10,"i31":10,"i32":10,"i33":10,"i34":10}; +var methods = {"i0":10,"i1":10,"i2":10,"i3":10,"i4":10,"i5":10,"i6":10,"i7":10,"i8":10,"i9":10,"i10":10,"i11":10,"i12":10,"i13":10,"i14":10,"i15":10,"i16":10,"i17":10,"i18":10,"i19":10,"i20":10,"i21":10,"i22":10,"i23":10,"i24":10,"i25":10,"i26":10,"i27":10,"i28":10,"i29":10,"i30":10,"i31":10,"i32":10,"i33":10,"i34":10,"i35":10}; var tabs = {65535:["t0","All Methods"],2:["t2","Instance Methods"],8:["t4","Concrete Methods"]}; var altColor = "altColor"; var rowColor = "rowColor"; @@ -125,7 +125,7 @@ var activeTableTab = "activeTableTab"; @InterfaceAudience.LimitedPrivate(value="Configuration") @InterfaceStability.Unstable -public class SnapshotManager +public class SnapshotManager extends MasterProcedureManager implements Stoppable This class manages the procedure of taking and restoring snapshots. There is only one @@ -285,11 +285,19 @@ implements void +checkPermissions(org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.ProcedureDescriptiondesc, +AccessCheckeraccessChecker, +Useruser) +Check for required permissions before executing the procedure. + + + +void checkSnapshotSupport() Throws an exception if snapshot operations (take a snapshot, restore, clone) are not supported. - + private void checkSnapshotSupport(org.apache.hadoop.conf.Configurationconf, MasterFileSystemmfs) @@ -297,26 +305,26 @@ implements - + private void cleanupCompletedRestoreInMap() Remove the procedures that are marked as finished - + private void cleanupSentinels() Removes "abandoned" snapshot/restore requests. - + private void cleanupSentinels(https://docs.oracle.com/javase/8/docs/api/java/util/Map.html?is-external=true; title="class or interface in java.util">MapTableName,SnapshotSentinelsentinels) Remove the sentinels that are marked as finished and the completion time has exceeded the removal timeout. - + (package private) long cloneSnapshot(org.apache.hadoop.hbase.shaded.protobuf.generated.SnapshotProtos.SnapshotDescriptionsnapshot, TableDescriptortableDescriptor, @@ -325,7 +333,7 @@ implements Clone the specified snapshot into a new table. - + private long cloneSnapshot(org.apache.hadoop.hbase.shaded.protobuf.generated.SnapshotProtos.SnapshotDescriptionreqSnapshot, TableNametableName, @@ -336,114 +344,114 @@ implements Clone the specified snapshot. - + void deleteSnapshot(org.apache.hadoop.hbase.shaded.protobuf.generated.SnapshotProtos.SnapshotDescriptionsnapshot) Delete the specified snapshot - + void execProcedure(org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.ProcedureDescriptiondesc) Execute a distributed procedure on cluster - + https://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true; title="class or interface in java.util">Listorg.apache.hadoop.hbase.shaded.protobuf.generated.SnapshotProtos.SnapshotDescription getCompletedSnapshots() Gets the list of all completed snapshots. - + private https://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true; title="class or interface in java.util">Listorg.apache.hadoop.hbase.shaded.protobuf.generated.SnapshotProtos.SnapshotDescription getCompletedSnapshots(org.apache.hadoop.fs.PathsnapshotDir, booleanwithCpCall) Gets the list of all completed snapshots. - + (package private) ProcedureCoordinator getCoordinator() - + KeyLockerhttps://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String getLocks() - + https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String getProcedureSignature() Return the unique signature of the procedure. - + void initialize(MasterServicesmaster, MetricsMastermetricsMaster) Initialize a globally barriered procedure for master. - + boolean
[01/51] [partial] hbase-site git commit: Published site at 31da4d0bce69b3a47066a5df675756087ce4dc60.
Repository: hbase-site Updated Branches: refs/heads/asf-site 291a8cf98 -> a754d8956 http://git-wip-us.apache.org/repos/asf/hbase-site/blob/a754d895/devapidocs/org/apache/hadoop/hbase/replication/TableReplicationPeerStorage.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/replication/TableReplicationPeerStorage.html b/devapidocs/org/apache/hadoop/hbase/replication/TableReplicationPeerStorage.html new file mode 100644 index 000..d59a2b0 --- /dev/null +++ b/devapidocs/org/apache/hadoop/hbase/replication/TableReplicationPeerStorage.html @@ -0,0 +1,497 @@ +http://www.w3.org/TR/html4/loose.dtd;> + + + + + +TableReplicationPeerStorage (Apache HBase 3.0.0-SNAPSHOT API) + + + + + +var methods = {"i0":10,"i1":10,"i2":10,"i3":10,"i4":10,"i5":10,"i6":10,"i7":10}; +var tabs = {65535:["t0","All Methods"],2:["t2","Instance Methods"],8:["t4","Concrete Methods"]}; +var altColor = "altColor"; +var rowColor = "rowColor"; +var tableTab = "tableTab"; +var activeTableTab = "activeTableTab"; + + +JavaScript is disabled on your browser. + + + + + +Skip navigation links + + + + +Overview +Package +Class +Use +Tree +Deprecated +Index +Help + + + + +PrevClass +NextClass + + +Frames +NoFrames + + +AllClasses + + + + + + + +Summary: +Nested| +Field| +Constr| +Method + + +Detail: +Field| +Constr| +Method + + + + + + + + +org.apache.hadoop.hbase.replication +Class TableReplicationPeerStorage + + + +https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true; title="class or interface in java.lang">java.lang.Object + + +org.apache.hadoop.hbase.replication.TableReplicationStorageBase + + +org.apache.hadoop.hbase.replication.TableReplicationPeerStorage + + + + + + + + + +All Implemented Interfaces: +ReplicationPeerStorage + + + +@InterfaceAudience.Private +public class TableReplicationPeerStorage +extends TableReplicationStorageBase +implements ReplicationPeerStorage +Table based replication peer storage. + + + + + + + + + + + +Field Summary + + + + +Fields inherited from classorg.apache.hadoop.hbase.replication.TableReplicationStorageBase +conf, FAMILY_HFILE_REFS, FAMILY_PEER, FAMILY_QUEUE, FAMILY_REGIONS, FAMILY_RS_STATE, FAMILY_WAL, QU ALIFIER_PEER_CONFIG, QUALIFIER_PEER_STATE, QUALIFIER_STATE_ENABLED, REPLICATION_TABLE, zookeeper + + + + + + + + +Constructor Summary + +Constructors + +Constructor and Description + + +TableReplicationPeerStorage(ZKWatcherzookeeper, + org.apache.hadoop.conf.Configurationconf) + + + + + + + + + +Method Summary + +All MethodsInstance MethodsConcrete Methods + +Modifier and Type +Method and Description + + +void +addPeer(https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">StringpeerId, + ReplicationPeerConfigpeerConfig, + booleanenabled) +Add a replication peer. + + + +ReplicationPeerConfig +getPeerConfig(https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">StringpeerId) +Get the peer config of a replication peer. + + + +boolean +isPeerEnabled(https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">StringpeerId) +Test whether a replication peer is enabled. + + + +https://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true; title="class or interface in java.util">Listhttps://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String +listPeerIds() +Return the peer ids of all replication peers. + + + +private boolean +peerExist(https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">StringpeerId, + Tabletable) + + +void +removePeer(https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">StringpeerId) +Remove a replication peer. + + + +void +setPeerState(https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">StringpeerId, +booleanenabled) +Set the state of peer, true to ENABLED, otherwise to DISABLED. + + + +void +updatePeerConfig(https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">StringpeerId, +
[06/51] [partial] hbase-site git commit: Published site at 31da4d0bce69b3a47066a5df675756087ce4dc60.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/a754d895/devapidocs/org/apache/hadoop/hbase/regionserver/RegionCoprocessorHost.BulkLoadObserverOperation.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/regionserver/RegionCoprocessorHost.BulkLoadObserverOperation.html b/devapidocs/org/apache/hadoop/hbase/regionserver/RegionCoprocessorHost.BulkLoadObserverOperation.html index 9771a14..136a97b 100644 --- a/devapidocs/org/apache/hadoop/hbase/regionserver/RegionCoprocessorHost.BulkLoadObserverOperation.html +++ b/devapidocs/org/apache/hadoop/hbase/regionserver/RegionCoprocessorHost.BulkLoadObserverOperation.html @@ -126,7 +126,7 @@ -abstract class RegionCoprocessorHost.BulkLoadObserverOperation +abstract class RegionCoprocessorHost.BulkLoadObserverOperation extends CoprocessorHost.ObserverOperationWithoutResultBulkLoadObserver @@ -205,7 +205,7 @@ extends BulkLoadObserverOperation -publicBulkLoadObserverOperation(Useruser) +publicBulkLoadObserverOperation(Useruser) http://git-wip-us.apache.org/repos/asf/hbase-site/blob/a754d895/devapidocs/org/apache/hadoop/hbase/regionserver/RegionCoprocessorHost.RegionEnvironment.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/regionserver/RegionCoprocessorHost.RegionEnvironment.html b/devapidocs/org/apache/hadoop/hbase/regionserver/RegionCoprocessorHost.RegionEnvironment.html index c88b1db..067b5c4 100644 --- a/devapidocs/org/apache/hadoop/hbase/regionserver/RegionCoprocessorHost.RegionEnvironment.html +++ b/devapidocs/org/apache/hadoop/hbase/regionserver/RegionCoprocessorHost.RegionEnvironment.html @@ -126,7 +126,7 @@ var activeTableTab = "activeTableTab"; -private static class RegionCoprocessorHost.RegionEnvironment +private static class RegionCoprocessorHost.RegionEnvironment extends BaseEnvironmentRegionCoprocessor implements RegionCoprocessorEnvironment Encapsulation of the environment of each coprocessor @@ -303,7 +303,7 @@ implements region -privateRegion region +privateRegion region @@ -312,7 +312,7 @@ implements sharedData -https://docs.oracle.com/javase/8/docs/api/java/util/concurrent/ConcurrentMap.html?is-external=true; title="class or interface in java.util.concurrent">ConcurrentMaphttps://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String,https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true; title="class or interface in java.lang">Object sharedData +https://docs.oracle.com/javase/8/docs/api/java/util/concurrent/ConcurrentMap.html?is-external=true; title="class or interface in java.util.concurrent">ConcurrentMaphttps://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String,https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true; title="class or interface in java.lang">Object sharedData @@ -321,7 +321,7 @@ implements metricRegistry -private finalMetricRegistry metricRegistry +private finalMetricRegistry metricRegistry @@ -330,7 +330,7 @@ implements services -private finalRegionServerServices services +private finalRegionServerServices services @@ -347,7 +347,7 @@ implements RegionEnvironment -publicRegionEnvironment(RegionCoprocessorimpl, +publicRegionEnvironment(RegionCoprocessorimpl, intpriority, intseq, org.apache.hadoop.conf.Configurationconf, @@ -376,7 +376,7 @@ implements getRegion -publicRegiongetRegion() +publicRegiongetRegion() Specified by: getRegionin interfaceRegionCoprocessorEnvironment @@ -391,7 +391,7 @@ implements getOnlineRegions -publicOnlineRegionsgetOnlineRegions() +publicOnlineRegionsgetOnlineRegions() Specified by: getOnlineRegionsin interfaceRegionCoprocessorEnvironment @@ -406,7 +406,7 @@ implements getConnection -publicConnectiongetConnection() +publicConnectiongetConnection() Description copied from interface:RegionCoprocessorEnvironment Returns the hosts' Connection to the Cluster. Do not close! This is a shared connection with the hosting server. Throws https://docs.oracle.com/javase/8/docs/api/java/lang/UnsupportedOperationException.html?is-external=true; title="class or interface in java.lang">UnsupportedOperationException if you try to close @@ -445,7 +445,7 @@ implements createConnection -publicConnectioncreateConnection(org.apache.hadoop.conf.Configurationconf) +publicConnectioncreateConnection(org.apache.hadoop.conf.Configurationconf) throws https://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true; title="class or interface in java.io">IOException Description copied from interface:RegionCoprocessorEnvironment Creates a cluster
[25/51] [partial] hbase-site git commit: Published site at 31da4d0bce69b3a47066a5df675756087ce4dc60.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/a754d895/devapidocs/org/apache/hadoop/hbase/master/cleaner/ReplicationBarrierCleaner.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/master/cleaner/ReplicationBarrierCleaner.html b/devapidocs/org/apache/hadoop/hbase/master/cleaner/ReplicationBarrierCleaner.html new file mode 100644 index 000..1378f27 --- /dev/null +++ b/devapidocs/org/apache/hadoop/hbase/master/cleaner/ReplicationBarrierCleaner.html @@ -0,0 +1,401 @@ +http://www.w3.org/TR/html4/loose.dtd;> + + + + + +ReplicationBarrierCleaner (Apache HBase 3.0.0-SNAPSHOT API) + + + + + +var methods = {"i0":10}; +var tabs = {65535:["t0","All Methods"],2:["t2","Instance Methods"],8:["t4","Concrete Methods"]}; +var altColor = "altColor"; +var rowColor = "rowColor"; +var tableTab = "tableTab"; +var activeTableTab = "activeTableTab"; + + +JavaScript is disabled on your browser. + + + + + +Skip navigation links + + + + +Overview +Package +Class +Use +Tree +Deprecated +Index +Help + + + + +PrevClass +NextClass + + +Frames +NoFrames + + +AllClasses + + + + + + + +Summary: +Nested| +Field| +Constr| +Method + + +Detail: +Field| +Constr| +Method + + + + + + + + +org.apache.hadoop.hbase.master.cleaner +Class ReplicationBarrierCleaner + + + +https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true; title="class or interface in java.lang">java.lang.Object + + +org.apache.hadoop.hbase.ScheduledChore + + +org.apache.hadoop.hbase.master.cleaner.ReplicationBarrierCleaner + + + + + + + + + +All Implemented Interfaces: +https://docs.oracle.com/javase/8/docs/api/java/lang/Runnable.html?is-external=true; title="class or interface in java.lang">Runnable + + + +@InterfaceAudience.Private +public class ReplicationBarrierCleaner +extends ScheduledChore +Used to clean the useless barriers in HConstants.REPLICATION_BARRIER_FAMILY_STR family in + meta table. + + + + + + + + + + + +Field Summary + +Fields + +Modifier and Type +Field and Description + + +private Connection +conn + + +private static int +DEFAULT_REPLICATION_BARRIER_CLEANER_INTERVAL + + +private static org.slf4j.Logger +LOG + + +private ReplicationPeerManager +peerManager + + +private static https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String +REPLICATION_BARRIER_CLEANER_INTERVAL + + + + + + + + + +Constructor Summary + +Constructors + +Constructor and Description + + +ReplicationBarrierCleaner(org.apache.hadoop.conf.Configurationconf, + Stoppablestopper, + Connectionconn, + ReplicationPeerManagerpeerManager) + + + + + + + + + +Method Summary + +All MethodsInstance MethodsConcrete Methods + +Modifier and Type +Method and Description + + +protected void +chore() +The task to execute on each scheduled execution of the Chore + + + + + + + +Methods inherited from classorg.apache.hadoop.hbase.ScheduledChore +cancel, cancel, choreForTesting, cleanup, getInitialDelay, getName, getPeriod, getStopper, getTimeUnit, initialChore, isInitialChoreComplete, isScheduled, run, toString, triggerNow + + + + + +Methods inherited from classjava.lang.https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true; title="class or interface in java.lang">Object +https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true#clone--; title="class or interface in java.lang">clone, https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true#equals-java.lang.Object-; title="class or interface in java.lang">equals, https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true#finalize--; title="class or interface in java.lang">finalize, https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true#getClass--; title="class or interface in java.lang">getClass, https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true#hashCode--; title="class or interface in java.lang">hashCode, https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true#notify--; title="class or interface in java.lang">notify, https://docs.oracle.com/javase/8/docs/api/ja va/lang/Object.html?is-external=true#notifyAll--" title="class or interface in java.lang">notifyAll, https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true#wait--; title="class or
[28/51] [partial] hbase-site git commit: Published site at 31da4d0bce69b3a47066a5df675756087ce4dc60.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/a754d895/devapidocs/org/apache/hadoop/hbase/master/assignment/AssignmentManager.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/master/assignment/AssignmentManager.html b/devapidocs/org/apache/hadoop/hbase/master/assignment/AssignmentManager.html index 6ccfee6..fa0c083 100644 --- a/devapidocs/org/apache/hadoop/hbase/master/assignment/AssignmentManager.html +++ b/devapidocs/org/apache/hadoop/hbase/master/assignment/AssignmentManager.html @@ -1304,7 +1304,7 @@ implements pendingAssignQueue -private finalhttps://docs.oracle.com/javase/8/docs/api/java/util/ArrayList.html?is-external=true; title="class or interface in java.util">ArrayListRegionStates.RegionStateNode pendingAssignQueue +private finalhttps://docs.oracle.com/javase/8/docs/api/java/util/ArrayList.html?is-external=true; title="class or interface in java.util">ArrayListRegionStates.RegionStateNode pendingAssignQueue @@ -1313,7 +1313,7 @@ implements assignQueueLock -private finalhttps://docs.oracle.com/javase/8/docs/api/java/util/concurrent/locks/ReentrantLock.html?is-external=true; title="class or interface in java.util.concurrent.locks">ReentrantLock assignQueueLock +private finalhttps://docs.oracle.com/javase/8/docs/api/java/util/concurrent/locks/ReentrantLock.html?is-external=true; title="class or interface in java.util.concurrent.locks">ReentrantLock assignQueueLock @@ -1322,7 +1322,7 @@ implements assignQueueFullCond -private finalhttps://docs.oracle.com/javase/8/docs/api/java/util/concurrent/locks/Condition.html?is-external=true; title="class or interface in java.util.concurrent.locks">Condition assignQueueFullCond +private finalhttps://docs.oracle.com/javase/8/docs/api/java/util/concurrent/locks/Condition.html?is-external=true; title="class or interface in java.util.concurrent.locks">Condition assignQueueFullCond @@ -1803,7 +1803,12 @@ implements moveAsync -publichttps://docs.oracle.com/javase/8/docs/api/java/util/concurrent/Future.html?is-external=true; title="class or interface in java.util.concurrent">Futurebyte[]moveAsync(RegionPlanregionPlan) +publichttps://docs.oracle.com/javase/8/docs/api/java/util/concurrent/Future.html?is-external=true; title="class or interface in java.util.concurrent">Futurebyte[]moveAsync(RegionPlanregionPlan) + throws HBaseIOException + +Throws: +HBaseIOException + @@ -1899,7 +1904,12 @@ implements createReopenProcedures -publicMoveRegionProcedure[]createReopenProcedures(https://docs.oracle.com/javase/8/docs/api/java/util/Collection.html?is-external=true; title="class or interface in java.util">CollectionRegionInforegionInfo) +publicMoveRegionProcedure[]createReopenProcedures(https://docs.oracle.com/javase/8/docs/api/java/util/Collection.html?is-external=true; title="class or interface in java.util">CollectionRegionInforegionInfo) + throws https://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true; title="class or interface in java.io">IOException + +Throws: +https://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true; title="class or interface in java.io">IOException + @@ -1908,7 +1918,7 @@ implements createUnassignProcedures -publicUnassignProcedure[]createUnassignProcedures(TableNametableName) +publicUnassignProcedure[]createUnassignProcedures(TableNametableName) Called by things like DisableTableProcedure to get a list of UnassignProcedure to unassign the regions of the table. @@ -1919,7 +1929,7 @@ implements createAssignProcedure -publicAssignProcedurecreateAssignProcedure(RegionInforegionInfo) +publicAssignProcedurecreateAssignProcedure(RegionInforegionInfo) @@ -1928,7 +1938,7 @@ implements createAssignProcedure -publicAssignProcedurecreateAssignProcedure(RegionInforegionInfo, +publicAssignProcedurecreateAssignProcedure(RegionInforegionInfo, ServerNametargetServer) @@ -1938,7 +1948,7 @@ implements createUnassignProcedure -UnassignProcedurecreateUnassignProcedure(RegionInforegionInfo, +UnassignProcedurecreateUnassignProcedure(RegionInforegionInfo, ServerNamedestinationServer, booleanforce) @@ -1949,7 +1959,7 @@ implements createUnassignProcedure -UnassignProcedurecreateUnassignProcedure(RegionInforegionInfo, +UnassignProcedurecreateUnassignProcedure(RegionInforegionInfo, ServerNamedestinationServer, booleanforce, booleanremoveAfterUnassigning) @@ -1961,7 +1971,12 @@ implements createMoveRegionProcedure -publicMoveRegionProcedurecreateMoveRegionProcedure(RegionPlanplan)
hbase-site git commit: INFRA-10751 Empty commit
Repository: hbase-site Updated Branches: refs/heads/asf-site a754d8956 -> 291f0a4e9 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/291f0a4e Tree: http://git-wip-us.apache.org/repos/asf/hbase-site/tree/291f0a4e Diff: http://git-wip-us.apache.org/repos/asf/hbase-site/diff/291f0a4e Branch: refs/heads/asf-site Commit: 291f0a4e9824bc38d464f6d236a617b15a7956d7 Parents: a754d89 Author: jenkinsAuthored: Thu Mar 15 14:54:22 2018 + Committer: jenkins Committed: Thu Mar 15 14:54:22 2018 + -- --
[35/51] [partial] hbase-site git commit: Published site at 31da4d0bce69b3a47066a5df675756087ce4dc60.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/a754d895/devapidocs/org/apache/hadoop/hbase/master/HMaster.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/master/HMaster.html b/devapidocs/org/apache/hadoop/hbase/master/HMaster.html index 2c04026..afc44ef 100644 --- a/devapidocs/org/apache/hadoop/hbase/master/HMaster.html +++ b/devapidocs/org/apache/hadoop/hbase/master/HMaster.html @@ -18,7 +18,7 @@ catch(err) { } //--> -var methods = {"i0":10,"i1":10,"i2":10,"i3":10,"i4":10,"i5":10,"i6":10,"i7":10,"i8":10,"i9":10,"i10":10,"i11":10,"i12":10,"i13":10,"i14":10,"i15":10,"i16":10,"i17":10,"i18":10,"i19":10,"i20":10,"i21":10,"i22":10,"i23":9,"i24":10,"i25":10,"i26":10,"i27":10,"i28":10,"i29":10,"i30":10,"i31":10,"i32":9,"i33":10,"i34":10,"i35":10,"i36":10,"i37":10,"i38":10,"i39":10,"i40":10,"i41":9,"i42":10,"i43":10,"i44":10,"i45":10,"i46":10,"i47":10,"i48":10,"i49":10,"i50":10,"i51":10,"i52":10,"i53":10,"i54":10,"i55":10,"i56":10,"i57":10,"i58":10,"i59":10,"i60":10,"i61":9,"i62":10,"i63":10,"i64":10,"i65":10,"i66":10,"i67":10,"i68":10,"i69":10,"i70":10,"i71":10,"i72":10,"i73":10,"i74":10,"i75":10,"i76":10,"i77":10,"i78":10,"i79":10,"i80":10,"i81":10,"i82":10,"i83":10,"i84":10,"i85":10,"i86":10,"i87":10,"i88":10,"i89":10,"i90":10,"i91":10,"i92":10,"i93":10,"i94":10,"i95":10,"i96":10,"i97":10,"i98":10,"i99":10,"i100":10,"i101":10,"i102":10,"i103":10,"i104":10,"i105":10,"i106":10,"i107":10,"i108":10,"i109" :10,"i110":10,"i111":10,"i112":10,"i113":10,"i114":10,"i115":10,"i116":10,"i117":10,"i118":10,"i119":9,"i120":10,"i121":10,"i122":10,"i123":10,"i124":10,"i125":10,"i126":10,"i127":10,"i128":10,"i129":10,"i130":10,"i131":10,"i132":10,"i133":9,"i134":10,"i135":10,"i136":10,"i137":10,"i138":10,"i139":10,"i140":10,"i141":10,"i142":10,"i143":10,"i144":10,"i145":10,"i146":10,"i147":10,"i148":10,"i149":10,"i150":10,"i151":10,"i152":10,"i153":10,"i154":10,"i155":10,"i156":10,"i157":10,"i158":10,"i159":10,"i160":10,"i161":10,"i162":10,"i163":10,"i164":10,"i165":10,"i166":10,"i167":10,"i168":10,"i169":10,"i170":10,"i171":9}; +var methods = {"i0":10,"i1":10,"i2":10,"i3":10,"i4":10,"i5":10,"i6":10,"i7":10,"i8":10,"i9":10,"i10":10,"i11":10,"i12":10,"i13":10,"i14":10,"i15":10,"i16":10,"i17":10,"i18":10,"i19":10,"i20":10,"i21":10,"i22":10,"i23":10,"i24":9,"i25":10,"i26":10,"i27":10,"i28":10,"i29":10,"i30":10,"i31":10,"i32":10,"i33":9,"i34":10,"i35":10,"i36":10,"i37":10,"i38":10,"i39":10,"i40":10,"i41":10,"i42":9,"i43":10,"i44":10,"i45":10,"i46":10,"i47":10,"i48":10,"i49":10,"i50":10,"i51":10,"i52":10,"i53":10,"i54":10,"i55":10,"i56":10,"i57":10,"i58":10,"i59":10,"i60":10,"i61":10,"i62":9,"i63":10,"i64":10,"i65":10,"i66":10,"i67":10,"i68":10,"i69":10,"i70":10,"i71":10,"i72":10,"i73":10,"i74":10,"i75":10,"i76":10,"i77":10,"i78":10,"i79":10,"i80":10,"i81":10,"i82":10,"i83":10,"i84":10,"i85":10,"i86":10,"i87":10,"i88":10,"i89":10,"i90":10,"i91":10,"i92":10,"i93":10,"i94":10,"i95":10,"i96":10,"i97":10,"i98":10,"i99":10,"i100":10,"i101":10,"i102":10,"i103":10,"i104":10,"i105":10,"i106":10,"i107":10,"i108":10,"i109" :10,"i110":10,"i111":10,"i112":10,"i113":10,"i114":10,"i115":10,"i116":10,"i117":10,"i118":10,"i119":10,"i120":9,"i121":10,"i122":10,"i123":10,"i124":10,"i125":10,"i126":10,"i127":10,"i128":10,"i129":10,"i130":10,"i131":10,"i132":10,"i133":10,"i134":9,"i135":10,"i136":10,"i137":10,"i138":10,"i139":10,"i140":10,"i141":10,"i142":10,"i143":10,"i144":10,"i145":10,"i146":10,"i147":10,"i148":10,"i149":10,"i150":10,"i151":10,"i152":10,"i153":10,"i154":10,"i155":10,"i156":10,"i157":10,"i158":10,"i159":10,"i160":10,"i161":10,"i162":10,"i163":10,"i164":10,"i165":10,"i166":10,"i167":10,"i168":10,"i169":10,"i170":10,"i171":10,"i172":9}; var tabs = {65535:["t0","All Methods"],1:["t1","Static Methods"],2:["t2","Instance Methods"],8:["t4","Concrete Methods"]}; var altColor = "altColor"; var rowColor = "rowColor"; @@ -128,7 +128,7 @@ var activeTableTab = "activeTableTab"; @InterfaceAudience.LimitedPrivate(value="Tools") -public class HMaster +public class HMaster extends HRegionServer implements MasterServices HMaster is the "master server" for HBase. An HBase cluster has one active @@ -402,50 +402,54 @@ implements regionServerTracker +private ReplicationBarrierCleaner +replicationBarrierCleaner + + private ReplicationPeerManager replicationPeerManager - + (package private) MemoryBoundedLogMessageBuffer rsFatals - + private ProcedureEvent? serverCrashProcessingEnabled - + private ServerManager serverManager - + (package private) boolean serviceStarted - + (package private) SnapshotManager snapshotManager - + private SnapshotQuotaObserverChore snapshotQuotaChore - + private SpaceQuotaSnapshotNotifier spaceQuotaSnapshotNotifier - + private SplitOrMergeTracker splitOrMergeTracker - + private long splitPlanCount - + private TableStateManager tableStateManager - + private
[22/51] [partial] hbase-site git commit: Published site at 31da4d0bce69b3a47066a5df675756087ce4dc60.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/a754d895/devapidocs/org/apache/hadoop/hbase/master/procedure/TruncateTableProcedure.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/master/procedure/TruncateTableProcedure.html b/devapidocs/org/apache/hadoop/hbase/master/procedure/TruncateTableProcedure.html index e5916be..4e0ec23 100644 --- a/devapidocs/org/apache/hadoop/hbase/master/procedure/TruncateTableProcedure.html +++ b/devapidocs/org/apache/hadoop/hbase/master/procedure/TruncateTableProcedure.html @@ -129,7 +129,7 @@ var activeTableTab = "activeTableTab"; @InterfaceAudience.Private -public class TruncateTableProcedure +public class TruncateTableProcedure extends AbstractStateMachineTableProcedureorg.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.TruncateTableState @@ -346,7 +346,7 @@ extends AbstractStateMachineTableProcedure -acquireLock, checkTableModifiable, getRegionDir, getUser, releaseLock, < a href="../../../../../../org/apache/hadoop/hbase/master/procedure/AbstractStateMachineTableProcedure.html#releaseSyncLatch--">releaseSyncLatch, setUser +acquireLock, checkTableModifiable, getRegionDir, getUser, preflightChecks, releaseLock, releaseSyncLatch, setUser @@ -389,7 +389,7 @@ extends LOG -private static finalorg.slf4j.Logger LOG +private static finalorg.slf4j.Logger LOG @@ -398,7 +398,7 @@ extends preserveSplits -privateboolean preserveSplits +privateboolean preserveSplits @@ -407,7 +407,7 @@ extends regions -privatehttps://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true; title="class or interface in java.util">ListRegionInfo regions +privatehttps://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true; title="class or interface in java.util">ListRegionInfo regions @@ -416,7 +416,7 @@ extends tableDescriptor -privateTableDescriptor tableDescriptor +privateTableDescriptor tableDescriptor @@ -425,7 +425,7 @@ extends tableName -privateTableName tableName +privateTableName tableName @@ -442,7 +442,7 @@ extends TruncateTableProcedure -publicTruncateTableProcedure() +publicTruncateTableProcedure() @@ -451,9 +451,14 @@ extends TruncateTableProcedure -publicTruncateTableProcedure(MasterProcedureEnvenv, +publicTruncateTableProcedure(MasterProcedureEnvenv, TableNametableName, - booleanpreserveSplits) + booleanpreserveSplits) + throws HBaseIOException + +Throws: +HBaseIOException + @@ -462,10 +467,15 @@ extends TruncateTableProcedure -publicTruncateTableProcedure(MasterProcedureEnvenv, +publicTruncateTableProcedure(MasterProcedureEnvenv, TableNametableName, booleanpreserveSplits, - ProcedurePrepareLatchlatch) + ProcedurePrepareLatchlatch) + throws HBaseIOException + +Throws: +HBaseIOException + @@ -482,7 +492,7 @@ extends executeFromState -protectedStateMachineProcedure.FlowexecuteFromState(MasterProcedureEnvenv, +protectedStateMachineProcedure.FlowexecuteFromState(MasterProcedureEnvenv, org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.TruncateTableStatestate) throws https://docs.oracle.com/javase/8/docs/api/java/lang/InterruptedException.html?is-external=true; title="class or interface in java.lang">InterruptedException Description copied from class:StateMachineProcedure @@ -505,7 +515,7 @@ extends rollbackState -protectedvoidrollbackState(MasterProcedureEnvenv, +protectedvoidrollbackState(MasterProcedureEnvenv, org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.TruncateTableStatestate) Description copied from class:StateMachineProcedure called to perform the rollback of the specified state @@ -522,7 +532,7 @@ extends completionCleanup -protectedvoidcompletionCleanup(MasterProcedureEnvenv) +protectedvoidcompletionCleanup(MasterProcedureEnvenv) Description copied from class:Procedure Called when the procedure is marked as completed (success or rollback). The procedure implementor may use this method to cleanup in-memory states. @@ -540,7 +550,7 @@ extends isRollbackSupported -protectedbooleanisRollbackSupported(org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.TruncateTableStatestate) +protectedbooleanisRollbackSupported(org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.TruncateTableStatestate) Description copied from class:StateMachineProcedure Used by the default implementation of abort() to know if the current state can be aborted and rollback
[48/51] [partial] hbase-site git commit: Published site at 31da4d0bce69b3a47066a5df675756087ce4dc60.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/a754d895/book.html -- diff --git a/book.html b/book.html index f1f915d..d7b547c 100644 --- a/book.html +++ b/book.html @@ -37286,7 +37286,7 @@ The server will return cellblocks compressed using this same compressor as long Version 3.0.0-SNAPSHOT -Last updated 2018-03-13 14:29:49 UTC +Last updated 2018-03-15 14:29:45 UTC http://git-wip-us.apache.org/repos/asf/hbase-site/blob/a754d895/bulk-loads.html -- diff --git a/bulk-loads.html b/bulk-loads.html index da63321..e848ac1 100644 --- a/bulk-loads.html +++ b/bulk-loads.html @@ -7,7 +7,7 @@ - + Apache HBase Bulk Loads in Apache HBase (TM) @@ -299,7 +299,7 @@ under the License. --> https://www.apache.org/;>The Apache Software Foundation. All rights reserved. - Last Published: 2018-03-13 + Last Published: 2018-03-15
[03/51] [partial] hbase-site git commit: Published site at 31da4d0bce69b3a47066a5df675756087ce4dc60.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/a754d895/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 8b1ac9b..dcd9fce 100644 --- a/devapidocs/org/apache/hadoop/hbase/regionserver/package-tree.html +++ b/devapidocs/org/apache/hadoop/hbase/regionserver/package-tree.html @@ -704,20 +704,20 @@ java.lang.https://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.https://docs.oracle.com/javase/8/docs/api/java/lang/Comparable.html?is-external=true; title="class or interface in java.lang">ComparableT, java.io.https://docs.oracle.com/javase/8/docs/api/java/io/Serializable.html?is-external=true; title="class or interface in java.io">Serializable) -org.apache.hadoop.hbase.regionserver.CompactingMemStore.IndexType -org.apache.hadoop.hbase.regionserver.ScanType -org.apache.hadoop.hbase.regionserver.ChunkCreator.ChunkType -org.apache.hadoop.hbase.regionserver.ScannerContext.LimitScope -org.apache.hadoop.hbase.regionserver.FlushType +org.apache.hadoop.hbase.regionserver.BloomType org.apache.hadoop.hbase.regionserver.HRegion.FlushResult.Result -org.apache.hadoop.hbase.regionserver.MemStoreCompactionStrategy.Action org.apache.hadoop.hbase.regionserver.SplitLogWorker.TaskExecutor.Status -org.apache.hadoop.hbase.regionserver.Region.Operation +org.apache.hadoop.hbase.regionserver.ChunkCreator.ChunkType org.apache.hadoop.hbase.regionserver.DefaultHeapMemoryTuner.StepDirection -org.apache.hadoop.hbase.regionserver.TimeRangeTracker.Type +org.apache.hadoop.hbase.regionserver.CompactingMemStore.IndexType org.apache.hadoop.hbase.regionserver.MetricsRegionServerSourceFactoryImpl.FactoryStorage -org.apache.hadoop.hbase.regionserver.BloomType +org.apache.hadoop.hbase.regionserver.ScanType org.apache.hadoop.hbase.regionserver.ScannerContext.NextState +org.apache.hadoop.hbase.regionserver.TimeRangeTracker.Type +org.apache.hadoop.hbase.regionserver.FlushType +org.apache.hadoop.hbase.regionserver.MemStoreCompactionStrategy.Action +org.apache.hadoop.hbase.regionserver.Region.Operation +org.apache.hadoop.hbase.regionserver.ScannerContext.LimitScope http://git-wip-us.apache.org/repos/asf/hbase-site/blob/a754d895/devapidocs/org/apache/hadoop/hbase/regionserver/package-use.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/regionserver/package-use.html b/devapidocs/org/apache/hadoop/hbase/regionserver/package-use.html index a62f000..7208218 100644 --- a/devapidocs/org/apache/hadoop/hbase/regionserver/package-use.html +++ b/devapidocs/org/apache/hadoop/hbase/regionserver/package-use.html @@ -2116,6 +2116,11 @@ Input/OutputFormats, a table indexing MapReduce job, and utility methods. +Region +Region is a subset of HRegion with operations required for the Coprocessors. + + + RegionServerServices A curated subset of services provided by HRegionServer. http://git-wip-us.apache.org/repos/asf/hbase-site/blob/a754d895/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 23060c2..2731576 100644 --- a/devapidocs/org/apache/hadoop/hbase/regionserver/querymatcher/package-tree.html +++ b/devapidocs/org/apache/hadoop/hbase/regionserver/querymatcher/package-tree.html @@ -130,9 +130,9 @@ java.lang.https://docs.oracle.com/javase/8/docs/api/java/lang/Enum.html?is-external=true; title="class or interface in java.lang">EnumE (implements java.lang.https://docs.oracle.com/javase/8/docs/api/java/lang/Comparable.html?is-external=true; title="class or interface in java.lang">ComparableT, java.io.https://docs.oracle.com/javase/8/docs/api/java/io/Serializable.html?is-external=true; title="class or interface in java.io">Serializable) -org.apache.hadoop.hbase.regionserver.querymatcher.StripeCompactionScanQueryMatcher.DropDeletesInOutput -org.apache.hadoop.hbase.regionserver.querymatcher.DeleteTracker.DeleteResult org.apache.hadoop.hbase.regionserver.querymatcher.ScanQueryMatcher.MatchCode +org.apache.hadoop.hbase.regionserver.querymatcher.DeleteTracker.DeleteResult +org.apache.hadoop.hbase.regionserver.querymatcher.StripeCompactionScanQueryMatcher.DropDeletesInOutput http://git-wip-us.apache.org/repos/asf/hbase-site/blob/a754d895/devapidocs/org/apache/hadoop/hbase/regionserver/throttle/PressureAwareThroughputController.ActiveOperation.html -- diff --git
[37/51] [partial] hbase-site git commit: Published site at 31da4d0bce69b3a47066a5df675756087ce4dc60.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/a754d895/devapidocs/org/apache/hadoop/hbase/constraint/Constraints.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/constraint/Constraints.html b/devapidocs/org/apache/hadoop/hbase/constraint/Constraints.html index 0cd2e41..5e884ed 100644 --- a/devapidocs/org/apache/hadoop/hbase/constraint/Constraints.html +++ b/devapidocs/org/apache/hadoop/hbase/constraint/Constraints.html @@ -110,7 +110,7 @@ var activeTableTab = "activeTableTab"; @InterfaceAudience.Private -public final class Constraints +public final class Constraints extends https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true; title="class or interface in java.lang">Object Utilities for adding/removing constraints from a table. @@ -409,7 +409,7 @@ extends https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html DEFAULT_PRIORITY -private static finalint DEFAULT_PRIORITY +private static finalint DEFAULT_PRIORITY See Also: Constant Field Values @@ -422,7 +422,7 @@ extends https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html LOG -private static finalorg.slf4j.Logger LOG +private static finalorg.slf4j.Logger LOG @@ -431,7 +431,7 @@ extends https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html CONSTRAINT_HTD_KEY_PREFIX -private static finalhttps://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String CONSTRAINT_HTD_KEY_PREFIX +private static finalhttps://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String CONSTRAINT_HTD_KEY_PREFIX See Also: Constant Field Values @@ -444,7 +444,7 @@ extends https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html CONSTRAINT_HTD_ATTR_KEY_PATTERN -private static finalhttps://docs.oracle.com/javase/8/docs/api/java/util/regex/Pattern.html?is-external=true; title="class or interface in java.util.regex">Pattern CONSTRAINT_HTD_ATTR_KEY_PATTERN +private static finalhttps://docs.oracle.com/javase/8/docs/api/java/util/regex/Pattern.html?is-external=true; title="class or interface in java.util.regex">Pattern CONSTRAINT_HTD_ATTR_KEY_PATTERN @@ -453,7 +453,7 @@ extends https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html ENABLED_KEY -private static finalhttps://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String ENABLED_KEY +private static finalhttps://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String ENABLED_KEY See Also: Constant Field Values @@ -466,7 +466,7 @@ extends https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html PRIORITY_KEY -private static finalhttps://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String PRIORITY_KEY +private static finalhttps://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String PRIORITY_KEY See Also: Constant Field Values @@ -479,7 +479,7 @@ extends https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html MIN_PRIORITY -private static finallong MIN_PRIORITY +private static finallong MIN_PRIORITY See Also: Constant Field Values @@ -492,7 +492,7 @@ extends https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html UNSET_PRIORITY -private static finallong UNSET_PRIORITY +private static finallong UNSET_PRIORITY See Also: Constant Field Values @@ -505,7 +505,7 @@ extends https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html COUNTER_KEY -private statichttps://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String COUNTER_KEY +private statichttps://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String COUNTER_KEY @@ -514,7 +514,7 @@ extends https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html constraintComparator -private static finalhttps://docs.oracle.com/javase/8/docs/api/java/util/Comparator.html?is-external=true; title="class or interface in java.util">ComparatorConstraint constraintComparator +private static finalhttps://docs.oracle.com/javase/8/docs/api/java/util/Comparator.html?is-external=true; title="class or interface in java.util">ComparatorConstraint constraintComparator @@ -531,7 +531,7 @@ extends https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html Constraints -privateConstraints() +privateConstraints() @@ -548,7 +548,7 @@ extends https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html enable -public staticvoidenable(HTableDescriptordesc) +public
[45/51] [partial] hbase-site git commit: Published site at 31da4d0bce69b3a47066a5df675756087ce4dc60.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/a754d895/devapidocs/index-all.html -- diff --git a/devapidocs/index-all.html b/devapidocs/index-all.html index 23cca53..d83e763 100644 --- a/devapidocs/index-all.html +++ b/devapidocs/index-all.html @@ -1787,6 +1787,8 @@ Add new hfile references to the queue. +addHFileRefs(String, ListPairPath, Path) - Method in class org.apache.hadoop.hbase.replication.TableReplicationQueueStorage + addHFileRefs(String, ListPairPath, Path) - Method in class org.apache.hadoop.hbase.replication.ZKReplicationQueueStorage addHFileRefsToQueue(TableName, byte[], ListPairPath, Path) - Method in class org.apache.hadoop.hbase.replication.regionserver.Replication @@ -2071,6 +2073,8 @@ Add a replication peer. +addPeer(String, ReplicationPeerConfig, boolean) - Method in class org.apache.hadoop.hbase.replication.TableReplicationPeerStorage + addPeer(String, ReplicationPeerConfig, boolean) - Method in class org.apache.hadoop.hbase.replication.ZKReplicationPeerStorage AddPeerProcedure - Class in org.apache.hadoop.hbase.master.replication @@ -2085,6 +2089,8 @@ Add a peer to hfile reference queue if peer does not exist. +addPeerToHFileRefs(String) - Method in class org.apache.hadoop.hbase.replication.TableReplicationQueueStorage + addPeerToHFileRefs(String) - Method in class org.apache.hadoop.hbase.replication.ZKReplicationQueueStorage addPrimaryAssignment(RegionInfo, ServerName) - Method in class org.apache.hadoop.hbase.master.SnapshotOfRegionAssignmentFromMeta @@ -2614,6 +2620,8 @@ Add a new WAL file to the given queue for a given regionserver. +addWAL(ServerName, String, String) - Method in class org.apache.hadoop.hbase.replication.TableReplicationQueueStorage + addWAL(ServerName, String, String) - Method in class org.apache.hadoop.hbase.replication.ZKReplicationQueueStorage addWALActionsListener(WALActionsListener) - Method in class org.apache.hadoop.hbase.wal.AbstractFSWALProvider @@ -8905,6 +8913,8 @@ cancelChore(ScheduledChore, boolean) - Method in class org.apache.hadoop.hbase.ChoreService +cancelChore(ScheduledChore) - Method in class org.apache.hadoop.hbase.master.HMaster + cancelChore(ScheduledChore) - Method in interface org.apache.hadoop.hbase.ScheduledChore.ChoreServicer Cancel any ongoing schedules that this chore has with the implementer of this interface. @@ -9660,6 +9670,8 @@ cellsSizeCompactedToMob - Variable in class org.apache.hadoop.hbase.regionserver.MetricsRegionServerWrapperImpl +cellTimestamp - Variable in class org.apache.hadoop.hbase.replication.TableReplicationQueueStorage.WALCell + cellToBackupInfo(Cell) - Method in class org.apache.hadoop.hbase.backup.impl.BackupSystemTable Converts cell to backup info instance. @@ -10669,6 +10681,16 @@ checkPermission(String) - Method in class org.apache.hadoop.hbase.rsgroup.RSGroupAdminEndpoint +checkPermissions(HBaseProtos.ProcedureDescription, AccessChecker, User) - Method in class org.apache.hadoop.hbase.backup.master.LogRollMasterProcedureManager + +checkPermissions(HBaseProtos.ProcedureDescription, AccessChecker, User) - Method in class org.apache.hadoop.hbase.master.snapshot.SnapshotManager + +checkPermissions(HBaseProtos.ProcedureDescription, AccessChecker, User) - Method in class org.apache.hadoop.hbase.procedure.flush.MasterFlushTableProcedureManager + +checkPermissions(HBaseProtos.ProcedureDescription, AccessChecker, User) - Method in class org.apache.hadoop.hbase.procedure.MasterProcedureManager + +Check for required permissions before executing the procedure. + checkPermissions(RpcController, AccessControlProtos.CheckPermissionsRequest, RpcCallbackAccessControlProtos.CheckPermissionsResponse) - Method in class org.apache.hadoop.hbase.security.access.AccessController checkpoint - Variable in class org.apache.hadoop.hbase.mapreduce.SampleUploader.Uploader @@ -11065,6 +11087,8 @@ chore() - Method in class org.apache.hadoop.hbase.master.cleaner.CleanerChore +chore() - Method in class org.apache.hadoop.hbase.master.cleaner.ReplicationBarrierCleaner + chore() - Method in class org.apache.hadoop.hbase.master.ClusterStatusPublisher chore() - Method in class org.apache.hadoop.hbase.master.ExpiredMobFileCleanerChore @@ -11272,6 +11296,8 @@ Change ownership for the queue identified by queueId and belongs to a dead region server. +claimQueue(ServerName, String, ServerName) - Method in class org.apache.hadoop.hbase.replication.TableReplicationQueueStorage + claimQueue(ServerName, String, ServerName) - Method in class org.apache.hadoop.hbase.replication.ZKReplicationQueueStorage CLASS - Static variable in class org.apache.hadoop.hbase.util.CommonFSUtils.StreamCapabilities @@ -16106,6 +16132,8 @@ conf - Variable in class org.apache.hadoop.hbase.replication.ReplicationPeers +conf - Variable in class
[16/51] [partial] hbase-site git commit: Published site at 31da4d0bce69b3a47066a5df675756087ce4dc60.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/a754d895/devapidocs/org/apache/hadoop/hbase/regionserver/HRegion.MutationBatchOperation.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/regionserver/HRegion.MutationBatchOperation.html b/devapidocs/org/apache/hadoop/hbase/regionserver/HRegion.MutationBatchOperation.html index a190a33..82da4d7 100644 --- a/devapidocs/org/apache/hadoop/hbase/regionserver/HRegion.MutationBatchOperation.html +++ b/devapidocs/org/apache/hadoop/hbase/regionserver/HRegion.MutationBatchOperation.html @@ -118,7 +118,7 @@ var activeTableTab = "activeTableTab"; -static class HRegion.MutationBatchOperation +static class HRegion.MutationBatchOperation extends HRegion.BatchOperationMutation Batch of mutation operations. Base class is shared with HRegion.ReplayBatchOperation as most of the logic is same. @@ -342,7 +342,7 @@ extends nonceGroup -privatelong nonceGroup +privatelong nonceGroup @@ -351,7 +351,7 @@ extends nonce -privatelong nonce +privatelong nonce @@ -368,7 +368,7 @@ extends MutationBatchOperation -publicMutationBatchOperation(HRegionregion, +publicMutationBatchOperation(HRegionregion, Mutation[]operations, booleanatomic, longnonceGroup, @@ -389,7 +389,7 @@ extends getMutation -publicMutationgetMutation(intindex) +publicMutationgetMutation(intindex) Specified by: getMutationin classHRegion.BatchOperationMutation @@ -402,7 +402,7 @@ extends getNonceGroup -publiclonggetNonceGroup(intindex) +publiclonggetNonceGroup(intindex) Specified by: getNonceGroupin classHRegion.BatchOperationMutation @@ -415,7 +415,7 @@ extends getNonce -publiclonggetNonce(intindex) +publiclonggetNonce(intindex) Specified by: getNoncein classHRegion.BatchOperationMutation @@ -428,7 +428,7 @@ extends getMutationsForCoprocs -publicMutation[]getMutationsForCoprocs() +publicMutation[]getMutationsForCoprocs() Description copied from class:HRegion.BatchOperation This method is potentially expensive and useful mostly for non-replay CP path. @@ -443,7 +443,7 @@ extends isInReplay -publicbooleanisInReplay() +publicbooleanisInReplay() Specified by: isInReplayin classHRegion.BatchOperationMutation @@ -456,7 +456,7 @@ extends getOrigLogSeqNum -publiclonggetOrigLogSeqNum() +publiclonggetOrigLogSeqNum() Specified by: getOrigLogSeqNumin classHRegion.BatchOperationMutation @@ -469,7 +469,7 @@ extends startRegionOperation -publicvoidstartRegionOperation() +publicvoidstartRegionOperation() throws https://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true; title="class or interface in java.io">IOException Specified by: @@ -485,7 +485,7 @@ extends closeRegionOperation -publicvoidcloseRegionOperation() +publicvoidcloseRegionOperation() throws https://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true; title="class or interface in java.io">IOException Specified by: @@ -501,7 +501,7 @@ extends checkAndPreparePut -publicvoidcheckAndPreparePut(Putp) +publicvoidcheckAndPreparePut(Putp) throws https://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true; title="class or interface in java.io">IOException Description copied from class:HRegion.BatchOperation Implement any Put request specific check and prepare logic here. Please refer to @@ -520,7 +520,7 @@ extends checkAndPrepare -publicvoidcheckAndPrepare() +publicvoidcheckAndPrepare() throws https://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true; title="class or interface in java.io">IOException Description copied from class:HRegion.BatchOperation Validates each mutation and prepares a batch for write. If necessary (non-replay case), runs @@ -542,7 +542,7 @@ extends prepareMiniBatchOperations -publicvoidprepareMiniBatchOperations(MiniBatchOperationInProgressMutationminiBatchOp, +publicvoidprepareMiniBatchOperations(MiniBatchOperationInProgressMutationminiBatchOp, longtimestamp, https://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true; title="class or interface in java.util">ListRegion.RowLockacquiredRowLocks) throws https://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true; title="class or interface in java.io">IOException @@ -563,7 +563,7 @@ extends buildWALEdits -publichttps://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true; title="class or interface in java.util">ListPairNonceKey,WALEditbuildWALEdits(MiniBatchOperationInProgressMutation ;miniBatchOp)
[05/51] [partial] hbase-site git commit: Published site at 31da4d0bce69b3a47066a5df675756087ce4dc60.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/a754d895/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 0ca6e81..bf375f2 100644 --- a/devapidocs/org/apache/hadoop/hbase/regionserver/RegionCoprocessorHost.html +++ b/devapidocs/org/apache/hadoop/hbase/regionserver/RegionCoprocessorHost.html @@ -115,7 +115,7 @@ var activeTableTab = "activeTableTab"; @InterfaceAudience.Private -public class RegionCoprocessorHost +public class RegionCoprocessorHost extends CoprocessorHostRegionCoprocessor,RegionCoprocessorEnvironment Implements the coprocessor environment and runtime support for coprocessors loaded within a Region. @@ -796,7 +796,7 @@ extends LOG -private static finalorg.slf4j.Logger LOG +private static finalorg.slf4j.Logger LOG @@ -805,7 +805,7 @@ extends SHARED_DATA_MAP -private static finalorg.apache.commons.collections4.map.ReferenceMaphttps://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String,https://docs.oracle.com/javase/8/docs/api/java/util/concurrent/ConcurrentMap.html?is-external=true; title="class or interface in java.util.concurrent">ConcurrentMaphttps://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String,https://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.ReferenceMaphttps://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String,https://docs.oracle.com/javase/8/docs/api/java/util/concurrent/ConcurrentMap.html?is-external=true; title="class or interface in java.util.concurrent">ConcurrentMaphttps://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String,https://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 @@ -814,7 +814,7 @@ extends hasCustomPostScannerFilterRow -private finalboolean hasCustomPostScannerFilterRow +private finalboolean hasCustomPostScannerFilterRow @@ -823,7 +823,7 @@ extends rsServices -RegionServerServices rsServices +RegionServerServices rsServices The region server services @@ -833,7 +833,7 @@ extends region -HRegion region +HRegion region The region @@ -843,7 +843,7 @@ extends regionObserverGetter -privateCoprocessorHost.ObserverGetterRegionCoprocessor,RegionObserver regionObserverGetter +privateCoprocessorHost.ObserverGetterRegionCoprocessor,RegionObserver regionObserverGetter @@ -852,7 +852,7 @@ extends endpointObserverGetter -privateCoprocessorHost.ObserverGetterRegionCoprocessor,EndpointObserver endpointObserverGetter +privateCoprocessorHost.ObserverGetterRegionCoprocessor,EndpointObserver endpointObserverGetter @@ -869,7 +869,7 @@ extends RegionCoprocessorHost -publicRegionCoprocessorHost(HRegionregion, +publicRegionCoprocessorHost(HRegionregion, RegionServerServicesrsServices, org.apache.hadoop.conf.Configurationconf) Constructor @@ -895,7 +895,7 @@ extends getTableCoprocessorAttrsFromSchema -statichttps://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, +statichttps://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) @@ -905,7 +905,7 @@ extends testTableCoprocessorAttrs -public staticvoidtestTableCoprocessorAttrs(org.apache.hadoop.conf.Configurationconf, +public staticvoidtestTableCoprocessorAttrs(org.apache.hadoop.conf.Configurationconf, TableDescriptorhtd) throws https://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. Will @@ -925,7 +925,7 @@ extends loadTableCoprocessors -voidloadTableCoprocessors(org.apache.hadoop.conf.Configurationconf)
[10/51] [partial] hbase-site git commit: Published site at 31da4d0bce69b3a47066a5df675756087ce4dc60.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/a754d895/devapidocs/org/apache/hadoop/hbase/regionserver/HStore.StoreFlusherImpl.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/regionserver/HStore.StoreFlusherImpl.html b/devapidocs/org/apache/hadoop/hbase/regionserver/HStore.StoreFlusherImpl.html index 286bad8..4c4a4d7 100644 --- a/devapidocs/org/apache/hadoop/hbase/regionserver/HStore.StoreFlusherImpl.html +++ b/devapidocs/org/apache/hadoop/hbase/regionserver/HStore.StoreFlusherImpl.html @@ -117,7 +117,7 @@ var activeTableTab = "activeTableTab"; -private final class HStore.StoreFlusherImpl +private final class HStore.StoreFlusherImpl extends https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true; title="class or interface in java.lang">Object implements StoreFlushContext @@ -279,7 +279,7 @@ implements tracker -private finalFlushLifeCycleTracker tracker +private finalFlushLifeCycleTracker tracker @@ -288,7 +288,7 @@ implements cacheFlushSeqNum -private finallong cacheFlushSeqNum +private finallong cacheFlushSeqNum @@ -297,7 +297,7 @@ implements snapshot -privateMemStoreSnapshot snapshot +privateMemStoreSnapshot snapshot @@ -306,7 +306,7 @@ implements tempFiles -privatehttps://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true; title="class or interface in java.util">Listorg.apache.hadoop.fs.Path tempFiles +privatehttps://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true; title="class or interface in java.util">Listorg.apache.hadoop.fs.Path tempFiles @@ -315,7 +315,7 @@ implements committedFiles -privatehttps://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true; title="class or interface in java.util">Listorg.apache.hadoop.fs.Path committedFiles +privatehttps://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true; title="class or interface in java.util">Listorg.apache.hadoop.fs.Path committedFiles @@ -324,7 +324,7 @@ implements cacheFlushCount -privatelong cacheFlushCount +privatelong cacheFlushCount @@ -333,7 +333,7 @@ implements cacheFlushSize -privatelong cacheFlushSize +privatelong cacheFlushSize @@ -342,7 +342,7 @@ implements outputFileSize -privatelong outputFileSize +privatelong outputFileSize @@ -359,7 +359,7 @@ implements StoreFlusherImpl -privateStoreFlusherImpl(longcacheFlushSeqNum, +privateStoreFlusherImpl(longcacheFlushSeqNum, FlushLifeCycleTrackertracker) @@ -377,7 +377,7 @@ implements prepare -publicMemStoreSizeprepare() +publicMemStoreSizeprepare() This is not thread safe. The caller should have a lock on the region or the store. If necessary, the lock can be added with the patch provided in HBASE-10087 @@ -394,7 +394,7 @@ implements flushCache -publicvoidflushCache(MonitoredTaskstatus) +publicvoidflushCache(MonitoredTaskstatus) throws https://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true; title="class or interface in java.io">IOException Description copied from interface:StoreFlushContext Flush the cache (create the new store file) @@ -415,7 +415,7 @@ implements commit -publicbooleancommit(MonitoredTaskstatus) +publicbooleancommit(MonitoredTaskstatus) throws https://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true; title="class or interface in java.io">IOException Description copied from interface:StoreFlushContext Commit the flush - add the store file to the store and clear the @@ -439,7 +439,7 @@ implements getOutputFileSize -publiclonggetOutputFileSize() +publiclonggetOutputFileSize() Specified by: getOutputFileSizein interfaceStoreFlushContext @@ -454,7 +454,7 @@ implements getCommittedFiles -publichttps://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true; title="class or interface in java.util">Listorg.apache.hadoop.fs.PathgetCommittedFiles() +publichttps://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true; title="class or interface in java.util">Listorg.apache.hadoop.fs.PathgetCommittedFiles() Description copied from interface:StoreFlushContext Returns the newly committed files from the flush. Called only if commit returns true @@ -471,7 +471,7 @@ implements replayFlush -publicvoidreplayFlush(https://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true; title="class or interface in java.util">Listhttps://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">StringfileNames, +publicvoidreplayFlush(https://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true; title="class or interface in java.util">Listhttps://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true;
[08/51] [partial] hbase-site git commit: Published site at 31da4d0bce69b3a47066a5df675756087ce4dc60.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/a754d895/devapidocs/org/apache/hadoop/hbase/regionserver/RSRpcServices.LogDelegate.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/regionserver/RSRpcServices.LogDelegate.html b/devapidocs/org/apache/hadoop/hbase/regionserver/RSRpcServices.LogDelegate.html index 24f6fb2..4729c8d 100644 --- a/devapidocs/org/apache/hadoop/hbase/regionserver/RSRpcServices.LogDelegate.html +++ b/devapidocs/org/apache/hadoop/hbase/regionserver/RSRpcServices.LogDelegate.html @@ -105,7 +105,7 @@ var activeTableTab = "activeTableTab"; -static interface RSRpcServices.LogDelegate +static interface RSRpcServices.LogDelegate @@ -151,7 +151,7 @@ var activeTableTab = "activeTableTab"; logBatchWarning -voidlogBatchWarning(https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">StringfirstRegionName, +voidlogBatchWarning(https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">StringfirstRegionName, intsum, introwSizeWarnThreshold) http://git-wip-us.apache.org/repos/asf/hbase-site/blob/a754d895/devapidocs/org/apache/hadoop/hbase/regionserver/RSRpcServices.RegionScannerCloseCallBack.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/regionserver/RSRpcServices.RegionScannerCloseCallBack.html b/devapidocs/org/apache/hadoop/hbase/regionserver/RSRpcServices.RegionScannerCloseCallBack.html index 7874951..82d92da 100644 --- a/devapidocs/org/apache/hadoop/hbase/regionserver/RSRpcServices.RegionScannerCloseCallBack.html +++ b/devapidocs/org/apache/hadoop/hbase/regionserver/RSRpcServices.RegionScannerCloseCallBack.html @@ -117,7 +117,7 @@ var activeTableTab = "activeTableTab"; -private static final class RSRpcServices.RegionScannerCloseCallBack +private static final class RSRpcServices.RegionScannerCloseCallBack extends https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true; title="class or interface in java.lang">Object implements RpcCallback An Rpc callback for closing a RegionScanner. @@ -209,7 +209,7 @@ implements scanner -private finalRegionScanner scanner +private finalRegionScanner scanner @@ -226,7 +226,7 @@ implements RegionScannerCloseCallBack -publicRegionScannerCloseCallBack(RegionScannerscanner) +publicRegionScannerCloseCallBack(RegionScannerscanner) @@ -243,7 +243,7 @@ implements run -publicvoidrun() +publicvoidrun() throws https://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true; title="class or interface in java.io">IOException Description copied from interface:RpcCallback Called at the end of an Rpc Call RpcCallContext http://git-wip-us.apache.org/repos/asf/hbase-site/blob/a754d895/devapidocs/org/apache/hadoop/hbase/regionserver/RSRpcServices.RegionScannerHolder.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/regionserver/RSRpcServices.RegionScannerHolder.html b/devapidocs/org/apache/hadoop/hbase/regionserver/RSRpcServices.RegionScannerHolder.html index 89d371b..1a7af7a 100644 --- a/devapidocs/org/apache/hadoop/hbase/regionserver/RSRpcServices.RegionScannerHolder.html +++ b/devapidocs/org/apache/hadoop/hbase/regionserver/RSRpcServices.RegionScannerHolder.html @@ -113,7 +113,7 @@ var activeTableTab = "activeTableTab"; -private static final class RSRpcServices.RegionScannerHolder +private static final class RSRpcServices.RegionScannerHolder extends https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true; title="class or interface in java.lang">Object Holder class which holds the RegionScanner, nextCallSeq and RpcCallbacks together. @@ -239,7 +239,7 @@ extends https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html nextCallSeq -private finalhttps://docs.oracle.com/javase/8/docs/api/java/util/concurrent/atomic/AtomicLong.html?is-external=true; title="class or interface in java.util.concurrent.atomic">AtomicLong nextCallSeq +private finalhttps://docs.oracle.com/javase/8/docs/api/java/util/concurrent/atomic/AtomicLong.html?is-external=true; title="class or interface in java.util.concurrent.atomic">AtomicLong nextCallSeq @@ -248,7 +248,7 @@ extends https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html scannerName -private finalhttps://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String scannerName +private finalhttps://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String scannerName @@ -257,7 +257,7 @@ extends
[07/51] [partial] hbase-site git commit: Published site at 31da4d0bce69b3a47066a5df675756087ce4dc60.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/a754d895/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 ec5a869..84f7079 100644 --- a/devapidocs/org/apache/hadoop/hbase/regionserver/RSRpcServices.html +++ b/devapidocs/org/apache/hadoop/hbase/regionserver/RSRpcServices.html @@ -118,7 +118,7 @@ var activeTableTab = "activeTableTab"; @InterfaceAudience.Private -public class RSRpcServices +public class RSRpcServices extends https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true; title="class or interface in java.lang">Object implements HBaseRPCErrorHandler, org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.AdminService.BlockingInterface, org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ClientService.BlockingInterface, PriorityFunction, ConfigurationObserver Implements the regionserver RPC services. @@ -191,7 +191,7 @@ implements Field and Description -private AccessChecker +protected AccessChecker accessChecker @@ -959,7 +959,7 @@ implements LOG -protected static finalorg.slf4j.Logger LOG +protected static finalorg.slf4j.Logger LOG @@ -968,7 +968,7 @@ implements REGION_SERVER_RPC_SCHEDULER_FACTORY_CLASS -public static finalhttps://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String REGION_SERVER_RPC_SCHEDULER_FACTORY_CLASS +public static finalhttps://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String REGION_SERVER_RPC_SCHEDULER_FACTORY_CLASS RPC scheduler to use for the region server. See Also: @@ -982,7 +982,7 @@ implements REGION_SERVER_RPC_MINIMUM_SCAN_TIME_LIMIT_DELTA -private static finalhttps://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String REGION_SERVER_RPC_MINIMUM_SCAN_TIME_LIMIT_DELTA +private static finalhttps://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String REGION_SERVER_RPC_MINIMUM_SCAN_TIME_LIMIT_DELTA Minimum allowable time limit delta (in milliseconds) that can be enforced during scans. This configuration exists to prevent the scenario where a time limit is specified to be so restrictive that the time limit is reached immediately (before any cells are scanned). @@ -998,7 +998,7 @@ implements DEFAULT_REGION_SERVER_RPC_MINIMUM_SCAN_TIME_LIMIT_DELTA -private static finallong DEFAULT_REGION_SERVER_RPC_MINIMUM_SCAN_TIME_LIMIT_DELTA +private static finallong DEFAULT_REGION_SERVER_RPC_MINIMUM_SCAN_TIME_LIMIT_DELTA Default value of REGION_SERVER_RPC_MINIMUM_SCAN_TIME_LIMIT_DELTA See Also: @@ -1012,7 +1012,7 @@ implements BATCH_ROWS_THRESHOLD_NAME -static finalhttps://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String BATCH_ROWS_THRESHOLD_NAME +static finalhttps://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String BATCH_ROWS_THRESHOLD_NAME Number of rows in a batch operation above which a warning will be logged. See Also: @@ -1026,7 +1026,7 @@ implements BATCH_ROWS_THRESHOLD_DEFAULT -static finalint BATCH_ROWS_THRESHOLD_DEFAULT +static finalint BATCH_ROWS_THRESHOLD_DEFAULT Default value of BATCH_ROWS_THRESHOLD_NAME See Also: @@ -1040,7 +1040,7 @@ implements RESERVOIR_ENABLED_KEY -protected static finalhttps://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String RESERVOIR_ENABLED_KEY +protected static finalhttps://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String RESERVOIR_ENABLED_KEY See Also: Constant Field Values @@ -1053,7 +1053,7 @@ implements requestCount -finalhttps://docs.oracle.com/javase/8/docs/api/java/util/concurrent/atomic/LongAdder.html?is-external=true; title="class or interface in java.util.concurrent.atomic">LongAdder requestCount +finalhttps://docs.oracle.com/javase/8/docs/api/java/util/concurrent/atomic/LongAdder.html?is-external=true; title="class or interface in java.util.concurrent.atomic">LongAdder requestCount @@ -1062,7 +1062,7 @@ implements rpcGetRequestCount -finalhttps://docs.oracle.com/javase/8/docs/api/java/util/concurrent/atomic/LongAdder.html?is-external=true; title="class or interface in java.util.concurrent.atomic">LongAdder rpcGetRequestCount +finalhttps://docs.oracle.com/javase/8/docs/api/java/util/concurrent/atomic/LongAdder.html?is-external=true; title="class or interface in
[13/51] [partial] hbase-site git commit: Published site at 31da4d0bce69b3a47066a5df675756087ce4dc60.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/a754d895/devapidocs/org/apache/hadoop/hbase/regionserver/HRegion.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/regionserver/HRegion.html b/devapidocs/org/apache/hadoop/hbase/regionserver/HRegion.html index 21ec0e6..b022e4a 100644 --- a/devapidocs/org/apache/hadoop/hbase/regionserver/HRegion.html +++ b/devapidocs/org/apache/hadoop/hbase/regionserver/HRegion.html @@ -114,7 +114,7 @@ var activeTableTab = "activeTableTab"; @InterfaceAudience.Private -public class HRegion +public class HRegion extends https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true; title="class or interface in java.lang">Object implements HeapSize, PropagatingConfigurationObserver, Region Regions store data for a certain region of a table. It stores all columns @@ -597,36 +597,40 @@ implements splitRequest +private StoreHotnessProtector +storeHotnessProtector + + protected https://docs.oracle.com/javase/8/docs/api/java/util/Map.html?is-external=true; title="class or interface in java.util">Mapbyte[],HStore stores - + static int SYSTEM_CACHE_FLUSH_INTERVAL Default interval for System tables memstore flush - + private https://docs.oracle.com/javase/8/docs/api/java/lang/Long.html?is-external=true; title="class or interface in java.lang">Long timeoutForWriteLock - + (package private) long timestampSlop - + private https://docs.oracle.com/javase/8/docs/api/java/util/concurrent/locks/ReentrantReadWriteLock.html?is-external=true; title="class or interface in java.util.concurrent.locks">ReentrantReadWriteLock updatesLock - + private WAL wal - + (package private) https://docs.oracle.com/javase/8/docs/api/java/util/concurrent/atomic/LongAdder.html?is-external=true; title="class or interface in java.util.concurrent.atomic">LongAdder writeRequestsCount - + (package private) HRegion.WriteState writestate @@ -2294,7 +2298,7 @@ implements LOG -private static finalorg.slf4j.Logger LOG +private static finalorg.slf4j.Logger LOG @@ -2303,7 +2307,7 @@ implements LOAD_CFS_ON_DEMAND_CONFIG_KEY -public static finalhttps://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String LOAD_CFS_ON_DEMAND_CONFIG_KEY +public static finalhttps://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String LOAD_CFS_ON_DEMAND_CONFIG_KEY See Also: Constant Field Values @@ -2316,7 +2320,7 @@ implements HBASE_MAX_CELL_SIZE_KEY -public static finalhttps://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String HBASE_MAX_CELL_SIZE_KEY +public static finalhttps://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String HBASE_MAX_CELL_SIZE_KEY See Also: Constant Field Values @@ -2329,7 +2333,7 @@ implements DEFAULT_MAX_CELL_SIZE -public static finalint DEFAULT_MAX_CELL_SIZE +public static finalint DEFAULT_MAX_CELL_SIZE See Also: Constant Field Values @@ -2342,7 +2346,7 @@ implements HBASE_REGIONSERVER_MINIBATCH_SIZE -public static finalhttps://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String HBASE_REGIONSERVER_MINIBATCH_SIZE +public static finalhttps://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String HBASE_REGIONSERVER_MINIBATCH_SIZE See Also: Constant Field Values @@ -2355,7 +2359,7 @@ implements DEFAULT_HBASE_REGIONSERVER_MINIBATCH_SIZE -public static finalint DEFAULT_HBASE_REGIONSERVER_MINIBATCH_SIZE +public static finalint DEFAULT_HBASE_REGIONSERVER_MINIBATCH_SIZE See Also: Constant Field Values @@ -2368,7 +2372,7 @@ implements DEFAULT_DURABILITY -private static finalDurability DEFAULT_DURABILITY +private static finalDurability DEFAULT_DURABILITY This is the global default value for durability. All tables/mutations not defining a durability or using USE_DEFAULT will default to this value. @@ -2379,7 +2383,7 @@ implements closed -finalhttps://docs.oracle.com/javase/8/docs/api/java/util/concurrent/atomic/AtomicBoolean.html?is-external=true; title="class or interface in java.util.concurrent.atomic">AtomicBoolean closed +finalhttps://docs.oracle.com/javase/8/docs/api/java/util/concurrent/atomic/AtomicBoolean.html?is-external=true; title="class or interface in java.util.concurrent.atomic">AtomicBoolean closed @@ -2388,7 +2392,7 @@ implements closing -finalhttps://docs.oracle.com/javase/8/docs/api/java/util/concurrent/atomic/AtomicBoolean.html?is-external=true; title="class or interface in java.util.concurrent.atomic">AtomicBoolean closing
[11/51] [partial] hbase-site git commit: Published site at 31da4d0bce69b3a47066a5df675756087ce4dc60.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/a754d895/devapidocs/org/apache/hadoop/hbase/regionserver/HRegionServer.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/regionserver/HRegionServer.html b/devapidocs/org/apache/hadoop/hbase/regionserver/HRegionServer.html index 5b76e92..adccbc4 100644 --- a/devapidocs/org/apache/hadoop/hbase/regionserver/HRegionServer.html +++ b/devapidocs/org/apache/hadoop/hbase/regionserver/HRegionServer.html @@ -1216,7 +1216,7 @@ implements -private boolean +boolean isClusterUp() @@ -2419,7 +2419,7 @@ protected static finalhttps://docs.oracle.com/javase/8/docs/api/j movedRegions -protectedhttps://docs.oracle.com/javase/8/docs/api/java/util/Map.html?is-external=true; title="class or interface in java.util">Maphttps://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String,HRegionServer.MovedRegionInfo movedRegions +protectedhttps://docs.oracle.com/javase/8/docs/api/java/util/Map.html?is-external=true; title="class or interface in java.util">Maphttps://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String,HRegionServer.MovedRegionInfo movedRegions @@ -2428,7 +2428,7 @@ protected static finalhttps://docs.oracle.com/javase/8/docs/api/j TIMEOUT_REGION_MOVED -private static finalint TIMEOUT_REGION_MOVED +private static finalint TIMEOUT_REGION_MOVED See Also: Constant Field Values @@ -2756,8 +2756,10 @@ protected static finalhttps://docs.oracle.com/javase/8/docs/api/j isClusterUp -privatebooleanisClusterUp() +publicbooleanisClusterUp() +Specified by: +isClusterUpin interfaceRegionServerServices Returns: True if the cluster is up. @@ -2769,7 +2771,7 @@ protected static finalhttps://docs.oracle.com/javase/8/docs/api/j run -publicvoidrun() +publicvoidrun() The HRegionServer sticks in this loop until closed. Specified by: @@ -2785,7 +2787,7 @@ protected static finalhttps://docs.oracle.com/javase/8/docs/api/j containsMetaTableRegions -privatebooleancontainsMetaTableRegions() +privatebooleancontainsMetaTableRegions() @@ -2794,7 +2796,7 @@ protected static finalhttps://docs.oracle.com/javase/8/docs/api/j areAllUserRegionsOffline -privatebooleanareAllUserRegionsOffline() +privatebooleanareAllUserRegionsOffline() @@ -2803,7 +2805,7 @@ protected static finalhttps://docs.oracle.com/javase/8/docs/api/j getWriteRequestCount -privatelonggetWriteRequestCount() +privatelonggetWriteRequestCount() Returns: Current write count for all online regions. @@ -2816,7 +2818,7 @@ protected static finalhttps://docs.oracle.com/javase/8/docs/api/j tryRegionServerReport -protectedvoidtryRegionServerReport(longreportStartTime, +protectedvoidtryRegionServerReport(longreportStartTime, longreportEndTime) throws https://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true; title="class or interface in java.io">IOException @@ -2831,7 +2833,7 @@ protected static finalhttps://docs.oracle.com/javase/8/docs/api/j reportRegionSizesForQuotas -publicbooleanreportRegionSizesForQuotas(RegionSizeStoreregionSizeStore) +publicbooleanreportRegionSizesForQuotas(RegionSizeStoreregionSizeStore) Reports the given map of Regions and their size on the filesystem to the active Master. Specified by: @@ -2849,7 +2851,7 @@ protected static finalhttps://docs.oracle.com/javase/8/docs/api/j buildReportAndSend -voidbuildReportAndSend(org.apache.hadoop.hbase.shaded.protobuf.generated.RegionServerStatusProtos.RegionServerStatusService.BlockingInterfacerss, +voidbuildReportAndSend(org.apache.hadoop.hbase.shaded.protobuf.generated.RegionServerStatusProtos.RegionServerStatusService.BlockingInterfacerss, RegionSizeStoreregionSizeStore) throws org.apache.hbase.thirdparty.com.google.protobuf.ServiceException Builds the region size report and sends it to the master. Upon successful sending of the @@ -2869,7 +2871,7 @@ protected static finalhttps://docs.oracle.com/javase/8/docs/api/j buildRegionSpaceUseReportRequest -org.apache.hadoop.hbase.shaded.protobuf.generated.RegionServerStatusProtos.RegionSpaceUseReportRequestbuildRegionSpaceUseReportRequest(RegionSizeStoreregionSizes) +org.apache.hadoop.hbase.shaded.protobuf.generated.RegionServerStatusProtos.RegionSpaceUseReportRequestbuildRegionSpaceUseReportRequest(RegionSizeStoreregionSizes) Builds a RegionServerStatusProtos.RegionSpaceUseReportRequest protobuf message from the region size map. Parameters: @@ -2885,7 +2887,7 @@ protected static finalhttps://docs.oracle.com/javase/8/docs/api/j convertRegionSize -org.apache.hadoop.hbase.shaded.protobuf.generated.RegionServerStatusProtos.RegionSpaceUseconvertRegionSize(RegionInforegionInfo,
[12/51] [partial] hbase-site git commit: Published site at 31da4d0bce69b3a47066a5df675756087ce4dc60.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/a754d895/devapidocs/org/apache/hadoop/hbase/regionserver/HRegionServer.CompactionChecker.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/regionserver/HRegionServer.CompactionChecker.html b/devapidocs/org/apache/hadoop/hbase/regionserver/HRegionServer.CompactionChecker.html index 1546b5d..31c6fd0 100644 --- a/devapidocs/org/apache/hadoop/hbase/regionserver/HRegionServer.CompactionChecker.html +++ b/devapidocs/org/apache/hadoop/hbase/regionserver/HRegionServer.CompactionChecker.html @@ -122,7 +122,7 @@ var activeTableTab = "activeTableTab"; -private static class HRegionServer.CompactionChecker +private static class HRegionServer.CompactionChecker extends ScheduledChore @@ -233,7 +233,7 @@ extends instance -private finalHRegionServer instance +private finalHRegionServer instance @@ -242,7 +242,7 @@ extends majorCompactPriority -private finalint majorCompactPriority +private finalint majorCompactPriority @@ -251,7 +251,7 @@ extends DEFAULT_PRIORITY -private static finalint DEFAULT_PRIORITY +private static finalint DEFAULT_PRIORITY See Also: Constant Field Values @@ -264,7 +264,7 @@ extends iteration -privatelong iteration +privatelong iteration @@ -281,7 +281,7 @@ extends CompactionChecker -CompactionChecker(HRegionServerh, +CompactionChecker(HRegionServerh, intsleepTime, Stoppablestopper) @@ -300,7 +300,7 @@ extends chore -protectedvoidchore() +protectedvoidchore() Description copied from class:ScheduledChore The task to execute on each scheduled execution of the Chore http://git-wip-us.apache.org/repos/asf/hbase-site/blob/a754d895/devapidocs/org/apache/hadoop/hbase/regionserver/HRegionServer.MovedRegionInfo.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/regionserver/HRegionServer.MovedRegionInfo.html b/devapidocs/org/apache/hadoop/hbase/regionserver/HRegionServer.MovedRegionInfo.html index 38486a8..1239bd7 100644 --- a/devapidocs/org/apache/hadoop/hbase/regionserver/HRegionServer.MovedRegionInfo.html +++ b/devapidocs/org/apache/hadoop/hbase/regionserver/HRegionServer.MovedRegionInfo.html @@ -113,7 +113,7 @@ var activeTableTab = "activeTableTab"; -private static class HRegionServer.MovedRegionInfo +private static class HRegionServer.MovedRegionInfo extends https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true; title="class or interface in java.lang">Object @@ -218,7 +218,7 @@ extends https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html serverName -private finalServerName serverName +private finalServerName serverName @@ -227,7 +227,7 @@ extends https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html seqNum -private finallong seqNum +private finallong seqNum @@ -236,7 +236,7 @@ extends https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html ts -private finallong ts +private finallong ts @@ -253,7 +253,7 @@ extends https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html MovedRegionInfo -publicMovedRegionInfo(ServerNameserverName, +publicMovedRegionInfo(ServerNameserverName, longcloseSeqNum) @@ -271,7 +271,7 @@ extends https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html getServerName -publicServerNamegetServerName() +publicServerNamegetServerName() @@ -280,7 +280,7 @@ extends https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html getSeqNum -publiclonggetSeqNum() +publiclonggetSeqNum() @@ -289,7 +289,7 @@ extends https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html getMoveTime -publiclonggetMoveTime() +publiclonggetMoveTime() http://git-wip-us.apache.org/repos/asf/hbase-site/blob/a754d895/devapidocs/org/apache/hadoop/hbase/regionserver/HRegionServer.MovedRegionsCleaner.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/regionserver/HRegionServer.MovedRegionsCleaner.html b/devapidocs/org/apache/hadoop/hbase/regionserver/HRegionServer.MovedRegionsCleaner.html index 95037fd..01fb6e7 100644 --- a/devapidocs/org/apache/hadoop/hbase/regionserver/HRegionServer.MovedRegionsCleaner.html +++ b/devapidocs/org/apache/hadoop/hbase/regionserver/HRegionServer.MovedRegionsCleaner.html @@ -122,7 +122,7 @@ var activeTableTab = "activeTableTab"; -protected static final class HRegionServer.MovedRegionsCleaner +protected static final class HRegionServer.MovedRegionsCleaner extends ScheduledChore implements Stoppable Creates a Chore thread to clean the moved region cache. @@ -242,7 +242,7 @@ implements regionServer -privateHRegionServer regionServer +privateHRegionServer regionServer @@ -251,7 +251,7 @@ implements
[09/51] [partial] hbase-site git commit: Published site at 31da4d0bce69b3a47066a5df675756087ce4dc60.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/a754d895/devapidocs/org/apache/hadoop/hbase/regionserver/HStore.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/regionserver/HStore.html b/devapidocs/org/apache/hadoop/hbase/regionserver/HStore.html index 0f17e58..7ae1c82 100644 --- a/devapidocs/org/apache/hadoop/hbase/regionserver/HStore.html +++ b/devapidocs/org/apache/hadoop/hbase/regionserver/HStore.html @@ -18,7 +18,7 @@ catch(err) { } //--> -var methods = {"i0":10,"i1":10,"i2":10,"i3":10,"i4":10,"i5":10,"i6":10,"i7":10,"i8":10,"i9":10,"i10":10,"i11":10,"i12":10,"i13":10,"i14":10,"i15":10,"i16":10,"i17":10,"i18":10,"i19":10,"i20":10,"i21":10,"i22":10,"i23":10,"i24":10,"i25":10,"i26":10,"i27":10,"i28":9,"i29":10,"i30":10,"i31":10,"i32":10,"i33":10,"i34":9,"i35":10,"i36":9,"i37":9,"i38":10,"i39":10,"i40":10,"i41":10,"i42":10,"i43":10,"i44":10,"i45":10,"i46":10,"i47":10,"i48":10,"i49":10,"i50":10,"i51":10,"i52":10,"i53":10,"i54":10,"i55":10,"i56":10,"i57":10,"i58":10,"i59":10,"i60":10,"i61":10,"i62":10,"i63":10,"i64":10,"i65":10,"i66":10,"i67":10,"i68":10,"i69":10,"i70":10,"i71":10,"i72":10,"i73":10,"i74":10,"i75":10,"i76":10,"i77":10,"i78":10,"i79":10,"i80":10,"i81":10,"i82":10,"i83":10,"i84":10,"i85":10,"i86":10,"i87":10,"i88":10,"i89":10,"i90":10,"i91":10,"i92":41,"i93":41,"i94":10,"i95":10,"i96":10,"i97":10,"i98":10,"i99":10,"i100":10,"i101":10,"i102":10,"i103":10,"i104":10,"i105":10,"i106":10,"i107":10,"i108":10,"i109" :10,"i110":10,"i111":10,"i112":10,"i113":10,"i114":10,"i115":10,"i116":10,"i117":10,"i118":10,"i119":10,"i120":10,"i121":10,"i122":10,"i123":10,"i124":10,"i125":10,"i126":10,"i127":10,"i128":10,"i129":10,"i130":10,"i131":10,"i132":10,"i133":10,"i134":10,"i135":10,"i136":10,"i137":10,"i138":10,"i139":10,"i140":10,"i141":10,"i142":10,"i143":10}; +var methods = {"i0":10,"i1":10,"i2":10,"i3":10,"i4":10,"i5":10,"i6":10,"i7":10,"i8":10,"i9":10,"i10":10,"i11":10,"i12":10,"i13":10,"i14":10,"i15":10,"i16":10,"i17":10,"i18":10,"i19":10,"i20":10,"i21":10,"i22":10,"i23":10,"i24":10,"i25":10,"i26":10,"i27":10,"i28":9,"i29":10,"i30":10,"i31":10,"i32":10,"i33":10,"i34":9,"i35":10,"i36":9,"i37":9,"i38":10,"i39":10,"i40":10,"i41":10,"i42":10,"i43":10,"i44":10,"i45":10,"i46":10,"i47":10,"i48":10,"i49":10,"i50":10,"i51":10,"i52":10,"i53":10,"i54":10,"i55":10,"i56":10,"i57":10,"i58":10,"i59":10,"i60":10,"i61":10,"i62":10,"i63":10,"i64":10,"i65":10,"i66":10,"i67":10,"i68":10,"i69":10,"i70":10,"i71":10,"i72":10,"i73":10,"i74":10,"i75":10,"i76":10,"i77":10,"i78":10,"i79":10,"i80":10,"i81":10,"i82":10,"i83":10,"i84":10,"i85":10,"i86":10,"i87":10,"i88":10,"i89":10,"i90":10,"i91":10,"i92":10,"i93":41,"i94":41,"i95":10,"i96":10,"i97":10,"i98":10,"i99":10,"i100":10,"i101":10,"i102":10,"i103":10,"i104":10,"i105":10,"i106":10,"i107":10,"i108":10,"i109" :10,"i110":10,"i111":10,"i112":10,"i113":10,"i114":10,"i115":10,"i116":10,"i117":10,"i118":10,"i119":10,"i120":10,"i121":10,"i122":10,"i123":10,"i124":10,"i125":10,"i126":10,"i127":10,"i128":10,"i129":10,"i130":10,"i131":10,"i132":10,"i133":10,"i134":10,"i135":10,"i136":10,"i137":10,"i138":10,"i139":10,"i140":10,"i141":10,"i142":10,"i143":10,"i144":10}; var tabs = {65535:["t0","All Methods"],1:["t1","Static Methods"],2:["t2","Instance Methods"],8:["t4","Concrete Methods"],32:["t6","Deprecated Methods"]}; var altColor = "altColor"; var rowColor = "rowColor"; @@ -118,7 +118,7 @@ var activeTableTab = "activeTableTab"; @InterfaceAudience.Private -public class HStore +public class HStore extends https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true; title="class or interface in java.lang">Object implements Store, HeapSize, StoreConfigInformation, PropagatingConfigurationObserver A Store holds a column family in a Region. Its a memstore and a set of zero @@ -242,103 +242,111 @@ implements cryptoContext +private https://docs.oracle.com/javase/8/docs/api/java/util/concurrent/atomic/AtomicInteger.html?is-external=true; title="class or interface in java.util.concurrent.atomic">AtomicInteger +currentParallelPutCount + + private HFileDataBlockEncoder dataBlockEncoder - + static long DEEP_OVERHEAD - + static https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String DEFAULT_BLOCK_STORAGE_POLICY - + static int DEFAULT_BLOCKING_STOREFILE_COUNT - + static int DEFAULT_COMPACTCHECKER_INTERVAL_MULTIPLIER - + private static int DEFAULT_FLUSH_RETRIES_NUMBER - + private ColumnFamilyDescriptor family - + private https://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true; title="class or interface in java.util">ListHStoreFile filesCompacting - + static long FIXED_OVERHEAD - + private https://docs.oracle.com/javase/8/docs/api/java/util/concurrent/atomic/AtomicLong.html?is-external=true; title="class or interface in
hbase git commit: HBASE-20200 list_procedures fails in shell
Repository: hbase Updated Branches: refs/heads/branch-2.0 6874e1a7b -> 907ec6775 HBASE-20200 list_procedures fails in shell Signed-off-by: Ted YuSigned-off-by: Umesh Agashe Project: http://git-wip-us.apache.org/repos/asf/hbase/repo Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/907ec677 Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/907ec677 Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/907ec677 Branch: refs/heads/branch-2.0 Commit: 907ec677570d379fdd02216d2ad424e63500bf03 Parents: 6874e1a Author: Balazs Meszaros Authored: Wed Mar 14 17:31:15 2018 +0100 Committer: Peter Somogyi Committed: Thu Mar 15 08:21:02 2018 +0100 -- hbase-shell/src/main/ruby/shell/commands/list_procedures.rb | 1 - 1 file changed, 1 deletion(-) -- http://git-wip-us.apache.org/repos/asf/hbase/blob/907ec677/hbase-shell/src/main/ruby/shell/commands/list_procedures.rb -- diff --git a/hbase-shell/src/main/ruby/shell/commands/list_procedures.rb b/hbase-shell/src/main/ruby/shell/commands/list_procedures.rb index 77335b8..68842a0 100644 --- a/hbase-shell/src/main/ruby/shell/commands/list_procedures.rb +++ b/hbase-shell/src/main/ruby/shell/commands/list_procedures.rb @@ -35,7 +35,6 @@ EOF list = JSON.parse(admin.list_procedures) list.each do |proc| - formatter.row([proc]) submitted_time = Time.at(Integer(proc['submittedTime']) / 1000).to_s last_update = Time.at(Integer(proc['lastUpdate']) / 1000).to_s formatter.row([proc['procId'], proc['className'], proc['state'],
hbase git commit: HBASE-20200 list_procedures fails in shell
Repository: hbase Updated Branches: refs/heads/branch-2 24ea9d1e4 -> 5ea0db0b1 HBASE-20200 list_procedures fails in shell Signed-off-by: Ted YuSigned-off-by: Umesh Agashe Project: http://git-wip-us.apache.org/repos/asf/hbase/repo Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/5ea0db0b Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/5ea0db0b Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/5ea0db0b Branch: refs/heads/branch-2 Commit: 5ea0db0b1f42978d3941a654e8efeba3cfdfe521 Parents: 24ea9d1 Author: Balazs Meszaros Authored: Wed Mar 14 17:31:15 2018 +0100 Committer: Peter Somogyi Committed: Thu Mar 15 08:20:24 2018 +0100 -- hbase-shell/src/main/ruby/shell/commands/list_procedures.rb | 1 - 1 file changed, 1 deletion(-) -- http://git-wip-us.apache.org/repos/asf/hbase/blob/5ea0db0b/hbase-shell/src/main/ruby/shell/commands/list_procedures.rb -- diff --git a/hbase-shell/src/main/ruby/shell/commands/list_procedures.rb b/hbase-shell/src/main/ruby/shell/commands/list_procedures.rb index 77335b8..68842a0 100644 --- a/hbase-shell/src/main/ruby/shell/commands/list_procedures.rb +++ b/hbase-shell/src/main/ruby/shell/commands/list_procedures.rb @@ -35,7 +35,6 @@ EOF list = JSON.parse(admin.list_procedures) list.each do |proc| - formatter.row([proc]) submitted_time = Time.at(Integer(proc['submittedTime']) / 1000).to_s last_update = Time.at(Integer(proc['lastUpdate']) / 1000).to_s formatter.row([proc['procId'], proc['className'], proc['state'],
hbase git commit: HBASE-20200 list_procedures fails in shell
Repository: hbase Updated Branches: refs/heads/master 82483fad7 -> 31da4d0bc HBASE-20200 list_procedures fails in shell Signed-off-by: Ted YuSigned-off-by: Umesh Agashe Project: http://git-wip-us.apache.org/repos/asf/hbase/repo Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/31da4d0b Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/31da4d0b Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/31da4d0b Branch: refs/heads/master Commit: 31da4d0bce69b3a47066a5df675756087ce4dc60 Parents: 82483fa Author: Balazs Meszaros Authored: Wed Mar 14 17:31:15 2018 +0100 Committer: Peter Somogyi Committed: Thu Mar 15 08:19:50 2018 +0100 -- hbase-shell/src/main/ruby/shell/commands/list_procedures.rb | 1 - 1 file changed, 1 deletion(-) -- http://git-wip-us.apache.org/repos/asf/hbase/blob/31da4d0b/hbase-shell/src/main/ruby/shell/commands/list_procedures.rb -- diff --git a/hbase-shell/src/main/ruby/shell/commands/list_procedures.rb b/hbase-shell/src/main/ruby/shell/commands/list_procedures.rb index 77335b8..68842a0 100644 --- a/hbase-shell/src/main/ruby/shell/commands/list_procedures.rb +++ b/hbase-shell/src/main/ruby/shell/commands/list_procedures.rb @@ -35,7 +35,6 @@ EOF list = JSON.parse(admin.list_procedures) list.each do |proc| - formatter.row([proc]) submitted_time = Time.at(Integer(proc['submittedTime']) / 1000).to_s last_update = Time.at(Integer(proc['lastUpdate']) / 1000).to_s formatter.row([proc['procId'], proc['className'], proc['state'],