hbase git commit: HBASE-18428 Migrate ITDDLMasterFailover away from HTable/HColumn
Repository: hbase Updated Branches: refs/heads/master 8e2f0b2ec -> f391770f4 HBASE-18428 Migrate ITDDLMasterFailover away from HTable/HColumn Signed-off-by: Michael StackProject: http://git-wip-us.apache.org/repos/asf/hbase/repo Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/f391770f Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/f391770f Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/f391770f Branch: refs/heads/master Commit: f391770f47aebc824b462308c7ef9e508e76e209 Parents: 8e2f0b2 Author: Mike Drob Authored: Fri Jul 21 15:36:09 2017 -0500 Committer: Michael Stack Committed: Sun Jul 23 10:29:16 2017 +0100 -- .../hbase/IntegrationTestDDLMasterFailover.java | 135 ++- 1 file changed, 74 insertions(+), 61 deletions(-) -- http://git-wip-us.apache.org/repos/asf/hbase/blob/f391770f/hbase-it/src/test/java/org/apache/hadoop/hbase/IntegrationTestDDLMasterFailover.java -- diff --git a/hbase-it/src/test/java/org/apache/hadoop/hbase/IntegrationTestDDLMasterFailover.java b/hbase-it/src/test/java/org/apache/hadoop/hbase/IntegrationTestDDLMasterFailover.java index 2d3693a..e280453 100644 --- a/hbase-it/src/test/java/org/apache/hadoop/hbase/IntegrationTestDDLMasterFailover.java +++ b/hbase-it/src/test/java/org/apache/hadoop/hbase/IntegrationTestDDLMasterFailover.java @@ -31,10 +31,14 @@ import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.hbase.client.Admin; +import org.apache.hadoop.hbase.client.ColumnFamilyDescriptor; +import org.apache.hadoop.hbase.client.ColumnFamilyDescriptorBuilder; import org.apache.hadoop.hbase.client.Connection; import org.apache.hadoop.hbase.client.ConnectionFactory; import org.apache.hadoop.hbase.client.Put; import org.apache.hadoop.hbase.client.Table; +import org.apache.hadoop.hbase.client.TableDescriptor; +import org.apache.hadoop.hbase.client.TableDescriptorBuilder; import org.apache.hadoop.hbase.io.encoding.DataBlockEncoding; import org.apache.hadoop.hbase.testclassification.IntegrationTests; import org.apache.hadoop.hbase.util.Bytes; @@ -127,11 +131,11 @@ public class IntegrationTestDDLMasterFailover extends IntegrationTestBase { ConcurrentHashMap namespaceMap = new ConcurrentHashMap<>(); - ConcurrentHashMap enabledTables = new ConcurrentHashMap<>(); + ConcurrentHashMap enabledTables = new ConcurrentHashMap<>(); - ConcurrentHashMap disabledTables = new ConcurrentHashMap<>(); + ConcurrentHashMap disabledTables = new ConcurrentHashMap<>(); - ConcurrentHashMap deletedTables = new ConcurrentHashMap<>(); + ConcurrentHashMap deletedTables = new ConcurrentHashMap<>(); @Override public void setUpCluster() throws Exception { @@ -384,7 +388,7 @@ public class IntegrationTestDDLMasterFailover extends IntegrationTestBase { private abstract class TableAction extends MasterAction{ // TableAction has implemented selectTable() shared by multiple table Actions -protected HTableDescriptor selectTable(ConcurrentHashMap tableMap) +protected TableDescriptor selectTable(ConcurrentHashMap tableMap) { // synchronization to prevent removal from multiple threads synchronized (tableMap){ @@ -394,10 +398,8 @@ public class IntegrationTestDDLMasterFailover extends IntegrationTestBase { } ArrayList tableList = new ArrayList<>(tableMap.keySet()); TableName randomKey = tableList.get(RandomUtils.nextInt(tableList.size())); -HTableDescriptor randomHtd = tableMap.get(randomKey); -// remove from tableMap -tableMap.remove(randomKey); -return randomHtd; +TableDescriptor randomTd = tableMap.remove(randomKey); +return randomTd; } } } @@ -408,8 +410,8 @@ public class IntegrationTestDDLMasterFailover extends IntegrationTestBase { void perform() throws IOException { Admin admin = connection.getAdmin(); try { -HTableDescriptor htd = createTableDesc(); -TableName tableName = htd.getTableName(); +TableDescriptor td = createTableDesc(); +TableName tableName = td.getTableName(); if ( admin.tableExists(tableName)){ return; } @@ -417,10 +419,10 @@ public class IntegrationTestDDLMasterFailover extends IntegrationTestBase { numRegions = getConf().getInt(numRegionKey, DEFAULT_NUM_REGIONS); byte[]
hbase git commit: HBASE-18428 Migrate ITDDLMasterFailover away from HTable/HColumn
Repository: hbase Updated Branches: refs/heads/branch-2 79b61a054 -> ab90823c4 HBASE-18428 Migrate ITDDLMasterFailover away from HTable/HColumn Signed-off-by: Michael StackProject: http://git-wip-us.apache.org/repos/asf/hbase/repo Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/ab90823c Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/ab90823c Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/ab90823c Branch: refs/heads/branch-2 Commit: ab90823c4a65153e431f4b98294b30903a377717 Parents: 79b61a0 Author: Mike Drob Authored: Fri Jul 21 15:36:09 2017 -0500 Committer: Michael Stack Committed: Sun Jul 23 10:29:44 2017 +0100 -- .../hbase/IntegrationTestDDLMasterFailover.java | 135 ++- 1 file changed, 74 insertions(+), 61 deletions(-) -- http://git-wip-us.apache.org/repos/asf/hbase/blob/ab90823c/hbase-it/src/test/java/org/apache/hadoop/hbase/IntegrationTestDDLMasterFailover.java -- diff --git a/hbase-it/src/test/java/org/apache/hadoop/hbase/IntegrationTestDDLMasterFailover.java b/hbase-it/src/test/java/org/apache/hadoop/hbase/IntegrationTestDDLMasterFailover.java index 2d3693a..e280453 100644 --- a/hbase-it/src/test/java/org/apache/hadoop/hbase/IntegrationTestDDLMasterFailover.java +++ b/hbase-it/src/test/java/org/apache/hadoop/hbase/IntegrationTestDDLMasterFailover.java @@ -31,10 +31,14 @@ import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.hbase.client.Admin; +import org.apache.hadoop.hbase.client.ColumnFamilyDescriptor; +import org.apache.hadoop.hbase.client.ColumnFamilyDescriptorBuilder; import org.apache.hadoop.hbase.client.Connection; import org.apache.hadoop.hbase.client.ConnectionFactory; import org.apache.hadoop.hbase.client.Put; import org.apache.hadoop.hbase.client.Table; +import org.apache.hadoop.hbase.client.TableDescriptor; +import org.apache.hadoop.hbase.client.TableDescriptorBuilder; import org.apache.hadoop.hbase.io.encoding.DataBlockEncoding; import org.apache.hadoop.hbase.testclassification.IntegrationTests; import org.apache.hadoop.hbase.util.Bytes; @@ -127,11 +131,11 @@ public class IntegrationTestDDLMasterFailover extends IntegrationTestBase { ConcurrentHashMap namespaceMap = new ConcurrentHashMap<>(); - ConcurrentHashMap enabledTables = new ConcurrentHashMap<>(); + ConcurrentHashMap enabledTables = new ConcurrentHashMap<>(); - ConcurrentHashMap disabledTables = new ConcurrentHashMap<>(); + ConcurrentHashMap disabledTables = new ConcurrentHashMap<>(); - ConcurrentHashMap deletedTables = new ConcurrentHashMap<>(); + ConcurrentHashMap deletedTables = new ConcurrentHashMap<>(); @Override public void setUpCluster() throws Exception { @@ -384,7 +388,7 @@ public class IntegrationTestDDLMasterFailover extends IntegrationTestBase { private abstract class TableAction extends MasterAction{ // TableAction has implemented selectTable() shared by multiple table Actions -protected HTableDescriptor selectTable(ConcurrentHashMap tableMap) +protected TableDescriptor selectTable(ConcurrentHashMap tableMap) { // synchronization to prevent removal from multiple threads synchronized (tableMap){ @@ -394,10 +398,8 @@ public class IntegrationTestDDLMasterFailover extends IntegrationTestBase { } ArrayList tableList = new ArrayList<>(tableMap.keySet()); TableName randomKey = tableList.get(RandomUtils.nextInt(tableList.size())); -HTableDescriptor randomHtd = tableMap.get(randomKey); -// remove from tableMap -tableMap.remove(randomKey); -return randomHtd; +TableDescriptor randomTd = tableMap.remove(randomKey); +return randomTd; } } } @@ -408,8 +410,8 @@ public class IntegrationTestDDLMasterFailover extends IntegrationTestBase { void perform() throws IOException { Admin admin = connection.getAdmin(); try { -HTableDescriptor htd = createTableDesc(); -TableName tableName = htd.getTableName(); +TableDescriptor td = createTableDesc(); +TableName tableName = td.getTableName(); if ( admin.tableExists(tableName)){ return; } @@ -417,10 +419,10 @@ public class IntegrationTestDDLMasterFailover extends IntegrationTestBase { numRegions = getConf().getInt(numRegionKey, DEFAULT_NUM_REGIONS);
[2/3] hbase git commit: HBASE-18107: [AMv2] Remove DispatchMergingRegionsRequest & DispatchMergingRegions
http://git-wip-us.apache.org/repos/asf/hbase/blob/9e230dc3/hbase-protocol-shaded/src/main/java/org/apache/hadoop/hbase/shaded/protobuf/generated/MasterProtos.java -- diff --git a/hbase-protocol-shaded/src/main/java/org/apache/hadoop/hbase/shaded/protobuf/generated/MasterProtos.java b/hbase-protocol-shaded/src/main/java/org/apache/hadoop/hbase/shaded/protobuf/generated/MasterProtos.java index 0d2e09f..bc401c2 100644 --- a/hbase-protocol-shaded/src/main/java/org/apache/hadoop/hbase/shaded/protobuf/generated/MasterProtos.java +++ b/hbase-protocol-shaded/src/main/java/org/apache/hadoop/hbase/shaded/protobuf/generated/MasterProtos.java @@ -5507,35 +5507,33 @@ public final class MasterProtos { } - public interface DispatchMergingRegionsRequestOrBuilder extends - // @@protoc_insertion_point(interface_extends:hbase.pb.DispatchMergingRegionsRequest) + public interface MergeTableRegionsRequestOrBuilder extends + // @@protoc_insertion_point(interface_extends:hbase.pb.MergeTableRegionsRequest) org.apache.hadoop.hbase.shaded.com.google.protobuf.MessageOrBuilder { /** - * required .hbase.pb.RegionSpecifier region_a = 1; - */ -boolean hasRegionA(); -/** - * required .hbase.pb.RegionSpecifier region_a = 1; + * repeated .hbase.pb.RegionSpecifier region = 1; */ - org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.RegionSpecifier getRegionA(); + java.util.List +getRegionList(); /** - * required .hbase.pb.RegionSpecifier region_a = 1; + * repeated .hbase.pb.RegionSpecifier region = 1; */ - org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.RegionSpecifierOrBuilder getRegionAOrBuilder(); - + org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.RegionSpecifier getRegion(int index); /** - * required .hbase.pb.RegionSpecifier region_b = 2; + * repeated .hbase.pb.RegionSpecifier region = 1; */ -boolean hasRegionB(); +int getRegionCount(); /** - * required .hbase.pb.RegionSpecifier region_b = 2; + * repeated .hbase.pb.RegionSpecifier region = 1; */ - org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.RegionSpecifier getRegionB(); +java.util.List +getRegionOrBuilderList(); /** - * required .hbase.pb.RegionSpecifier region_b = 2; + * repeated .hbase.pb.RegionSpecifier region = 1; */ - org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.RegionSpecifierOrBuilder getRegionBOrBuilder(); + org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.RegionSpecifierOrBuilder getRegionOrBuilder( +int index); /** * optional bool forcible = 3 [default = false]; @@ -5567,20 +5565,21 @@ public final class MasterProtos { /** * ** - * Dispatch merging the specified regions. + * Merging the specified regions in a table. * * - * Protobuf type {@code hbase.pb.DispatchMergingRegionsRequest} + * Protobuf type {@code hbase.pb.MergeTableRegionsRequest} */ - public static final class DispatchMergingRegionsRequest extends + public static final class MergeTableRegionsRequest extends org.apache.hadoop.hbase.shaded.com.google.protobuf.GeneratedMessageV3 implements - // @@protoc_insertion_point(message_implements:hbase.pb.DispatchMergingRegionsRequest) - DispatchMergingRegionsRequestOrBuilder { -// Use DispatchMergingRegionsRequest.newBuilder() to construct. -private DispatchMergingRegionsRequest(org.apache.hadoop.hbase.shaded.com.google.protobuf.GeneratedMessageV3.Builder builder) { + // @@protoc_insertion_point(message_implements:hbase.pb.MergeTableRegionsRequest) + MergeTableRegionsRequestOrBuilder { +// Use MergeTableRegionsRequest.newBuilder() to construct. +private MergeTableRegionsRequest(org.apache.hadoop.hbase.shaded.com.google.protobuf.GeneratedMessageV3.Builder builder) { super(builder); } -private DispatchMergingRegionsRequest() { +private MergeTableRegionsRequest() { + region_ = java.util.Collections.emptyList(); forcible_ = false; nonceGroup_ = 0L; nonce_ = 0L; @@ -5591,7 +5590,7 @@ public final class MasterProtos { getUnknownFields() { return this.unknownFields; } -private DispatchMergingRegionsRequest( +private MergeTableRegionsRequest( org.apache.hadoop.hbase.shaded.com.google.protobuf.CodedInputStream input, org.apache.hadoop.hbase.shaded.com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws org.apache.hadoop.hbase.shaded.com.google.protobuf.InvalidProtocolBufferException { @@ -5615,43 +5614,26 @@ public final class MasterProtos { break; } case 10: { - org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.RegionSpecifier.Builder
hbase git commit: HBASE-18419 Update IntegrationTestIngestWithMOB and Actions to use ColumnFamily builders for modification
Repository: hbase Updated Branches: refs/heads/branch-2 254b78c11 -> 79b61a054 HBASE-18419 Update IntegrationTestIngestWithMOB and Actions to use ColumnFamily builders for modification Signed-off-by: Chia-Ping TsaiProject: http://git-wip-us.apache.org/repos/asf/hbase/repo Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/79b61a05 Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/79b61a05 Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/79b61a05 Branch: refs/heads/branch-2 Commit: 79b61a05460a5c889a3f657fd6227808015e3c5a Parents: 254b78c Author: Mike Drob Authored: Sun Jul 23 14:50:56 2017 +0800 Committer: Chia-Ping Tsai Committed: Sun Jul 23 15:00:07 2017 +0800 -- .../hbase/IntegrationTestIngestWithMOB.java | 29 ++-- .../hadoop/hbase/chaos/actions/Action.java | 47 +++ .../chaos/actions/ChangeBloomFilterAction.java | 40 .../chaos/actions/ChangeCompressionAction.java | 48 +--- .../chaos/actions/ChangeEncodingAction.java | 47 +-- .../chaos/actions/ChangeVersionsAction.java | 36 --- .../hbase/chaos/actions/RemoveColumnAction.java | 15 +++--- 7 files changed, 113 insertions(+), 149 deletions(-) -- http://git-wip-us.apache.org/repos/asf/hbase/blob/79b61a05/hbase-it/src/test/java/org/apache/hadoop/hbase/IntegrationTestIngestWithMOB.java -- diff --git a/hbase-it/src/test/java/org/apache/hadoop/hbase/IntegrationTestIngestWithMOB.java b/hbase-it/src/test/java/org/apache/hadoop/hbase/IntegrationTestIngestWithMOB.java index cd9e355..5bbb12b 100644 --- a/hbase-it/src/test/java/org/apache/hadoop/hbase/IntegrationTestIngestWithMOB.java +++ b/hbase-it/src/test/java/org/apache/hadoop/hbase/IntegrationTestIngestWithMOB.java @@ -25,6 +25,9 @@ import java.util.List; import org.apache.commons.cli.CommandLine; import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.hbase.client.Admin; +import org.apache.hadoop.hbase.client.ColumnFamilyDescriptor; +import org.apache.hadoop.hbase.client.ColumnFamilyDescriptorBuilder; +import org.apache.hadoop.hbase.client.Connection; import org.apache.hadoop.hbase.client.ConnectionFactory; import org.apache.hadoop.hbase.testclassification.IntegrationTests; import org.apache.hadoop.hbase.util.Bytes; @@ -113,20 +116,20 @@ public class IntegrationTestIngestWithMOB extends IntegrationTestIngest { super.initTable(); TableName tableName = getTablename(); -Admin admin = ConnectionFactory.createConnection().getAdmin(); -HTableDescriptor tableDesc = admin.getTableDescriptor(tableName); -LOG.info("Disabling table " + getTablename()); -admin.disableTable(tableName); -for (HColumnDescriptor columnDescriptor : tableDesc.getFamilies()) { - if(Arrays.equals(columnDescriptor.getName(), mobColumnFamily)) { -columnDescriptor.setMobEnabled(true); -columnDescriptor.setMobThreshold((long) threshold); -admin.modifyColumnFamily(tableName, columnDescriptor); - } +try (Connection connection = ConnectionFactory.createConnection(); + Admin admin = connection.getAdmin()) { + HTableDescriptor tableDesc = admin.getTableDescriptor(tableName); + LOG.info("Disabling table " + getTablename()); + admin.disableTable(tableName); + ColumnFamilyDescriptor mobColumn = tableDesc.getColumnFamily(mobColumnFamily); + ColumnFamilyDescriptor cfd = ColumnFamilyDescriptorBuilder.newBuilder(mobColumn) +.setMobEnabled(true) +.setMobThreshold((long) threshold) +.build(); + admin.modifyColumnFamily(tableName, cfd); + LOG.info("Enabling table " + getTablename()); + admin.enableTable(tableName); } -LOG.info("Enabling table " + getTablename()); -admin.enableTable(tableName); -admin.close(); } @Override http://git-wip-us.apache.org/repos/asf/hbase/blob/79b61a05/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/Action.java -- diff --git a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/Action.java b/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/Action.java index 4c7be8c..5ec9cdb 100644 --- a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/Action.java +++ b/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/Action.java @@ -23,6 +23,8 @@ import java.util.ArrayList; import java.util.Collection; import java.util.LinkedList; import java.util.List; +import java.util.function.BiConsumer; +import java.util.function.Consumer; import org.apache.commons.lang.math.RandomUtils; import org.apache.commons.logging.Log; @@ -30,12
hbase git commit: HBASE-18419 Update IntegrationTestIngestWithMOB and Actions to use ColumnFamily builders for modification
Repository: hbase Updated Branches: refs/heads/master 317ce7396 -> 8e2f0b2ec HBASE-18419 Update IntegrationTestIngestWithMOB and Actions to use ColumnFamily builders for modification Signed-off-by: Chia-Ping TsaiProject: http://git-wip-us.apache.org/repos/asf/hbase/repo Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/8e2f0b2e Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/8e2f0b2e Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/8e2f0b2e Branch: refs/heads/master Commit: 8e2f0b2ec203cb085686796350cb2420bb5c5cc7 Parents: 317ce73 Author: Mike Drob Authored: Sun Jul 23 14:50:56 2017 +0800 Committer: Chia-Ping Tsai Committed: Sun Jul 23 14:59:09 2017 +0800 -- .../hbase/IntegrationTestIngestWithMOB.java | 29 ++-- .../hadoop/hbase/chaos/actions/Action.java | 47 +++ .../chaos/actions/ChangeBloomFilterAction.java | 40 .../chaos/actions/ChangeCompressionAction.java | 48 +--- .../chaos/actions/ChangeEncodingAction.java | 47 +-- .../chaos/actions/ChangeVersionsAction.java | 36 --- .../hbase/chaos/actions/RemoveColumnAction.java | 15 +++--- 7 files changed, 113 insertions(+), 149 deletions(-) -- http://git-wip-us.apache.org/repos/asf/hbase/blob/8e2f0b2e/hbase-it/src/test/java/org/apache/hadoop/hbase/IntegrationTestIngestWithMOB.java -- diff --git a/hbase-it/src/test/java/org/apache/hadoop/hbase/IntegrationTestIngestWithMOB.java b/hbase-it/src/test/java/org/apache/hadoop/hbase/IntegrationTestIngestWithMOB.java index cd9e355..5bbb12b 100644 --- a/hbase-it/src/test/java/org/apache/hadoop/hbase/IntegrationTestIngestWithMOB.java +++ b/hbase-it/src/test/java/org/apache/hadoop/hbase/IntegrationTestIngestWithMOB.java @@ -25,6 +25,9 @@ import java.util.List; import org.apache.commons.cli.CommandLine; import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.hbase.client.Admin; +import org.apache.hadoop.hbase.client.ColumnFamilyDescriptor; +import org.apache.hadoop.hbase.client.ColumnFamilyDescriptorBuilder; +import org.apache.hadoop.hbase.client.Connection; import org.apache.hadoop.hbase.client.ConnectionFactory; import org.apache.hadoop.hbase.testclassification.IntegrationTests; import org.apache.hadoop.hbase.util.Bytes; @@ -113,20 +116,20 @@ public class IntegrationTestIngestWithMOB extends IntegrationTestIngest { super.initTable(); TableName tableName = getTablename(); -Admin admin = ConnectionFactory.createConnection().getAdmin(); -HTableDescriptor tableDesc = admin.getTableDescriptor(tableName); -LOG.info("Disabling table " + getTablename()); -admin.disableTable(tableName); -for (HColumnDescriptor columnDescriptor : tableDesc.getFamilies()) { - if(Arrays.equals(columnDescriptor.getName(), mobColumnFamily)) { -columnDescriptor.setMobEnabled(true); -columnDescriptor.setMobThreshold((long) threshold); -admin.modifyColumnFamily(tableName, columnDescriptor); - } +try (Connection connection = ConnectionFactory.createConnection(); + Admin admin = connection.getAdmin()) { + HTableDescriptor tableDesc = admin.getTableDescriptor(tableName); + LOG.info("Disabling table " + getTablename()); + admin.disableTable(tableName); + ColumnFamilyDescriptor mobColumn = tableDesc.getColumnFamily(mobColumnFamily); + ColumnFamilyDescriptor cfd = ColumnFamilyDescriptorBuilder.newBuilder(mobColumn) +.setMobEnabled(true) +.setMobThreshold((long) threshold) +.build(); + admin.modifyColumnFamily(tableName, cfd); + LOG.info("Enabling table " + getTablename()); + admin.enableTable(tableName); } -LOG.info("Enabling table " + getTablename()); -admin.enableTable(tableName); -admin.close(); } @Override http://git-wip-us.apache.org/repos/asf/hbase/blob/8e2f0b2e/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/Action.java -- diff --git a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/Action.java b/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/Action.java index 4c7be8c..5ec9cdb 100644 --- a/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/Action.java +++ b/hbase-it/src/test/java/org/apache/hadoop/hbase/chaos/actions/Action.java @@ -23,6 +23,8 @@ import java.util.ArrayList; import java.util.Collection; import java.util.LinkedList; import java.util.List; +import java.util.function.BiConsumer; +import java.util.function.Consumer; import org.apache.commons.lang.math.RandomUtils; import org.apache.commons.logging.Log; @@ -30,12 +32,18
[1/3] hbase git commit: HBASE-18107: [AMv2] Remove DispatchMergingRegionsRequest & DispatchMergingRegions
Repository: hbase Updated Branches: refs/heads/branch-2 ab90823c4 -> 9e230dc32 http://git-wip-us.apache.org/repos/asf/hbase/blob/9e230dc3/hbase-protocol-shaded/src/main/protobuf/Admin.proto -- diff --git a/hbase-protocol-shaded/src/main/protobuf/Admin.proto b/hbase-protocol-shaded/src/main/protobuf/Admin.proto index 6d67c89..3b8891b 100644 --- a/hbase-protocol-shaded/src/main/protobuf/Admin.proto +++ b/hbase-protocol-shaded/src/main/protobuf/Admin.proto @@ -273,22 +273,6 @@ message ExecuteProceduresResponse { repeated CloseRegionResponse close_region = 2; } -/** - * Merges the specified regions. - * - * This method currently closes the regions and then merges them - */ -message MergeRegionsRequest { - required RegionSpecifier region_a = 1; - required RegionSpecifier region_b = 2; - optional bool forcible = 3 [default = false]; - // wall clock time from master - optional uint64 master_system_time = 4; -} - -message MergeRegionsResponse { -} - service AdminService { rpc GetRegionInfo(GetRegionInfoRequest) returns(GetRegionInfoResponse); @@ -350,7 +334,4 @@ service AdminService { rpc ExecuteProcedures(ExecuteProceduresRequest) returns(ExecuteProceduresResponse); - - rpc MergeRegions(MergeRegionsRequest) -returns(MergeRegionsResponse); } http://git-wip-us.apache.org/repos/asf/hbase/blob/9e230dc3/hbase-protocol-shaded/src/main/protobuf/Master.proto -- diff --git a/hbase-protocol-shaded/src/main/protobuf/Master.proto b/hbase-protocol-shaded/src/main/protobuf/Master.proto index c9c586f..8d7cad9 100644 --- a/hbase-protocol-shaded/src/main/protobuf/Master.proto +++ b/hbase-protocol-shaded/src/main/protobuf/Master.proto @@ -81,20 +81,6 @@ message MoveRegionRequest { message MoveRegionResponse { } - /** - * Dispatch merging the specified regions. - */ -message DispatchMergingRegionsRequest { - required RegionSpecifier region_a = 1; - required RegionSpecifier region_b = 2; - optional bool forcible = 3 [default = false]; - optional uint64 nonce_group = 4 [default = 0]; - optional uint64 nonce = 5 [default = 0]; -} - -message DispatchMergingRegionsResponse { - optional uint64 proc_id = 1; -} /** * Merging the specified regions in a table. @@ -667,10 +653,6 @@ service MasterService { rpc ModifyColumn(ModifyColumnRequest) returns(ModifyColumnResponse); - /** Master dispatch merging the regions */ - rpc DispatchMergingRegions(DispatchMergingRegionsRequest) -returns(DispatchMergingRegionsResponse); - /** Move the region region to the destination server. */ rpc MoveRegion(MoveRegionRequest) returns(MoveRegionResponse); http://git-wip-us.apache.org/repos/asf/hbase/blob/9e230dc3/hbase-server/src/main/java/org/apache/hadoop/hbase/master/HMaster.java -- diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/master/HMaster.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/master/HMaster.java index e5f440e..573c353 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/master/HMaster.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/master/HMaster.java @@ -115,7 +115,6 @@ import org.apache.hadoop.hbase.master.procedure.CreateTableProcedure; import org.apache.hadoop.hbase.master.procedure.DeleteColumnFamilyProcedure; import org.apache.hadoop.hbase.master.procedure.DeleteTableProcedure; import org.apache.hadoop.hbase.master.procedure.DisableTableProcedure; -import org.apache.hadoop.hbase.master.procedure.DispatchMergingRegionsProcedure; import org.apache.hadoop.hbase.master.procedure.EnableTableProcedure; import org.apache.hadoop.hbase.master.procedure.MasterProcedureConstants; import org.apache.hadoop.hbase.master.procedure.MasterProcedureEnv; @@ -1522,59 +1521,6 @@ public class HMaster extends HRegionServer implements MasterServices { } @Override - public long dispatchMergingRegions( - final HRegionInfo regionInfoA, - final HRegionInfo regionInfoB, - final boolean forcible, - final long nonceGroup, - final long nonce) throws IOException { -checkInitialized(); - -TableName tableName = regionInfoA.getTable(); -if (tableName == null || regionInfoB.getTable() == null) { - throw new UnknownRegionException ("Can't merge regions without table associated"); -} - -if (!tableName.equals(regionInfoB.getTable())) { - throw new IOException ("Cannot merge regions from two different tables"); -} - -if (regionInfoA.compareTo(regionInfoB) == 0) { - throw new MergeRegionException( -"Cannot merge a region to itself " + regionInfoA + ", " + regionInfoB); -} - -final HRegionInfo [] regionsToMerge = new HRegionInfo[2]; -regionsToMerge [0] = regionInfoA; -regionsToMerge [1] = regionInfoB; - -return
[3/3] hbase git commit: HBASE-18107: [AMv2] Remove DispatchMergingRegionsRequest & DispatchMergingRegions
HBASE-18107: [AMv2] Remove DispatchMergingRegionsRequest & DispatchMergingRegions Signed-off-by: Michael StackProject: http://git-wip-us.apache.org/repos/asf/hbase/repo Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/9e230dc3 Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/9e230dc3 Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/9e230dc3 Branch: refs/heads/branch-2 Commit: 9e230dc321c9346660c8b33f37f44f3c789de0fd Parents: ab90823 Author: Yi Liang Authored: Mon Jul 17 13:24:38 2017 -0700 Committer: Michael Stack Committed: Sun Jul 23 10:45:38 2017 +0100 -- .../hbase/client/ConnectionImplementation.java |7 - .../client/ShortCircuitMasterConnection.java|6 - .../hbase/shaded/protobuf/ProtobufUtil.java | 63 - .../shaded/protobuf/generated/AdminProtos.java | 1592 +-- .../shaded/protobuf/generated/MasterProtos.java | 4372 ++ .../src/main/protobuf/Admin.proto | 19 - .../src/main/protobuf/Master.proto | 18 - .../org/apache/hadoop/hbase/master/HMaster.java | 54 - .../hbase/master/MasterCoprocessorHost.java | 22 - .../hadoop/hbase/master/MasterRpcServices.java | 30 - .../hadoop/hbase/master/MasterServices.java | 17 - .../hadoop/hbase/master/ServerManager.java | 31 - .../DispatchMergingRegionsProcedure.java| 584 --- .../hadoop/hbase/regionserver/CompactSplit.java | 14 - .../hbase/regionserver/RSRpcServices.java | 44 - .../hbase/master/MockNoopMasterServices.java|6 - .../hadoop/hbase/master/MockRegionServer.java |9 - .../regionserver/TestReplicator.java|7 - 18 files changed, 1404 insertions(+), 5491 deletions(-) -- http://git-wip-us.apache.org/repos/asf/hbase/blob/9e230dc3/hbase-client/src/main/java/org/apache/hadoop/hbase/client/ConnectionImplementation.java -- diff --git a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/ConnectionImplementation.java b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/ConnectionImplementation.java index 4dff7dd..fcd7c22 100644 --- a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/ConnectionImplementation.java +++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/ConnectionImplementation.java @@ -1342,13 +1342,6 @@ class ConnectionImplementation implements ClusterConnection, Closeable { } @Override - public MasterProtos.DispatchMergingRegionsResponse dispatchMergingRegions( - RpcController controller, MasterProtos.DispatchMergingRegionsRequest request) - throws ServiceException { -return stub.dispatchMergingRegions(controller, request); - } - - @Override public MasterProtos.AssignRegionResponse assignRegion(RpcController controller, MasterProtos.AssignRegionRequest request) throws ServiceException { return stub.assignRegion(controller, request); http://git-wip-us.apache.org/repos/asf/hbase/blob/9e230dc3/hbase-client/src/main/java/org/apache/hadoop/hbase/client/ShortCircuitMasterConnection.java -- diff --git a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/ShortCircuitMasterConnection.java b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/ShortCircuitMasterConnection.java index 6d75446..a8050d4 100644 --- a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/ShortCircuitMasterConnection.java +++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/ShortCircuitMasterConnection.java @@ -505,10 +505,4 @@ public class ShortCircuitMasterConnection implements MasterKeepAliveConnection { throws ServiceException { return stub.splitRegion(controller, request); } - - @Override - public DispatchMergingRegionsResponse dispatchMergingRegions(RpcController controller, - DispatchMergingRegionsRequest request) throws ServiceException { -return stub.dispatchMergingRegions(controller, request); - } } http://git-wip-us.apache.org/repos/asf/hbase/blob/9e230dc3/hbase-client/src/main/java/org/apache/hadoop/hbase/shaded/protobuf/ProtobufUtil.java -- diff --git a/hbase-client/src/main/java/org/apache/hadoop/hbase/shaded/protobuf/ProtobufUtil.java b/hbase-client/src/main/java/org/apache/hadoop/hbase/shaded/protobuf/ProtobufUtil.java index b1b52b1..91b7d3f 100644 --- a/hbase-client/src/main/java/org/apache/hadoop/hbase/shaded/protobuf/ProtobufUtil.java +++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/shaded/protobuf/ProtobufUtil.java @@ -95,7 +95,6 @@ import org.apache.hadoop.hbase.io.TimeRange; import
[2/3] hbase git commit: HBASE-18107: [AMv2] Remove DispatchMergingRegionsRequest & DispatchMergingRegions
http://git-wip-us.apache.org/repos/asf/hbase/blob/e9d8a7b6/hbase-protocol-shaded/src/main/java/org/apache/hadoop/hbase/shaded/protobuf/generated/MasterProtos.java -- diff --git a/hbase-protocol-shaded/src/main/java/org/apache/hadoop/hbase/shaded/protobuf/generated/MasterProtos.java b/hbase-protocol-shaded/src/main/java/org/apache/hadoop/hbase/shaded/protobuf/generated/MasterProtos.java index 0d2e09f..bc401c2 100644 --- a/hbase-protocol-shaded/src/main/java/org/apache/hadoop/hbase/shaded/protobuf/generated/MasterProtos.java +++ b/hbase-protocol-shaded/src/main/java/org/apache/hadoop/hbase/shaded/protobuf/generated/MasterProtos.java @@ -5507,35 +5507,33 @@ public final class MasterProtos { } - public interface DispatchMergingRegionsRequestOrBuilder extends - // @@protoc_insertion_point(interface_extends:hbase.pb.DispatchMergingRegionsRequest) + public interface MergeTableRegionsRequestOrBuilder extends + // @@protoc_insertion_point(interface_extends:hbase.pb.MergeTableRegionsRequest) org.apache.hadoop.hbase.shaded.com.google.protobuf.MessageOrBuilder { /** - * required .hbase.pb.RegionSpecifier region_a = 1; - */ -boolean hasRegionA(); -/** - * required .hbase.pb.RegionSpecifier region_a = 1; + * repeated .hbase.pb.RegionSpecifier region = 1; */ - org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.RegionSpecifier getRegionA(); + java.util.List +getRegionList(); /** - * required .hbase.pb.RegionSpecifier region_a = 1; + * repeated .hbase.pb.RegionSpecifier region = 1; */ - org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.RegionSpecifierOrBuilder getRegionAOrBuilder(); - + org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.RegionSpecifier getRegion(int index); /** - * required .hbase.pb.RegionSpecifier region_b = 2; + * repeated .hbase.pb.RegionSpecifier region = 1; */ -boolean hasRegionB(); +int getRegionCount(); /** - * required .hbase.pb.RegionSpecifier region_b = 2; + * repeated .hbase.pb.RegionSpecifier region = 1; */ - org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.RegionSpecifier getRegionB(); +java.util.List +getRegionOrBuilderList(); /** - * required .hbase.pb.RegionSpecifier region_b = 2; + * repeated .hbase.pb.RegionSpecifier region = 1; */ - org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.RegionSpecifierOrBuilder getRegionBOrBuilder(); + org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.RegionSpecifierOrBuilder getRegionOrBuilder( +int index); /** * optional bool forcible = 3 [default = false]; @@ -5567,20 +5565,21 @@ public final class MasterProtos { /** * ** - * Dispatch merging the specified regions. + * Merging the specified regions in a table. * * - * Protobuf type {@code hbase.pb.DispatchMergingRegionsRequest} + * Protobuf type {@code hbase.pb.MergeTableRegionsRequest} */ - public static final class DispatchMergingRegionsRequest extends + public static final class MergeTableRegionsRequest extends org.apache.hadoop.hbase.shaded.com.google.protobuf.GeneratedMessageV3 implements - // @@protoc_insertion_point(message_implements:hbase.pb.DispatchMergingRegionsRequest) - DispatchMergingRegionsRequestOrBuilder { -// Use DispatchMergingRegionsRequest.newBuilder() to construct. -private DispatchMergingRegionsRequest(org.apache.hadoop.hbase.shaded.com.google.protobuf.GeneratedMessageV3.Builder builder) { + // @@protoc_insertion_point(message_implements:hbase.pb.MergeTableRegionsRequest) + MergeTableRegionsRequestOrBuilder { +// Use MergeTableRegionsRequest.newBuilder() to construct. +private MergeTableRegionsRequest(org.apache.hadoop.hbase.shaded.com.google.protobuf.GeneratedMessageV3.Builder builder) { super(builder); } -private DispatchMergingRegionsRequest() { +private MergeTableRegionsRequest() { + region_ = java.util.Collections.emptyList(); forcible_ = false; nonceGroup_ = 0L; nonce_ = 0L; @@ -5591,7 +5590,7 @@ public final class MasterProtos { getUnknownFields() { return this.unknownFields; } -private DispatchMergingRegionsRequest( +private MergeTableRegionsRequest( org.apache.hadoop.hbase.shaded.com.google.protobuf.CodedInputStream input, org.apache.hadoop.hbase.shaded.com.google.protobuf.ExtensionRegistryLite extensionRegistry) throws org.apache.hadoop.hbase.shaded.com.google.protobuf.InvalidProtocolBufferException { @@ -5615,43 +5614,26 @@ public final class MasterProtos { break; } case 10: { - org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.RegionSpecifier.Builder
[3/3] hbase git commit: HBASE-18107: [AMv2] Remove DispatchMergingRegionsRequest & DispatchMergingRegions
HBASE-18107: [AMv2] Remove DispatchMergingRegionsRequest & DispatchMergingRegions Signed-off-by: Michael StackProject: http://git-wip-us.apache.org/repos/asf/hbase/repo Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/e9d8a7b6 Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/e9d8a7b6 Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/e9d8a7b6 Branch: refs/heads/master Commit: e9d8a7b6d5aa1ee8e523146ae535dcd0d7ca342f Parents: f391770 Author: Yi Liang Authored: Mon Jul 17 13:24:38 2017 -0700 Committer: Michael Stack Committed: Sun Jul 23 10:44:34 2017 +0100 -- .../hbase/client/ConnectionImplementation.java |7 - .../client/ShortCircuitMasterConnection.java|6 - .../hbase/shaded/protobuf/ProtobufUtil.java | 63 - .../shaded/protobuf/generated/AdminProtos.java | 1592 +-- .../shaded/protobuf/generated/MasterProtos.java | 4372 ++ .../src/main/protobuf/Admin.proto | 19 - .../src/main/protobuf/Master.proto | 18 - .../org/apache/hadoop/hbase/master/HMaster.java | 54 - .../hbase/master/MasterCoprocessorHost.java | 22 - .../hadoop/hbase/master/MasterRpcServices.java | 30 - .../hadoop/hbase/master/MasterServices.java | 17 - .../hadoop/hbase/master/ServerManager.java | 31 - .../DispatchMergingRegionsProcedure.java| 584 --- .../hadoop/hbase/regionserver/CompactSplit.java | 14 - .../hbase/regionserver/RSRpcServices.java | 44 - .../hbase/master/MockNoopMasterServices.java|6 - .../hadoop/hbase/master/MockRegionServer.java |9 - .../regionserver/TestReplicator.java|7 - 18 files changed, 1404 insertions(+), 5491 deletions(-) -- http://git-wip-us.apache.org/repos/asf/hbase/blob/e9d8a7b6/hbase-client/src/main/java/org/apache/hadoop/hbase/client/ConnectionImplementation.java -- diff --git a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/ConnectionImplementation.java b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/ConnectionImplementation.java index 4dff7dd..fcd7c22 100644 --- a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/ConnectionImplementation.java +++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/ConnectionImplementation.java @@ -1342,13 +1342,6 @@ class ConnectionImplementation implements ClusterConnection, Closeable { } @Override - public MasterProtos.DispatchMergingRegionsResponse dispatchMergingRegions( - RpcController controller, MasterProtos.DispatchMergingRegionsRequest request) - throws ServiceException { -return stub.dispatchMergingRegions(controller, request); - } - - @Override public MasterProtos.AssignRegionResponse assignRegion(RpcController controller, MasterProtos.AssignRegionRequest request) throws ServiceException { return stub.assignRegion(controller, request); http://git-wip-us.apache.org/repos/asf/hbase/blob/e9d8a7b6/hbase-client/src/main/java/org/apache/hadoop/hbase/client/ShortCircuitMasterConnection.java -- diff --git a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/ShortCircuitMasterConnection.java b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/ShortCircuitMasterConnection.java index 6d75446..a8050d4 100644 --- a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/ShortCircuitMasterConnection.java +++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/ShortCircuitMasterConnection.java @@ -505,10 +505,4 @@ public class ShortCircuitMasterConnection implements MasterKeepAliveConnection { throws ServiceException { return stub.splitRegion(controller, request); } - - @Override - public DispatchMergingRegionsResponse dispatchMergingRegions(RpcController controller, - DispatchMergingRegionsRequest request) throws ServiceException { -return stub.dispatchMergingRegions(controller, request); - } } http://git-wip-us.apache.org/repos/asf/hbase/blob/e9d8a7b6/hbase-client/src/main/java/org/apache/hadoop/hbase/shaded/protobuf/ProtobufUtil.java -- diff --git a/hbase-client/src/main/java/org/apache/hadoop/hbase/shaded/protobuf/ProtobufUtil.java b/hbase-client/src/main/java/org/apache/hadoop/hbase/shaded/protobuf/ProtobufUtil.java index b1b52b1..91b7d3f 100644 --- a/hbase-client/src/main/java/org/apache/hadoop/hbase/shaded/protobuf/ProtobufUtil.java +++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/shaded/protobuf/ProtobufUtil.java @@ -95,7 +95,6 @@ import org.apache.hadoop.hbase.io.TimeRange; import
[1/3] hbase git commit: HBASE-18107: [AMv2] Remove DispatchMergingRegionsRequest & DispatchMergingRegions
Repository: hbase Updated Branches: refs/heads/master f391770f4 -> e9d8a7b6d http://git-wip-us.apache.org/repos/asf/hbase/blob/e9d8a7b6/hbase-protocol-shaded/src/main/protobuf/Admin.proto -- diff --git a/hbase-protocol-shaded/src/main/protobuf/Admin.proto b/hbase-protocol-shaded/src/main/protobuf/Admin.proto index 6d67c89..3b8891b 100644 --- a/hbase-protocol-shaded/src/main/protobuf/Admin.proto +++ b/hbase-protocol-shaded/src/main/protobuf/Admin.proto @@ -273,22 +273,6 @@ message ExecuteProceduresResponse { repeated CloseRegionResponse close_region = 2; } -/** - * Merges the specified regions. - * - * This method currently closes the regions and then merges them - */ -message MergeRegionsRequest { - required RegionSpecifier region_a = 1; - required RegionSpecifier region_b = 2; - optional bool forcible = 3 [default = false]; - // wall clock time from master - optional uint64 master_system_time = 4; -} - -message MergeRegionsResponse { -} - service AdminService { rpc GetRegionInfo(GetRegionInfoRequest) returns(GetRegionInfoResponse); @@ -350,7 +334,4 @@ service AdminService { rpc ExecuteProcedures(ExecuteProceduresRequest) returns(ExecuteProceduresResponse); - - rpc MergeRegions(MergeRegionsRequest) -returns(MergeRegionsResponse); } http://git-wip-us.apache.org/repos/asf/hbase/blob/e9d8a7b6/hbase-protocol-shaded/src/main/protobuf/Master.proto -- diff --git a/hbase-protocol-shaded/src/main/protobuf/Master.proto b/hbase-protocol-shaded/src/main/protobuf/Master.proto index c9c586f..8d7cad9 100644 --- a/hbase-protocol-shaded/src/main/protobuf/Master.proto +++ b/hbase-protocol-shaded/src/main/protobuf/Master.proto @@ -81,20 +81,6 @@ message MoveRegionRequest { message MoveRegionResponse { } - /** - * Dispatch merging the specified regions. - */ -message DispatchMergingRegionsRequest { - required RegionSpecifier region_a = 1; - required RegionSpecifier region_b = 2; - optional bool forcible = 3 [default = false]; - optional uint64 nonce_group = 4 [default = 0]; - optional uint64 nonce = 5 [default = 0]; -} - -message DispatchMergingRegionsResponse { - optional uint64 proc_id = 1; -} /** * Merging the specified regions in a table. @@ -667,10 +653,6 @@ service MasterService { rpc ModifyColumn(ModifyColumnRequest) returns(ModifyColumnResponse); - /** Master dispatch merging the regions */ - rpc DispatchMergingRegions(DispatchMergingRegionsRequest) -returns(DispatchMergingRegionsResponse); - /** Move the region region to the destination server. */ rpc MoveRegion(MoveRegionRequest) returns(MoveRegionResponse); http://git-wip-us.apache.org/repos/asf/hbase/blob/e9d8a7b6/hbase-server/src/main/java/org/apache/hadoop/hbase/master/HMaster.java -- diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/master/HMaster.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/master/HMaster.java index 46be60f..77869f5 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/master/HMaster.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/master/HMaster.java @@ -115,7 +115,6 @@ import org.apache.hadoop.hbase.master.procedure.CreateTableProcedure; import org.apache.hadoop.hbase.master.procedure.DeleteColumnFamilyProcedure; import org.apache.hadoop.hbase.master.procedure.DeleteTableProcedure; import org.apache.hadoop.hbase.master.procedure.DisableTableProcedure; -import org.apache.hadoop.hbase.master.procedure.DispatchMergingRegionsProcedure; import org.apache.hadoop.hbase.master.procedure.EnableTableProcedure; import org.apache.hadoop.hbase.master.procedure.MasterProcedureConstants; import org.apache.hadoop.hbase.master.procedure.MasterProcedureEnv; @@ -1531,59 +1530,6 @@ public class HMaster extends HRegionServer implements MasterServices { } @Override - public long dispatchMergingRegions( - final HRegionInfo regionInfoA, - final HRegionInfo regionInfoB, - final boolean forcible, - final long nonceGroup, - final long nonce) throws IOException { -checkInitialized(); - -TableName tableName = regionInfoA.getTable(); -if (tableName == null || regionInfoB.getTable() == null) { - throw new UnknownRegionException ("Can't merge regions without table associated"); -} - -if (!tableName.equals(regionInfoB.getTable())) { - throw new IOException ("Cannot merge regions from two different tables"); -} - -if (regionInfoA.compareTo(regionInfoB) == 0) { - throw new MergeRegionException( -"Cannot merge a region to itself " + regionInfoA + ", " + regionInfoB); -} - -final HRegionInfo [] regionsToMerge = new HRegionInfo[2]; -regionsToMerge [0] = regionInfoA; -regionsToMerge [1] = regionInfoB; - -return
[45/51] [partial] hbase-site git commit: Published site at 82d554e3783372cc6b05489452c815b57c06f6cd.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/0383a9c2/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 fc793b9..278c383 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":9,"i23":10,"i24":10,"i25":10,"i26":10,"i27":10,"i28":10,"i29":10,"i30":10,"i31":10,"i32":10,"i33":10,"i34":10,"i35":10,"i36":10,"i37":10,"i38":10,"i39":9,"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":9,"i57":10,"i58":10,"i59":10,"i60":10,"i61":10,"i62":10,"i63":10,"i64":10,"i65":10,"i66":10,"i67":10,"i68":10,"i69":10,"i70":10,"i71":10,"i72":10,"i73":10,"i74":10,"i75":10,"i76":10,"i77":10,"i78":10,"i79":10,"i80":10,"i81":10,"i82":10,"i83":10,"i84":10,"i85":10,"i86":10,"i87":10,"i88":10,"i89":10,"i90":10,"i91":10,"i92":10,"i93":10,"i94":10,"i95":10,"i96":10,"i97":10,"i98":10,"i99":10,"i100":10,"i101":10,"i102":10,"i103":10,"i104":10,"i105":10,"i106":10,"i107":9,"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":9,"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,"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":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":9,"i23":10,"i24":10,"i25":10,"i26":10,"i27":10,"i28":10,"i29":10,"i30":10,"i31":10,"i32":10,"i33":10,"i34":10,"i35":10,"i36":10,"i37":10,"i38":9,"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":9,"i56":10,"i57":10,"i58":10,"i59":10,"i60":10,"i61":10,"i62":10,"i63":10,"i64":10,"i65":10,"i66":10,"i67":10,"i68":10,"i69":10,"i70":10,"i71":10,"i72":10,"i73":10,"i74":10,"i75":10,"i76":10,"i77":10,"i78":10,"i79":10,"i80":10,"i81":10,"i82":10,"i83":10,"i84":10,"i85":10,"i86":10,"i87":10,"i88":10,"i89":10,"i90":10,"i91":10,"i92":10,"i93":10,"i94":10,"i95":10,"i96":10,"i97":10,"i98":10,"i99":10,"i100":10,"i101":10,"i102":10,"i103":10,"i104":10,"i105":10,"i106":9,"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":9,"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,"i145":10,"i146":10,"i147":10,"i148":10,"i149":10,"i150":10,"i151":10,"i152":10,"i153":10,"i154":10,"i155":10,"i156":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 @@ -694,28 +694,18 @@ implements -long -dispatchMergingRegions(HRegionInforegionInfoA, - HRegionInforegionInfoB, - booleanforcible, - longnonceGroup, - longnonce) -Merge two regions. - - - void drainRegionServer(ServerNameserver) Mark a region server as draining to prevent additional regions from getting assigned to it. - + void enableReplicationPeer(http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">StringpeerId) Restart the replication stream to the specified peer - + long enableTable(TableNametableName, longnonceGroup, @@ -723,251 +713,251 @@ implements Enable an existing table - + private static void filterTablesByRegex(http://docs.oracle.com/javase/8/docs/api/java/util/Collection.html?is-external=true; title="class or interface in java.util">CollectionHTableDescriptordescriptors,
[17/51] [partial] hbase-site git commit: Published site at 82d554e3783372cc6b05489452c815b57c06f6cd.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/0383a9c2/devapidocs/src-html/org/apache/hadoop/hbase/master/procedure/DispatchMergingRegionsProcedure.html -- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/master/procedure/DispatchMergingRegionsProcedure.html b/devapidocs/src-html/org/apache/hadoop/hbase/master/procedure/DispatchMergingRegionsProcedure.html deleted file mode 100644 index a41cd97..000 --- a/devapidocs/src-html/org/apache/hadoop/hbase/master/procedure/DispatchMergingRegionsProcedure.html +++ /dev/null @@ -1,656 +0,0 @@ -http://www.w3.org/TR/html4/loose.dtd;> - - -Source code - - - - -001/** -002 * Licensed to the Apache Software Foundation (ASF) under one -003 * or more contributor license agreements. See the NOTICE file -004 * distributed with this work for additional information -005 * regarding copyright ownership. The ASF licenses this file -006 * to you under the Apache License, Version 2.0 (the -007 * "License"); you may not use this file except in compliance -008 * with the License. You may obtain a copy of the License at -009 * -010 * http://www.apache.org/licenses/LICENSE-2.0 -011 * -012 * Unless required by applicable law or agreed to in writing, software -013 * distributed under the License is distributed on an "AS IS" BASIS, -014 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -015 * See the License for the specific language governing permissions and -016 * limitations under the License. -017 */ -018 -019package org.apache.hadoop.hbase.master.procedure; -020 -021import java.io.IOException; -022import java.io.InputStream; -023import java.io.InterruptedIOException; -024import java.io.OutputStream; -025import java.util.Map; -026import java.util.concurrent.atomic.AtomicBoolean; -027 -028import org.apache.commons.logging.Log; -029import org.apache.commons.logging.LogFactory; -030import org.apache.hadoop.hbase.HRegionInfo; -031import org.apache.hadoop.hbase.RegionLoad; -032import org.apache.hadoop.hbase.ServerLoad; -033import org.apache.hadoop.hbase.ServerName; -034import org.apache.hadoop.hbase.TableName; -035import org.apache.hadoop.hbase.UnknownRegionException; -036import org.apache.hadoop.hbase.classification.InterfaceAudience; -037import org.apache.hadoop.hbase.exceptions.MergeRegionException; -038import org.apache.hadoop.hbase.exceptions.RegionOpeningException; -039import org.apache.hadoop.hbase.master.assignment.AssignmentManager; -040import org.apache.hadoop.hbase.master.assignment.RegionStates; -041import org.apache.hadoop.hbase.master.CatalogJanitor; -042import org.apache.hadoop.hbase.master.RegionPlan; -043import org.apache.hadoop.hbase.master.RegionState; -044import org.apache.hadoop.hbase.master.ServerManager; -045import org.apache.hadoop.hbase.shaded.protobuf.ProtobufUtil; -046import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos; -047import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.DispatchMergingRegionsState; -048import org.apache.hadoop.hbase.util.EnvironmentEdgeManager; -049 -050/** -051 * The procedure to Merge a region in a table. -052 */ -053@InterfaceAudience.Private -054public class DispatchMergingRegionsProcedure -055extends AbstractStateMachineTableProcedureDispatchMergingRegionsState { -056 private static final Log LOG = LogFactory.getLog(DispatchMergingRegionsProcedure.class); -057 -058 private final AtomicBoolean aborted = new AtomicBoolean(false); -059 private Boolean traceEnabled; -060 private AssignmentManager assignmentManager; -061 private int timeout; -062 private ServerName regionLocation; -063 private String regionsToMergeListFullName; -064 private String regionsToMergeListEncodedName; -065 -066 private TableName tableName; -067 private HRegionInfo [] regionsToMerge; -068 private boolean forcible; -069 -070 public DispatchMergingRegionsProcedure() { -071this.traceEnabled = isTraceEnabled(); -072this.assignmentManager = null; -073this.timeout = -1; -074this.regionLocation = null; -075this.regionsToMergeListFullName = null; -076this.regionsToMergeListEncodedName = null; -077 } -078 -079 public DispatchMergingRegionsProcedure( -080 final MasterProcedureEnv env, -081 final TableName tableName, -082 final HRegionInfo [] regionsToMerge, -083 final boolean forcible) { -084super(env); -085this.traceEnabled = isTraceEnabled(); -086this.assignmentManager = getAssignmentManager(env); -087this.tableName = tableName; -088// For now, we only merge 2 regions. It could be extended to more than 2 regions in -089// the future. -090assert(regionsToMerge.length == 2); -091this.regionsToMerge = regionsToMerge; -092this.forcible = forcible; -093 -094this.timeout = -1; -095this.regionsToMergeListFullName =
[06/51] [partial] hbase-site git commit: Published site at 82d554e3783372cc6b05489452c815b57c06f6cd.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/0383a9c2/export_control.html -- diff --git a/export_control.html b/export_control.html index 6fe3b1e..4f3356c 100644 --- a/export_control.html +++ b/export_control.html @@ -7,7 +7,7 @@ - + Apache HBase Export Control @@ -336,7 +336,7 @@ for more details. https://www.apache.org/;>The Apache Software Foundation. All rights reserved. - Last Published: 2017-07-22 + Last Published: 2017-07-23 http://git-wip-us.apache.org/repos/asf/hbase-site/blob/0383a9c2/hbase-annotations/checkstyle.html -- diff --git a/hbase-annotations/checkstyle.html b/hbase-annotations/checkstyle.html index 920..5a26d8e 100644 --- a/hbase-annotations/checkstyle.html +++ b/hbase-annotations/checkstyle.html @@ -1,5 +1,5 @@ http://www.w3.org/TR/xhtml1/DTD/xhtml1-transitional.dtd;> - + http://www.w3.org/1999/xhtml; xml:lang="en" lang="en"> @@ -10,7 +10,7 @@ @import url("./css/site.css"); - + @@ -27,7 +27,7 @@ -Last Published: 2017-07-22 +Last Published: 2017-07-23 | Version: 3.0.0-SNAPSHOT Apache HBase - Annotations http://git-wip-us.apache.org/repos/asf/hbase-site/blob/0383a9c2/hbase-annotations/dependencies.html -- diff --git a/hbase-annotations/dependencies.html b/hbase-annotations/dependencies.html index 5518f91..cd30803 100644 --- a/hbase-annotations/dependencies.html +++ b/hbase-annotations/dependencies.html @@ -1,5 +1,5 @@ http://www.w3.org/TR/xhtml1/DTD/xhtml1-transitional.dtd;> - + http://www.w3.org/1999/xhtml; xml:lang="en" lang="en"> @@ -10,7 +10,7 @@ @import url("./css/site.css"); - + @@ -27,7 +27,7 @@ -Last Published: 2017-07-22 +Last Published: 2017-07-23 | Version: 3.0.0-SNAPSHOT Apache HBase - Annotations http://git-wip-us.apache.org/repos/asf/hbase-site/blob/0383a9c2/hbase-annotations/dependency-convergence.html -- diff --git a/hbase-annotations/dependency-convergence.html b/hbase-annotations/dependency-convergence.html index 8ccf878..6fb3be5 100644 --- a/hbase-annotations/dependency-convergence.html +++ b/hbase-annotations/dependency-convergence.html @@ -1,5 +1,5 @@ http://www.w3.org/TR/xhtml1/DTD/xhtml1-transitional.dtd;> - + http://www.w3.org/1999/xhtml; xml:lang="en" lang="en"> @@ -10,7 +10,7 @@ @import url("./css/site.css"); - + @@ -27,7 +27,7 @@ -Last Published: 2017-07-22 +Last Published: 2017-07-23 | Version: 3.0.0-SNAPSHOT Apache HBase - Annotations http://git-wip-us.apache.org/repos/asf/hbase-site/blob/0383a9c2/hbase-annotations/dependency-info.html -- diff --git a/hbase-annotations/dependency-info.html b/hbase-annotations/dependency-info.html index 1575b93..1810629 100644 --- a/hbase-annotations/dependency-info.html +++ b/hbase-annotations/dependency-info.html @@ -1,5 +1,5 @@ http://www.w3.org/TR/xhtml1/DTD/xhtml1-transitional.dtd;> - + http://www.w3.org/1999/xhtml; xml:lang="en" lang="en"> @@ -10,7 +10,7 @@ @import url("./css/site.css"); - + @@ -27,7 +27,7 @@ -Last Published: 2017-07-22 +Last Published: 2017-07-23 | Version: 3.0.0-SNAPSHOT Apache HBase - Annotations http://git-wip-us.apache.org/repos/asf/hbase-site/blob/0383a9c2/hbase-annotations/dependency-management.html -- diff --git a/hbase-annotations/dependency-management.html b/hbase-annotations/dependency-management.html index 9f0bb09..8386a04 100644 --- a/hbase-annotations/dependency-management.html +++ b/hbase-annotations/dependency-management.html @@ -1,5 +1,5 @@ http://www.w3.org/TR/xhtml1/DTD/xhtml1-transitional.dtd;> - + http://www.w3.org/1999/xhtml; xml:lang="en" lang="en"> @@ -10,7 +10,7 @@ @import url("./css/site.css"); - +
[40/51] [partial] hbase-site git commit: Published site at 82d554e3783372cc6b05489452c815b57c06f6cd.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/0383a9c2/devapidocs/org/apache/hadoop/hbase/master/ServerManager.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/master/ServerManager.html b/devapidocs/org/apache/hadoop/hbase/master/ServerManager.html index feefdbc..5c84d5c 100644 --- a/devapidocs/org/apache/hadoop/hbase/master/ServerManager.html +++ b/devapidocs/org/apache/hadoop/hbase/master/ServerManager.html @@ -18,7 +18,7 @@ catch(err) { } //--> -var methods = {"i0":10,"i1":10,"i2":10,"i3":10,"i4":10,"i5":10,"i6":10,"i7":9,"i8":10,"i9":10,"i10":10,"i11":10,"i12":10,"i13":10,"i14":10,"i15":10,"i16":10,"i17":10,"i18":10,"i19":10,"i20":10,"i21":10,"i22":10,"i23":10,"i24":10,"i25":10,"i26":10,"i27":10,"i28":10,"i29":10,"i30":10,"i31":10,"i32":10,"i33":10,"i34":10,"i35":10,"i36":10,"i37":10,"i38":10,"i39":10,"i40":10,"i41":10,"i42":10,"i43":10,"i44":10,"i45":10,"i46":10,"i47":10,"i48":10,"i49":10,"i50":10,"i51":10,"i52":10,"i53":10,"i54":10,"i55":10,"i56":10}; +var methods = {"i0":10,"i1":10,"i2":10,"i3":10,"i4":10,"i5":10,"i6":10,"i7":9,"i8":10,"i9":10,"i10":10,"i11":10,"i12":10,"i13":10,"i14":10,"i15":10,"i16":10,"i17":10,"i18":10,"i19":10,"i20":10,"i21":10,"i22":10,"i23":10,"i24":10,"i25":10,"i26":10,"i27":10,"i28":10,"i29":10,"i30":10,"i31":10,"i32":10,"i33":10,"i34":10,"i35":10,"i36":10,"i37":10,"i38":10,"i39":10,"i40":10,"i41":10,"i42":10,"i43":10,"i44":10,"i45":10,"i46":10,"i47":10,"i48":10,"i49":10,"i50":10,"i51":10,"i52":10,"i53":10,"i54":10,"i55":10}; var tabs = {65535:["t0","All Methods"],1:["t1","Static Methods"],2:["t2","Instance Methods"],8:["t4","Concrete Methods"]}; var altColor = "altColor"; var rowColor = "rowColor"; @@ -564,46 +564,35 @@ extends http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? void -sendRegionsMerge(ServerNameserver, -HRegionInforegion_a, -HRegionInforegion_b, -booleanforcible, -Useruser) -Sends an MERGE REGIONS RPC to the specified server to merge the specified - regions. - - - -void sendRegionWarmup(ServerNameserver, HRegionInforegion) Sends a WARMUP RPC to the specified server to warmup the specified region. - + void shutdownCluster() - + void stop() Stop the ServerManager. - + boolean unregisterListener(ServerListenerlistener) Remove the listener from the notification list. - + private void updateLastFlushedSequenceIds(ServerNamesn, ServerLoadhsl) Updates last flushed sequence Ids for the regions on server sn - + void waitForRegionServers(MonitoredTaskstatus) Wait for the region servers to report in. @@ -1211,42 +1200,13 @@ extends http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? publicvoidexpireServer(ServerNameserverName) - - - - - -sendRegionsMerge -publicvoidsendRegionsMerge(ServerNameserver, - HRegionInforegion_a, - HRegionInforegion_b, - booleanforcible, - Useruser) - throws http://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true; title="class or interface in java.io">IOException -Sends an MERGE REGIONS RPC to the specified server to merge the specified - regions. - - A region server could reject the close request because it either does not - have the specified region. - -Parameters: -server - server to merge regions -region_a - region to merge -region_b - region to merge -forcible - true if do a compulsory merge, otherwise we will only merge - two adjacent regions -Throws: -http://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true; title="class or interface in java.io">IOException - - - moveFromOnlineToDeadServers -publicvoidmoveFromOnlineToDeadServers(ServerNamesn) +publicvoidmoveFromOnlineToDeadServers(ServerNamesn) @@ -1255,7 +1215,7 @@ extends http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? processDeadServer -publicvoidprocessDeadServer(ServerNameserverName, +publicvoidprocessDeadServer(ServerNameserverName, booleanshouldSplitWal) @@ -1265,7 +1225,7 @@ extends http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? processQueuedDeadServers -voidprocessQueuedDeadServers() +voidprocessQueuedDeadServers() Process the servers which died during master's initialization. It will be called after HMaster#assignMeta and AssignmentManager#joinCluster. @@ -1276,7 +1236,7 @@ extends http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? removeServerFromDrainList -publicbooleanremoveServerFromDrainList(ServerNamesn) +publicbooleanremoveServerFromDrainList(ServerNamesn) @@ -1285,7 +1245,7 @@ extends http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?
[50/51] [partial] hbase-site git commit: Published site at 82d554e3783372cc6b05489452c815b57c06f6cd.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/0383a9c2/checkstyle-aggregate.html -- diff --git a/checkstyle-aggregate.html b/checkstyle-aggregate.html index 3489918..86eb488 100644 --- a/checkstyle-aggregate.html +++ b/checkstyle-aggregate.html @@ -7,7 +7,7 @@ - + Apache HBase Checkstyle Results @@ -286,10 +286,10 @@ Warnings Errors -2247 +2246 0 0 -14922 +14830 Files @@ -3012,7 +3012,7 @@ org/apache/hadoop/hbase/master/HMaster.java 0 0 -270 +253 org/apache/hadoop/hbase/master/HMasterCommandLine.java 0 @@ -3057,7 +3057,7 @@ org/apache/hadoop/hbase/master/MasterServices.java 0 0 -44 +43 org/apache/hadoop/hbase/master/MasterStatusServlet.java 0 @@ -3132,7 +3132,7 @@ org/apache/hadoop/hbase/master/ServerManager.java 0 0 -38 +36 org/apache/hadoop/hbase/master/SnapshotOfRegionAssignmentFromMeta.java 0 @@ -3394,3886 +3394,3881 @@ 0 37 -org/apache/hadoop/hbase/master/procedure/DispatchMergingRegionsProcedure.java -0 -0 -60 - org/apache/hadoop/hbase/master/procedure/EnableTableProcedure.java 0 0 37 - + org/apache/hadoop/hbase/master/procedure/MasterProcedureEnv.java 0 0 3 - + org/apache/hadoop/hbase/master/procedure/MasterProcedureScheduler.java 0 0 32 - + org/apache/hadoop/hbase/master/procedure/MasterProcedureUtil.java 0 0 2 - + org/apache/hadoop/hbase/master/procedure/ModifyColumnFamilyProcedure.java 0 0 31 - + org/apache/hadoop/hbase/master/procedure/ModifyNamespaceProcedure.java 0 0 16 - + org/apache/hadoop/hbase/master/procedure/ModifyTableProcedure.java 0 0 45 - + org/apache/hadoop/hbase/master/procedure/ProcedureSyncWait.java 0 0 46 - + org/apache/hadoop/hbase/master/procedure/RSProcedureDispatcher.java 0 0 6 - + org/apache/hadoop/hbase/master/procedure/RestoreSnapshotProcedure.java 0 0 3 - + org/apache/hadoop/hbase/master/procedure/ServerCrashProcedure.java 0 0 59 - + org/apache/hadoop/hbase/master/procedure/TruncateTableProcedure.java 0 0 1 - + org/apache/hadoop/hbase/master/replication/ReplicationManager.java 0 0 3 - + org/apache/hadoop/hbase/master/snapshot/DisabledTableSnapshotHandler.java 0 0 1 - + org/apache/hadoop/hbase/master/snapshot/EnabledTableSnapshotHandler.java 0 0 3 - + org/apache/hadoop/hbase/master/snapshot/MasterSnapshotVerifier.java 0 0 5 - + org/apache/hadoop/hbase/master/snapshot/SnapshotFileCache.java 0 0 4 - + org/apache/hadoop/hbase/master/snapshot/SnapshotHFileCleaner.java 0 0 1 - + org/apache/hadoop/hbase/master/snapshot/SnapshotManager.java 0 0 17 - + org/apache/hadoop/hbase/master/snapshot/TakeSnapshotHandler.java 0 0 6 - + org/apache/hadoop/hbase/metrics/BaseSourceImpl.java 0 0 8 - + org/apache/hadoop/hbase/metrics/Interns.java 0 0 1 - + org/apache/hadoop/hbase/metrics/MetricRegistriesLoader.java 0 0 2 - + org/apache/hadoop/hbase/metrics/MetricSet.java 0 0 1 - + org/apache/hadoop/hbase/metrics/MetricsInfoImpl.java 0 0 1 - + org/apache/hadoop/hbase/metrics/impl/DropwizardMeter.java 0 0 1 - + org/apache/hadoop/hbase/metrics/impl/GlobalMetricRegistriesAdapter.java 0 0 3 - + org/apache/hadoop/hbase/metrics/impl/RefCountingMap.java 0 0 1 - + org/apache/hadoop/hbase/mob/CachedMobFile.java 0 0 1 - + org/apache/hadoop/hbase/mob/DefaultMobStoreCompactor.java 0 0 6 - + org/apache/hadoop/hbase/mob/DefaultMobStoreFlusher.java 0 0 4 - + org/apache/hadoop/hbase/mob/MobCacheConfig.java 0 0 1 - + org/apache/hadoop/hbase/mob/MobFile.java 0 0 6 - + org/apache/hadoop/hbase/mob/MobFileCache.java 0 0 2 - + org/apache/hadoop/hbase/mob/MobUtils.java 0 0 12 - + org/apache/hadoop/hbase/mob/compactions/MobCompactor.java 0 0 3 - + org/apache/hadoop/hbase/mob/compactions/PartitionedMobCompactionRequest.java 0 0 7 - + org/apache/hadoop/hbase/mob/compactions/PartitionedMobCompactor.java 0 0 10 - + org/apache/hadoop/hbase/monitoring/LogMonitoring.java 0 0 2 - + org/apache/hadoop/hbase/monitoring/MemoryBoundedLogMessageBuffer.java 0 0 2 - + org/apache/hadoop/hbase/monitoring/MonitoredRPCHandlerImpl.java 0 0 4 - + org/apache/hadoop/hbase/monitoring/MonitoredTaskImpl.java 0 0 1 - + org/apache/hadoop/hbase/monitoring/StateDumpServlet.java 0 0 1 - + org/apache/hadoop/hbase/monitoring/ThreadMonitoring.java 0 0 3 - + org/apache/hadoop/hbase/namespace/NamespaceStateManager.java 0 0 3 - + org/apache/hadoop/hbase/namespace/NamespaceTableAndRegionInfo.java 0 0 1 - + org/apache/hadoop/hbase/net/Address.java 0 0 3 - + org/apache/hadoop/hbase/nio/ByteBuff.java 0 0 24 - + org/apache/hadoop/hbase/nio/MultiByteBuff.java 0 0 30 - + org/apache/hadoop/hbase/nio/SingleByteBuff.java 0 0 2 - + org/apache/hadoop/hbase/procedure/MasterProcedureManager.java 0 0 7 - + org/apache/hadoop/hbase/procedure/Procedure.java 0 0 13 - +
[32/51] [partial] hbase-site git commit: Published site at 82d554e3783372cc6b05489452c815b57c06f6cd.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/0383a9c2/devapidocs/src-html/org/apache/hadoop/hbase/client/ConnectionImplementation.MasterServiceState.html -- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/client/ConnectionImplementation.MasterServiceState.html b/devapidocs/src-html/org/apache/hadoop/hbase/client/ConnectionImplementation.MasterServiceState.html index 6c200a1..e6f8c2e 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/client/ConnectionImplementation.MasterServiceState.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/client/ConnectionImplementation.MasterServiceState.html @@ -1350,726 +1350,719 @@ 1342 } 1343 1344 @Override -1345 public MasterProtos.DispatchMergingRegionsResponse dispatchMergingRegions( -1346 RpcController controller, MasterProtos.DispatchMergingRegionsRequest request) -1347 throws ServiceException { -1348return stub.dispatchMergingRegions(controller, request); -1349 } -1350 -1351 @Override -1352 public MasterProtos.AssignRegionResponse assignRegion(RpcController controller, -1353 MasterProtos.AssignRegionRequest request) throws ServiceException { -1354return stub.assignRegion(controller, request); -1355 } -1356 -1357 @Override -1358 public MasterProtos.UnassignRegionResponse unassignRegion(RpcController controller, -1359 MasterProtos.UnassignRegionRequest request) throws ServiceException { -1360return stub.unassignRegion(controller, request); -1361 } -1362 -1363 @Override -1364 public MasterProtos.OfflineRegionResponse offlineRegion(RpcController controller, -1365 MasterProtos.OfflineRegionRequest request) throws ServiceException { -1366return stub.offlineRegion(controller, request); -1367 } -1368 -1369 @Override -1370 public MasterProtos.SplitTableRegionResponse splitRegion(RpcController controller, -1371 MasterProtos.SplitTableRegionRequest request) throws ServiceException { -1372return stub.splitRegion(controller, request); -1373 } -1374 -1375 @Override -1376 public MasterProtos.DeleteTableResponse deleteTable(RpcController controller, -1377 MasterProtos.DeleteTableRequest request) throws ServiceException { -1378return stub.deleteTable(controller, request); -1379 } -1380 -1381 @Override -1382 public MasterProtos.TruncateTableResponse truncateTable(RpcController controller, -1383 MasterProtos.TruncateTableRequest request) throws ServiceException { -1384return stub.truncateTable(controller, request); -1385 } -1386 -1387 @Override -1388 public MasterProtos.EnableTableResponse enableTable(RpcController controller, -1389 MasterProtos.EnableTableRequest request) throws ServiceException { -1390return stub.enableTable(controller, request); -1391 } -1392 -1393 @Override -1394 public MasterProtos.DisableTableResponse disableTable(RpcController controller, -1395 MasterProtos.DisableTableRequest request) throws ServiceException { -1396return stub.disableTable(controller, request); -1397 } -1398 -1399 @Override -1400 public MasterProtos.ModifyTableResponse modifyTable(RpcController controller, -1401 MasterProtos.ModifyTableRequest request) throws ServiceException { -1402return stub.modifyTable(controller, request); -1403 } -1404 -1405 @Override -1406 public MasterProtos.CreateTableResponse createTable(RpcController controller, -1407 MasterProtos.CreateTableRequest request) throws ServiceException { -1408return stub.createTable(controller, request); -1409 } -1410 -1411 @Override -1412 public MasterProtos.ShutdownResponse shutdown(RpcController controller, -1413 MasterProtos.ShutdownRequest request) throws ServiceException { -1414return stub.shutdown(controller, request); -1415 } -1416 -1417 @Override -1418 public MasterProtos.StopMasterResponse stopMaster(RpcController controller, -1419 MasterProtos.StopMasterRequest request) throws ServiceException { -1420return stub.stopMaster(controller, request); +1345 public MasterProtos.AssignRegionResponse assignRegion(RpcController controller, +1346 MasterProtos.AssignRegionRequest request) throws ServiceException { +1347return stub.assignRegion(controller, request); +1348 } +1349 +1350 @Override +1351 public MasterProtos.UnassignRegionResponse unassignRegion(RpcController controller, +1352 MasterProtos.UnassignRegionRequest request) throws ServiceException { +1353return stub.unassignRegion(controller, request); +1354 } +1355 +1356 @Override +1357 public MasterProtos.OfflineRegionResponse
[24/51] [partial] hbase-site git commit: Published site at 82d554e3783372cc6b05489452c815b57c06f6cd.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/0383a9c2/devapidocs/src-html/org/apache/hadoop/hbase/master/HMaster.html -- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/master/HMaster.html b/devapidocs/src-html/org/apache/hadoop/hbase/master/HMaster.html index 5479fb1..49ef112 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/master/HMaster.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/master/HMaster.html @@ -123,3388 +123,3334 @@ 115import org.apache.hadoop.hbase.master.procedure.DeleteColumnFamilyProcedure; 116import org.apache.hadoop.hbase.master.procedure.DeleteTableProcedure; 117import org.apache.hadoop.hbase.master.procedure.DisableTableProcedure; -118import org.apache.hadoop.hbase.master.procedure.DispatchMergingRegionsProcedure; -119import org.apache.hadoop.hbase.master.procedure.EnableTableProcedure; -120import org.apache.hadoop.hbase.master.procedure.MasterProcedureConstants; -121import org.apache.hadoop.hbase.master.procedure.MasterProcedureEnv; -122import org.apache.hadoop.hbase.master.procedure.MasterProcedureScheduler; -123import org.apache.hadoop.hbase.master.procedure.MasterProcedureUtil; -124import org.apache.hadoop.hbase.master.procedure.ModifyColumnFamilyProcedure; -125import org.apache.hadoop.hbase.master.procedure.ModifyTableProcedure; -126import org.apache.hadoop.hbase.master.procedure.ProcedurePrepareLatch; -127import org.apache.hadoop.hbase.master.procedure.TruncateTableProcedure; -128import org.apache.hadoop.hbase.master.replication.ReplicationManager; -129import org.apache.hadoop.hbase.master.snapshot.SnapshotManager; -130import org.apache.hadoop.hbase.mob.MobConstants; -131import org.apache.hadoop.hbase.monitoring.MemoryBoundedLogMessageBuffer; -132import org.apache.hadoop.hbase.monitoring.MonitoredTask; -133import org.apache.hadoop.hbase.monitoring.TaskMonitor; -134import org.apache.hadoop.hbase.procedure.MasterProcedureManagerHost; -135import org.apache.hadoop.hbase.procedure.flush.MasterFlushTableProcedureManager; -136import org.apache.hadoop.hbase.procedure2.LockInfo; -137import org.apache.hadoop.hbase.procedure2.ProcedureEvent; -138import org.apache.hadoop.hbase.procedure2.ProcedureExecutor; -139import org.apache.hadoop.hbase.procedure2.store.wal.WALProcedureStore; -140import org.apache.hadoop.hbase.quotas.MasterQuotaManager; -141import org.apache.hadoop.hbase.quotas.MasterSpaceQuotaObserver; -142import org.apache.hadoop.hbase.quotas.QuotaObserverChore; -143import org.apache.hadoop.hbase.quotas.QuotaUtil; -144import org.apache.hadoop.hbase.quotas.SnapshotQuotaObserverChore; -145import org.apache.hadoop.hbase.quotas.SpaceQuotaSnapshotNotifier; -146import org.apache.hadoop.hbase.quotas.SpaceQuotaSnapshotNotifierFactory; -147import org.apache.hadoop.hbase.regionserver.DefaultStoreEngine; -148import org.apache.hadoop.hbase.regionserver.HRegionServer; -149import org.apache.hadoop.hbase.regionserver.HStore; -150import org.apache.hadoop.hbase.regionserver.RSRpcServices; -151import org.apache.hadoop.hbase.regionserver.RegionCoprocessorHost; -152import org.apache.hadoop.hbase.regionserver.RegionSplitPolicy; -153import org.apache.hadoop.hbase.regionserver.compactions.ExploringCompactionPolicy; -154import org.apache.hadoop.hbase.regionserver.compactions.FIFOCompactionPolicy; -155import org.apache.hadoop.hbase.replication.ReplicationException; -156import org.apache.hadoop.hbase.replication.ReplicationFactory; -157import org.apache.hadoop.hbase.replication.ReplicationPeerConfig; -158import org.apache.hadoop.hbase.replication.ReplicationPeerDescription; -159import org.apache.hadoop.hbase.replication.ReplicationQueuesZKImpl; -160import org.apache.hadoop.hbase.replication.master.TableCFsUpdater; -161import org.apache.hadoop.hbase.replication.regionserver.Replication; -162import org.apache.hadoop.hbase.security.AccessDeniedException; -163import org.apache.hadoop.hbase.security.UserProvider; -164import org.apache.hadoop.hbase.shaded.protobuf.ProtobufUtil; -165import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.GetRegionInfoResponse.CompactionState; -166import org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.RegionServerInfo; -167import org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.Quotas; -168import org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.SpaceViolationPolicy; -169import org.apache.hadoop.hbase.shaded.protobuf.generated.SnapshotProtos.SnapshotDescription; -170import org.apache.hadoop.hbase.shaded.protobuf.generated.WALProtos; -171import org.apache.hadoop.hbase.util.Addressing; -172import org.apache.hadoop.hbase.util.Bytes; -173import org.apache.hadoop.hbase.util.CompressionTest; -174import org.apache.hadoop.hbase.util.EncryptionTest; -175import org.apache.hadoop.hbase.util.FSUtils; -176import org.apache.hadoop.hbase.util.HFileArchiveUtil; -177import
[26/51] [partial] hbase-site git commit: Published site at 82d554e3783372cc6b05489452c815b57c06f6cd.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/0383a9c2/devapidocs/src-html/org/apache/hadoop/hbase/master/HMaster.InitializationMonitor.html -- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/master/HMaster.InitializationMonitor.html b/devapidocs/src-html/org/apache/hadoop/hbase/master/HMaster.InitializationMonitor.html index 5479fb1..49ef112 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/master/HMaster.InitializationMonitor.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/master/HMaster.InitializationMonitor.html @@ -123,3388 +123,3334 @@ 115import org.apache.hadoop.hbase.master.procedure.DeleteColumnFamilyProcedure; 116import org.apache.hadoop.hbase.master.procedure.DeleteTableProcedure; 117import org.apache.hadoop.hbase.master.procedure.DisableTableProcedure; -118import org.apache.hadoop.hbase.master.procedure.DispatchMergingRegionsProcedure; -119import org.apache.hadoop.hbase.master.procedure.EnableTableProcedure; -120import org.apache.hadoop.hbase.master.procedure.MasterProcedureConstants; -121import org.apache.hadoop.hbase.master.procedure.MasterProcedureEnv; -122import org.apache.hadoop.hbase.master.procedure.MasterProcedureScheduler; -123import org.apache.hadoop.hbase.master.procedure.MasterProcedureUtil; -124import org.apache.hadoop.hbase.master.procedure.ModifyColumnFamilyProcedure; -125import org.apache.hadoop.hbase.master.procedure.ModifyTableProcedure; -126import org.apache.hadoop.hbase.master.procedure.ProcedurePrepareLatch; -127import org.apache.hadoop.hbase.master.procedure.TruncateTableProcedure; -128import org.apache.hadoop.hbase.master.replication.ReplicationManager; -129import org.apache.hadoop.hbase.master.snapshot.SnapshotManager; -130import org.apache.hadoop.hbase.mob.MobConstants; -131import org.apache.hadoop.hbase.monitoring.MemoryBoundedLogMessageBuffer; -132import org.apache.hadoop.hbase.monitoring.MonitoredTask; -133import org.apache.hadoop.hbase.monitoring.TaskMonitor; -134import org.apache.hadoop.hbase.procedure.MasterProcedureManagerHost; -135import org.apache.hadoop.hbase.procedure.flush.MasterFlushTableProcedureManager; -136import org.apache.hadoop.hbase.procedure2.LockInfo; -137import org.apache.hadoop.hbase.procedure2.ProcedureEvent; -138import org.apache.hadoop.hbase.procedure2.ProcedureExecutor; -139import org.apache.hadoop.hbase.procedure2.store.wal.WALProcedureStore; -140import org.apache.hadoop.hbase.quotas.MasterQuotaManager; -141import org.apache.hadoop.hbase.quotas.MasterSpaceQuotaObserver; -142import org.apache.hadoop.hbase.quotas.QuotaObserverChore; -143import org.apache.hadoop.hbase.quotas.QuotaUtil; -144import org.apache.hadoop.hbase.quotas.SnapshotQuotaObserverChore; -145import org.apache.hadoop.hbase.quotas.SpaceQuotaSnapshotNotifier; -146import org.apache.hadoop.hbase.quotas.SpaceQuotaSnapshotNotifierFactory; -147import org.apache.hadoop.hbase.regionserver.DefaultStoreEngine; -148import org.apache.hadoop.hbase.regionserver.HRegionServer; -149import org.apache.hadoop.hbase.regionserver.HStore; -150import org.apache.hadoop.hbase.regionserver.RSRpcServices; -151import org.apache.hadoop.hbase.regionserver.RegionCoprocessorHost; -152import org.apache.hadoop.hbase.regionserver.RegionSplitPolicy; -153import org.apache.hadoop.hbase.regionserver.compactions.ExploringCompactionPolicy; -154import org.apache.hadoop.hbase.regionserver.compactions.FIFOCompactionPolicy; -155import org.apache.hadoop.hbase.replication.ReplicationException; -156import org.apache.hadoop.hbase.replication.ReplicationFactory; -157import org.apache.hadoop.hbase.replication.ReplicationPeerConfig; -158import org.apache.hadoop.hbase.replication.ReplicationPeerDescription; -159import org.apache.hadoop.hbase.replication.ReplicationQueuesZKImpl; -160import org.apache.hadoop.hbase.replication.master.TableCFsUpdater; -161import org.apache.hadoop.hbase.replication.regionserver.Replication; -162import org.apache.hadoop.hbase.security.AccessDeniedException; -163import org.apache.hadoop.hbase.security.UserProvider; -164import org.apache.hadoop.hbase.shaded.protobuf.ProtobufUtil; -165import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.GetRegionInfoResponse.CompactionState; -166import org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.RegionServerInfo; -167import org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.Quotas; -168import org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.SpaceViolationPolicy; -169import org.apache.hadoop.hbase.shaded.protobuf.generated.SnapshotProtos.SnapshotDescription; -170import org.apache.hadoop.hbase.shaded.protobuf.generated.WALProtos; -171import org.apache.hadoop.hbase.util.Addressing; -172import org.apache.hadoop.hbase.util.Bytes; -173import org.apache.hadoop.hbase.util.CompressionTest; -174import org.apache.hadoop.hbase.util.EncryptionTest; -175import
[51/51] [partial] hbase-site git commit: Published site at 82d554e3783372cc6b05489452c815b57c06f6cd.
Published site at 82d554e3783372cc6b05489452c815b57c06f6cd. Project: http://git-wip-us.apache.org/repos/asf/hbase-site/repo Commit: http://git-wip-us.apache.org/repos/asf/hbase-site/commit/0383a9c2 Tree: http://git-wip-us.apache.org/repos/asf/hbase-site/tree/0383a9c2 Diff: http://git-wip-us.apache.org/repos/asf/hbase-site/diff/0383a9c2 Branch: refs/heads/asf-site Commit: 0383a9c245ca6b9c8ffc03193a50252dcb1b044f Parents: dd9ff6c Author: jenkinsAuthored: Sun Jul 23 15:08:17 2017 + Committer: jenkins Committed: Sun Jul 23 15:08:17 2017 + -- acid-semantics.html | 4 +- apache_hbase_reference_guide.pdf| 6 +- apidocs/index-all.html | 2 - .../client/ShortCircuitMasterConnection.html| 144 +- .../client/ShortCircuitMasterConnection.html| 8 +- bulk-loads.html | 4 +- checkstyle-aggregate.html | 26076 - checkstyle.rss |28 +- coc.html| 4 +- cygwin.html | 4 +- dependencies.html | 4 +- dependency-convergence.html | 4 +- dependency-info.html| 4 +- dependency-management.html | 4 +- devapidocs/allclasses-frame.html| 1 - devapidocs/allclasses-noframe.html | 1 - devapidocs/constant-values.html | 6 +- devapidocs/index-all.html | 123 - .../hadoop/hbase/backup/package-tree.html | 2 +- .../hadoop/hbase/class-use/HRegionInfo.html |93 +- .../hadoop/hbase/class-use/RegionLoad.html |24 - .../hadoop/hbase/class-use/ServerName.html |67 +- .../hadoop/hbase/class-use/TableName.html |36 +- .../class-use/InterfaceAudience.Private.html|42 +- .../hbase/classification/package-tree.html | 6 +- .../hbase/client/ConnectionImplementation.html |50 +- .../hbase/client/MasterKeepAliveConnection.html | 2 +- .../client/ShortCircuitMasterConnection.html| 146 +- .../hadoop/hbase/client/package-tree.html |28 +- .../hadoop/hbase/filter/package-tree.html | 8 +- .../hadoop/hbase/io/hfile/package-tree.html | 8 +- .../hadoop/hbase/ipc/class-use/QosPriority.html |15 +- .../apache/hadoop/hbase/ipc/package-tree.html | 2 +- .../hadoop/hbase/mapreduce/package-tree.html| 2 +- .../master/HMaster.InitializationMonitor.html |20 +- .../hbase/master/HMaster.RedirectServlet.html |12 +- .../org/apache/hadoop/hbase/master/HMaster.html | 722 +- .../master/HMasterCommandLine.LocalHMaster.html | 2 +- ...terCoprocessorHost.CoprocessorOperation.html |10 +- ...ssorHost.CoprocessorOperationWithResult.html |10 +- .../hbase/master/MasterCoprocessorHost.html | 426 +- .../hadoop/hbase/master/MasterRpcServices.html | 174 +- .../hadoop/hbase/master/MasterServices.html | 197 +- .../hadoop/hbase/master/ServerManager.html | 124 +- .../assignment/class-use/AssignmentManager.html |19 - .../hbase/master/balancer/package-tree.html | 2 +- .../hadoop/hbase/master/package-tree.html | 6 +- .../AbstractStateMachineTableProcedure.html | 2 +- ...ableProcedure.MarkRegionOfflineOpResult.html | 4 +- .../DispatchMergingRegionsProcedure.html| 1118 - .../master/procedure/EnableTableProcedure.html | 4 +- .../procedure/TableProcedureInterface.html | 2 +- .../AbstractStateMachineTableProcedure.html |14 +- .../DispatchMergingRegionsProcedure.html| 125 - .../procedure/class-use/MasterProcedureEnv.html | 292 +- ...leProcedureInterface.TableOperationType.html |14 +- .../class-use/TableProcedureInterface.html |16 +- .../hbase/master/procedure/package-frame.html | 1 - .../hbase/master/procedure/package-summary.html |70 +- .../hbase/master/procedure/package-tree.html| 3 +- .../org/apache/hadoop/hbase/package-tree.html |12 +- .../org/apache/hadoop/hbase/package-use.html| 7 +- .../class-use/Procedure.LockState.html | 4 - .../hbase/procedure2/class-use/Procedure.html |18 +- .../class-use/StateMachineProcedure.Flow.html |17 +- .../class-use/StateMachineProcedure.html|18 +- .../hadoop/hbase/procedure2/package-tree.html | 2 +- .../hadoop/hbase/quotas/package-tree.html | 6 +- .../CompactSplit.CompactionRunner.html |28 +- .../regionserver/CompactSplit.Rejection.html| 6 +- .../hadoop/hbase/regionserver/CompactSplit.html | 105 +- .../regionserver/RSRpcServices.LogDelegate.html | 4 +-
[20/51] [partial] hbase-site git commit: Published site at 82d554e3783372cc6b05489452c815b57c06f6cd.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/0383a9c2/devapidocs/src-html/org/apache/hadoop/hbase/master/MasterCoprocessorHost.html -- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/master/MasterCoprocessorHost.html b/devapidocs/src-html/org/apache/hadoop/hbase/master/MasterCoprocessorHost.html index e690c2d..ec75aa9 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/master/MasterCoprocessorHost.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/master/MasterCoprocessorHost.html @@ -818,1092 +818,1070 @@ 810}); 811 } 812 -813 public void preDispatchMerge(final HRegionInfo regionInfoA, final HRegionInfo regionInfoB) -814 throws IOException { +813 public void preMergeRegions(final HRegionInfo[] regionsToMerge) +814 throws IOException { 815execOperation(coprocessors.isEmpty() ? null : new CoprocessorOperation() { 816 @Override 817 public void call(MasterObserver oserver, ObserverContextMasterCoprocessorEnvironment ctx) 818 throws IOException { -819oserver.preDispatchMerge(ctx, regionInfoA, regionInfoB); +819oserver.preMergeRegions(ctx, regionsToMerge); 820 } 821}); 822 } 823 -824 public void postDispatchMerge(final HRegionInfo regionInfoA, final HRegionInfo regionInfoB) -825 throws IOException { +824 public void postMergeRegions(final HRegionInfo[] regionsToMerge) +825 throws IOException { 826execOperation(coprocessors.isEmpty() ? null : new CoprocessorOperation() { 827 @Override 828 public void call(MasterObserver oserver, ObserverContextMasterCoprocessorEnvironment ctx) 829 throws IOException { -830oserver.postDispatchMerge(ctx, regionInfoA, regionInfoB); +830oserver.postMergeRegions(ctx, regionsToMerge); 831 } 832}); 833 } 834 -835 public void preMergeRegions(final HRegionInfo[] regionsToMerge) -836 throws IOException { -837execOperation(coprocessors.isEmpty() ? null : new CoprocessorOperation() { -838 @Override -839 public void call(MasterObserver oserver, ObserverContextMasterCoprocessorEnvironment ctx) -840 throws IOException { -841oserver.preMergeRegions(ctx, regionsToMerge); -842 } -843}); -844 } -845 -846 public void postMergeRegions(final HRegionInfo[] regionsToMerge) -847 throws IOException { -848execOperation(coprocessors.isEmpty() ? null : new CoprocessorOperation() { -849 @Override -850 public void call(MasterObserver oserver, ObserverContextMasterCoprocessorEnvironment ctx) -851 throws IOException { -852oserver.postMergeRegions(ctx, regionsToMerge); -853 } -854}); -855 } -856 -857 public boolean preBalance() throws IOException { -858return execOperation(coprocessors.isEmpty() ? null : new CoprocessorOperation() { -859 @Override -860 public void call(MasterObserver oserver, ObserverContextMasterCoprocessorEnvironment ctx) -861 throws IOException { -862oserver.preBalance(ctx); -863 } -864}); -865 } -866 -867 public void postBalance(final ListRegionPlan plans) throws IOException { +835 public boolean preBalance() throws IOException { +836return execOperation(coprocessors.isEmpty() ? null : new CoprocessorOperation() { +837 @Override +838 public void call(MasterObserver oserver, ObserverContextMasterCoprocessorEnvironment ctx) +839 throws IOException { +840oserver.preBalance(ctx); +841 } +842}); +843 } +844 +845 public void postBalance(final ListRegionPlan plans) throws IOException { +846execOperation(coprocessors.isEmpty() ? null : new CoprocessorOperation() { +847 @Override +848 public void call(MasterObserver oserver, ObserverContextMasterCoprocessorEnvironment ctx) +849 throws IOException { +850oserver.postBalance(ctx, plans); +851 } +852}); +853 } +854 +855 public boolean preSetSplitOrMergeEnabled(final boolean newValue, +856 final MasterSwitchType switchType) throws IOException { +857return execOperation(coprocessors.isEmpty() ? null : new CoprocessorOperation() { +858 @Override +859 public void call(MasterObserver oserver, ObserverContextMasterCoprocessorEnvironment ctx) +860 throws IOException { +861 oserver.preSetSplitOrMergeEnabled(ctx, newValue, switchType); +862 } +863}); +864 } +865 +866 public void postSetSplitOrMergeEnabled(final boolean newValue, +867 final MasterSwitchType switchType) throws IOException { 868execOperation(coprocessors.isEmpty() ? null : new CoprocessorOperation() { 869 @Override 870 public void call(MasterObserver oserver, ObserverContextMasterCoprocessorEnvironment ctx) 871 throws IOException { -872oserver.postBalance(ctx, plans); +872 oserver.postSetSplitOrMergeEnabled(ctx,
[05/51] [partial] hbase-site git commit: Published site at 82d554e3783372cc6b05489452c815b57c06f6cd.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/0383a9c2/hbase-archetypes/hbase-client-project/license.html -- diff --git a/hbase-archetypes/hbase-client-project/license.html b/hbase-archetypes/hbase-client-project/license.html index 1b0e200..c397b94 100644 --- a/hbase-archetypes/hbase-client-project/license.html +++ b/hbase-archetypes/hbase-client-project/license.html @@ -1,5 +1,5 @@ http://www.w3.org/TR/xhtml1/DTD/xhtml1-transitional.dtd;> - + http://www.w3.org/1999/xhtml; xml:lang="en" lang="en"> @@ -10,7 +10,7 @@ @import url("./css/site.css"); - + @@ -27,7 +27,7 @@ -Last Published: 2017-07-22 +Last Published: 2017-07-23 | Version: 3.0.0-SNAPSHOT Apache HBase - Exemplar for hbase-client archetype @@ -117,7 +117,210 @@ Project Licenses Apache License, Version 2.0 -Can't read the url [https://www.apache.org/licenses/LICENSE-2.0.txt] : connect timed out + + + Apache License + Version 2.0, January 2004 +http://www.apache.org/licenses/ + + TERMS AND CONDITIONS FOR USE, REPRODUCTION, AND DISTRIBUTION + + 1. Definitions. + + License shall mean the terms and conditions for use, reproduction, + and distribution as defined by Sections 1 through 9 of this document. + + Licensor shall mean the copyright owner or entity authorized by + the copyright owner that is granting the License. + + Legal Entity shall mean the union of the acting entity and all + other entities that control, are controlled by, or are under common + control with that entity. For the purposes of this definition, + control means (i) the power, direct or indirect, to cause the + direction or management of such entity, whether by contract or + otherwise, or (ii) ownership of fifty percent (50%) or more of the + outstanding shares, or (iii) beneficial ownership of such entity. + + You (or Your) shall mean an individual or Legal Entity + exercising permissions granted by this License. + + Source form shall mean the preferred form for making modifications, + including but not limited to software source code, documentation + source, and configuration files. + + Object form shall mean any form resulting from mechanical + transformation or translation of a Source form, including but + not limited to compiled object code, generated documentation, + and conversions to other media types. + + Work shall mean the work of authorship, whether in Source or + Object form, made available under the License, as indicated by a + copyright notice that is included in or attached to the work + (an example is provided in the Appendix below). + + Derivative Works shall mean any work, whether in Source or Object + form, that is based on (or derived from) the Work and for which the + editorial revisions, annotations, elaborations, or other modifications + represent, as a whole, an original work of authorship. For the purposes + of this License, Derivative Works shall not include works that remain + separable from, or merely link (or bind by name) to the interfaces of, + the Work and Derivative Works thereof. + + Contribution shall mean any work of authorship, including + the original version of the Work and any modifications or additions + to that Work or Derivative Works thereof, that is intentionally + submitted to Licensor for inclusion in the Work by the copyright owner + or by an individual or Legal Entity authorized to submit on behalf of + the copyright owner. For the purposes of this definition, submitted + means any form of electronic, verbal, or written communication sent + to the Licensor or its representatives, including but not limited to + communication on electronic mailing lists, source code control systems, + and issue tracking systems that are managed by, or on behalf of, the + Licensor for the purpose of discussing and improving the Work, but + excluding communication that is conspicuously marked or otherwise + designated in writing by the copyright owner as Not a Contribution. + + Contributor shall mean Licensor and any individual or Legal Entity + on behalf of whom a Contribution has been received by Licensor and + subsequently incorporated within the Work. + + 2. Grant of Copyright License. Subject to the terms and conditions of + this License, each Contributor hereby grants to You a perpetual, + worldwide, non-exclusive, no-charge, royalty-free, irrevocable + copyright license to reproduce, prepare Derivative Works of, +
[46/51] [partial] hbase-site git commit: Published site at 82d554e3783372cc6b05489452c815b57c06f6cd.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/0383a9c2/devapidocs/org/apache/hadoop/hbase/client/package-tree.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/client/package-tree.html b/devapidocs/org/apache/hadoop/hbase/client/package-tree.html index ce30fbb..2ff25e3 100644 --- a/devapidocs/org/apache/hadoop/hbase/client/package-tree.html +++ b/devapidocs/org/apache/hadoop/hbase/client/package-tree.html @@ -538,25 +538,25 @@ java.lang.http://docs.oracle.com/javase/8/docs/api/java/lang/Enum.html?is-external=true; title="class or interface in java.lang">EnumE (implements java.lang.http://docs.oracle.com/javase/8/docs/api/java/lang/Comparable.html?is-external=true; title="class or interface in java.lang">ComparableT, java.io.http://docs.oracle.com/javase/8/docs/api/java/io/Serializable.html?is-external=true; title="class or interface in java.io">Serializable) -org.apache.hadoop.hbase.client.MasterSwitchType -org.apache.hadoop.hbase.client.CompactType -org.apache.hadoop.hbase.client.TableState.State -org.apache.hadoop.hbase.client.AbstractResponse.ResponseType -org.apache.hadoop.hbase.client.AsyncProcessTask.SubmittedRows -org.apache.hadoop.hbase.client.MobCompactPartitionPolicy +org.apache.hadoop.hbase.client.ScannerCallable.MoreResults +org.apache.hadoop.hbase.client.Consistency org.apache.hadoop.hbase.client.AsyncScanSingleRegionRpcRetryingCaller.ScanResumerState +org.apache.hadoop.hbase.client.AbstractResponse.ResponseType +org.apache.hadoop.hbase.client.CompactionState +org.apache.hadoop.hbase.client.RegionLocateType org.apache.hadoop.hbase.client.Durability -org.apache.hadoop.hbase.client.AsyncScanSingleRegionRpcRetryingCaller.ScanControllerState -org.apache.hadoop.hbase.client.Consistency org.apache.hadoop.hbase.client.IsolationLevel -org.apache.hadoop.hbase.client.RegionLocateType -org.apache.hadoop.hbase.client.SnapshotType -org.apache.hadoop.hbase.client.CompactionState -org.apache.hadoop.hbase.client.ScannerCallable.MoreResults -org.apache.hadoop.hbase.client.AsyncRequestFutureImpl.Retry -org.apache.hadoop.hbase.client.RequestController.ReturnCode +org.apache.hadoop.hbase.client.MasterSwitchType +org.apache.hadoop.hbase.client.AsyncProcessTask.SubmittedRows +org.apache.hadoop.hbase.client.CompactType org.apache.hadoop.hbase.client.Scan.ReadType +org.apache.hadoop.hbase.client.AsyncScanSingleRegionRpcRetryingCaller.ScanControllerState +org.apache.hadoop.hbase.client.MobCompactPartitionPolicy +org.apache.hadoop.hbase.client.RequestController.ReturnCode +org.apache.hadoop.hbase.client.SnapshotType org.apache.hadoop.hbase.client.HBaseAdmin.ReplicationState +org.apache.hadoop.hbase.client.TableState.State +org.apache.hadoop.hbase.client.AsyncRequestFutureImpl.Retry http://git-wip-us.apache.org/repos/asf/hbase-site/blob/0383a9c2/devapidocs/org/apache/hadoop/hbase/filter/package-tree.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/filter/package-tree.html b/devapidocs/org/apache/hadoop/hbase/filter/package-tree.html index 4c7f64d..8c82f05 100644 --- a/devapidocs/org/apache/hadoop/hbase/filter/package-tree.html +++ b/devapidocs/org/apache/hadoop/hbase/filter/package-tree.html @@ -175,14 +175,14 @@ java.lang.http://docs.oracle.com/javase/8/docs/api/java/lang/Enum.html?is-external=true; title="class or interface in java.lang">EnumE (implements java.lang.http://docs.oracle.com/javase/8/docs/api/java/lang/Comparable.html?is-external=true; title="class or interface in java.lang">ComparableT, java.io.http://docs.oracle.com/javase/8/docs/api/java/io/Serializable.html?is-external=true; title="class or interface in java.io">Serializable) -org.apache.hadoop.hbase.filter.CompareFilter.CompareOp -org.apache.hadoop.hbase.filter.FuzzyRowFilter.SatisfiesCode +org.apache.hadoop.hbase.filter.RegexStringComparator.EngineType org.apache.hadoop.hbase.filter.BitComparator.BitwiseOp -org.apache.hadoop.hbase.filter.FuzzyRowFilter.Order org.apache.hadoop.hbase.filter.FilterWrapper.FilterRowRetCode -org.apache.hadoop.hbase.filter.RegexStringComparator.EngineType org.apache.hadoop.hbase.filter.Filter.ReturnCode +org.apache.hadoop.hbase.filter.FuzzyRowFilter.Order org.apache.hadoop.hbase.filter.FilterList.Operator +org.apache.hadoop.hbase.filter.FuzzyRowFilter.SatisfiesCode +org.apache.hadoop.hbase.filter.CompareFilter.CompareOp http://git-wip-us.apache.org/repos/asf/hbase-site/blob/0383a9c2/devapidocs/org/apache/hadoop/hbase/io/hfile/package-tree.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/io/hfile/package-tree.html b/devapidocs/org/apache/hadoop/hbase/io/hfile/package-tree.html index 9d8e5cd..62b4bbc 100644 --- a/devapidocs/org/apache/hadoop/hbase/io/hfile/package-tree.html +++ b/devapidocs/org/apache/hadoop/hbase/io/hfile/package-tree.html @@ -273,12
[09/51] [partial] hbase-site git commit: Published site at 82d554e3783372cc6b05489452c815b57c06f6cd.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/0383a9c2/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RSRpcServices.RegionScannersCloseCallBack.html -- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RSRpcServices.RegionScannersCloseCallBack.html b/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RSRpcServices.RegionScannersCloseCallBack.html index a945b54..422c076 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RSRpcServices.RegionScannersCloseCallBack.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RSRpcServices.RegionScannersCloseCallBack.html @@ -92,3454 +92,3410 @@ 084import org.apache.hadoop.hbase.client.VersionInfoUtil; 085import org.apache.hadoop.hbase.conf.ConfigurationObserver; 086import org.apache.hadoop.hbase.exceptions.FailedSanityCheckException; -087import org.apache.hadoop.hbase.exceptions.MergeRegionException; -088import org.apache.hadoop.hbase.exceptions.OutOfOrderScannerNextException; -089import org.apache.hadoop.hbase.exceptions.ScannerResetException; -090import org.apache.hadoop.hbase.filter.ByteArrayComparable; -091import org.apache.hadoop.hbase.filter.CompareFilter.CompareOp; -092import org.apache.hadoop.hbase.ipc.HBaseRPCErrorHandler; -093import org.apache.hadoop.hbase.ipc.HBaseRpcController; -094import org.apache.hadoop.hbase.ipc.PriorityFunction; -095import org.apache.hadoop.hbase.ipc.QosPriority; -096import org.apache.hadoop.hbase.ipc.RpcCallContext; -097import org.apache.hadoop.hbase.ipc.RpcCallback; -098import org.apache.hadoop.hbase.ipc.RpcServer; -099import org.apache.hadoop.hbase.ipc.RpcServer.BlockingServiceAndInterface; -100import org.apache.hadoop.hbase.ipc.RpcServerFactory; -101import org.apache.hadoop.hbase.ipc.RpcServerInterface; -102import org.apache.hadoop.hbase.ipc.ServerNotRunningYetException; -103import org.apache.hadoop.hbase.ipc.ServerRpcController; -104import org.apache.hadoop.hbase.master.MasterRpcServices; -105import org.apache.hadoop.hbase.quotas.ActivePolicyEnforcement; -106import org.apache.hadoop.hbase.quotas.OperationQuota; -107import org.apache.hadoop.hbase.quotas.QuotaUtil; -108import org.apache.hadoop.hbase.quotas.RegionServerRpcQuotaManager; -109import org.apache.hadoop.hbase.quotas.RegionServerSpaceQuotaManager; -110import org.apache.hadoop.hbase.quotas.SpaceQuotaSnapshot; -111import org.apache.hadoop.hbase.quotas.SpaceViolationPolicyEnforcement; -112import org.apache.hadoop.hbase.regionserver.HRegion.RegionScannerImpl; -113import org.apache.hadoop.hbase.regionserver.Leases.Lease; -114import org.apache.hadoop.hbase.regionserver.Leases.LeaseStillHeldException; -115import org.apache.hadoop.hbase.regionserver.Region.Operation; -116import org.apache.hadoop.hbase.regionserver.ScannerContext.LimitScope; -117import org.apache.hadoop.hbase.regionserver.handler.OpenMetaHandler; -118import org.apache.hadoop.hbase.regionserver.handler.OpenPriorityRegionHandler; -119import org.apache.hadoop.hbase.regionserver.handler.OpenRegionHandler; -120import org.apache.hadoop.hbase.regionserver.wal.WALEdit; -121import org.apache.hadoop.hbase.security.Superusers; -122import org.apache.hadoop.hbase.security.User; -123import org.apache.hadoop.hbase.shaded.com.google.protobuf.ByteString; -124import org.apache.hadoop.hbase.shaded.com.google.protobuf.Message; -125import org.apache.hadoop.hbase.shaded.com.google.protobuf.RpcController; -126import org.apache.hadoop.hbase.shaded.com.google.protobuf.ServiceException; -127import org.apache.hadoop.hbase.shaded.com.google.protobuf.TextFormat; -128import org.apache.hadoop.hbase.shaded.com.google.protobuf.UnsafeByteOperations; -129import org.apache.hadoop.hbase.shaded.protobuf.ProtobufUtil; -130import org.apache.hadoop.hbase.shaded.protobuf.RequestConverter; -131import org.apache.hadoop.hbase.shaded.protobuf.ResponseConverter; -132import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.AdminService; -133import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.ClearCompactionQueuesRequest; -134import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.ClearCompactionQueuesResponse; -135import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CloseRegionRequest; -136import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CloseRegionResponse; -137import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CompactRegionRequest; -138import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CompactRegionResponse; -139import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.ExecuteProceduresRequest; -140import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.ExecuteProceduresResponse; -141import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.FlushRegionRequest; -142import
[08/51] [partial] hbase-site git commit: Published site at 82d554e3783372cc6b05489452c815b57c06f6cd.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/0383a9c2/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RSRpcServices.ScannerListener.html -- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RSRpcServices.ScannerListener.html b/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RSRpcServices.ScannerListener.html index a945b54..422c076 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RSRpcServices.ScannerListener.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RSRpcServices.ScannerListener.html @@ -92,3454 +92,3410 @@ 084import org.apache.hadoop.hbase.client.VersionInfoUtil; 085import org.apache.hadoop.hbase.conf.ConfigurationObserver; 086import org.apache.hadoop.hbase.exceptions.FailedSanityCheckException; -087import org.apache.hadoop.hbase.exceptions.MergeRegionException; -088import org.apache.hadoop.hbase.exceptions.OutOfOrderScannerNextException; -089import org.apache.hadoop.hbase.exceptions.ScannerResetException; -090import org.apache.hadoop.hbase.filter.ByteArrayComparable; -091import org.apache.hadoop.hbase.filter.CompareFilter.CompareOp; -092import org.apache.hadoop.hbase.ipc.HBaseRPCErrorHandler; -093import org.apache.hadoop.hbase.ipc.HBaseRpcController; -094import org.apache.hadoop.hbase.ipc.PriorityFunction; -095import org.apache.hadoop.hbase.ipc.QosPriority; -096import org.apache.hadoop.hbase.ipc.RpcCallContext; -097import org.apache.hadoop.hbase.ipc.RpcCallback; -098import org.apache.hadoop.hbase.ipc.RpcServer; -099import org.apache.hadoop.hbase.ipc.RpcServer.BlockingServiceAndInterface; -100import org.apache.hadoop.hbase.ipc.RpcServerFactory; -101import org.apache.hadoop.hbase.ipc.RpcServerInterface; -102import org.apache.hadoop.hbase.ipc.ServerNotRunningYetException; -103import org.apache.hadoop.hbase.ipc.ServerRpcController; -104import org.apache.hadoop.hbase.master.MasterRpcServices; -105import org.apache.hadoop.hbase.quotas.ActivePolicyEnforcement; -106import org.apache.hadoop.hbase.quotas.OperationQuota; -107import org.apache.hadoop.hbase.quotas.QuotaUtil; -108import org.apache.hadoop.hbase.quotas.RegionServerRpcQuotaManager; -109import org.apache.hadoop.hbase.quotas.RegionServerSpaceQuotaManager; -110import org.apache.hadoop.hbase.quotas.SpaceQuotaSnapshot; -111import org.apache.hadoop.hbase.quotas.SpaceViolationPolicyEnforcement; -112import org.apache.hadoop.hbase.regionserver.HRegion.RegionScannerImpl; -113import org.apache.hadoop.hbase.regionserver.Leases.Lease; -114import org.apache.hadoop.hbase.regionserver.Leases.LeaseStillHeldException; -115import org.apache.hadoop.hbase.regionserver.Region.Operation; -116import org.apache.hadoop.hbase.regionserver.ScannerContext.LimitScope; -117import org.apache.hadoop.hbase.regionserver.handler.OpenMetaHandler; -118import org.apache.hadoop.hbase.regionserver.handler.OpenPriorityRegionHandler; -119import org.apache.hadoop.hbase.regionserver.handler.OpenRegionHandler; -120import org.apache.hadoop.hbase.regionserver.wal.WALEdit; -121import org.apache.hadoop.hbase.security.Superusers; -122import org.apache.hadoop.hbase.security.User; -123import org.apache.hadoop.hbase.shaded.com.google.protobuf.ByteString; -124import org.apache.hadoop.hbase.shaded.com.google.protobuf.Message; -125import org.apache.hadoop.hbase.shaded.com.google.protobuf.RpcController; -126import org.apache.hadoop.hbase.shaded.com.google.protobuf.ServiceException; -127import org.apache.hadoop.hbase.shaded.com.google.protobuf.TextFormat; -128import org.apache.hadoop.hbase.shaded.com.google.protobuf.UnsafeByteOperations; -129import org.apache.hadoop.hbase.shaded.protobuf.ProtobufUtil; -130import org.apache.hadoop.hbase.shaded.protobuf.RequestConverter; -131import org.apache.hadoop.hbase.shaded.protobuf.ResponseConverter; -132import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.AdminService; -133import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.ClearCompactionQueuesRequest; -134import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.ClearCompactionQueuesResponse; -135import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CloseRegionRequest; -136import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CloseRegionResponse; -137import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CompactRegionRequest; -138import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CompactRegionResponse; -139import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.ExecuteProceduresRequest; -140import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.ExecuteProceduresResponse; -141import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.FlushRegionRequest; -142import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.FlushRegionResponse; -143import
[42/51] [partial] hbase-site git commit: Published site at 82d554e3783372cc6b05489452c815b57c06f6cd.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/0383a9c2/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 25f9006..6d90343 100644 --- a/devapidocs/org/apache/hadoop/hbase/master/MasterRpcServices.html +++ b/devapidocs/org/apache/hadoop/hbase/master/MasterRpcServices.html @@ -18,7 +18,7 @@ catch(err) { } //--> -var methods = {"i0":10,"i1":10,"i2":10,"i3":10,"i4":10,"i5":10,"i6":10,"i7":10,"i8":10,"i9":10,"i10":10,"i11":10,"i12":10,"i13":10,"i14":10,"i15":10,"i16":10,"i17":10,"i18":10,"i19":10,"i20":10,"i21":10,"i22":10,"i23":10,"i24":10,"i25":10,"i26":10,"i27":10,"i28":10,"i29":10,"i30":10,"i31":10,"i32":10,"i33":10,"i34":10,"i35":10,"i36":10,"i37":10,"i38":10,"i39":10,"i40":10,"i41":10,"i42":10,"i43":10,"i44":10,"i45":10,"i46":10,"i47":10,"i48":10,"i49":10,"i50":10,"i51":10,"i52":10,"i53":10,"i54":10,"i55":10,"i56":10,"i57":10,"i58":10,"i59":10,"i60":10,"i61":10,"i62":10,"i63":10,"i64":10,"i65":10,"i66":10,"i67":10,"i68":10,"i69":10,"i70":10,"i71":10,"i72":10,"i73":10,"i74":10,"i75":10,"i76":10,"i77":10,"i78":10,"i79":10,"i80":10,"i81":10,"i82":10,"i83":10,"i84":10,"i85":10,"i86":10,"i87":10,"i88":10,"i89":10,"i90":10,"i91":10,"i92":10,"i93":10}; +var methods = {"i0":10,"i1":10,"i2":10,"i3":10,"i4":10,"i5":10,"i6":10,"i7":10,"i8":10,"i9":10,"i10":10,"i11":10,"i12":10,"i13":10,"i14":10,"i15":10,"i16":10,"i17":10,"i18":10,"i19":10,"i20":10,"i21":10,"i22":10,"i23":10,"i24":10,"i25":10,"i26":10,"i27":10,"i28":10,"i29":10,"i30":10,"i31":10,"i32":10,"i33":10,"i34":10,"i35":10,"i36":10,"i37":10,"i38":10,"i39":10,"i40":10,"i41":10,"i42":10,"i43":10,"i44":10,"i45":10,"i46":10,"i47":10,"i48":10,"i49":10,"i50":10,"i51":10,"i52":10,"i53":10,"i54":10,"i55":10,"i56":10,"i57":10,"i58":10,"i59":10,"i60":10,"i61":10,"i62":10,"i63":10,"i64":10,"i65":10,"i66":10,"i67":10,"i68":10,"i69":10,"i70":10,"i71":10,"i72":10,"i73":10,"i74":10,"i75":10,"i76":10,"i77":10,"i78":10,"i79":10,"i80":10,"i81":10,"i82":10,"i83":10,"i84":10,"i85":10,"i86":10,"i87":10,"i88":10,"i89":10,"i90":10,"i91":10,"i92":10}; var tabs = {65535:["t0","All Methods"],2:["t2","Instance Methods"],8:["t4","Concrete Methods"]}; var altColor = "altColor"; var rowColor = "rowColor"; @@ -306,43 +306,38 @@ implements org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.Master org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.DisableTableRequestrequest) -org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.DispatchMergingRegionsResponse -dispatchMergingRegions(org.apache.hadoop.hbase.shaded.com.google.protobuf.RpcControllercontroller, - org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.DispatchMergingRegionsRequestrequest) - - org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.DrainRegionServersResponse drainRegionServers(org.apache.hadoop.hbase.shaded.com.google.protobuf.RpcControllercontroller, org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.DrainRegionServersRequestrequest) - + org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.EnableCatalogJanitorResponse enableCatalogJanitor(org.apache.hadoop.hbase.shaded.com.google.protobuf.RpcControllerc, org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.EnableCatalogJanitorRequestreq) - + org.apache.hadoop.hbase.shaded.protobuf.generated.ReplicationProtos.EnableReplicationPeerResponse enableReplicationPeer(org.apache.hadoop.hbase.shaded.com.google.protobuf.RpcControllercontroller, org.apache.hadoop.hbase.shaded.protobuf.generated.ReplicationProtos.EnableReplicationPeerRequestrequest) - + org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.EnableTableResponse enableTable(org.apache.hadoop.hbase.shaded.com.google.protobuf.RpcControllercontroller, org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.EnableTableRequestrequest) - + org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.CoprocessorServiceResponse execMasterService(org.apache.hadoop.hbase.shaded.com.google.protobuf.RpcControllercontroller, org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.CoprocessorServiceRequestrequest) - + org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.ExecProcedureResponse execProcedure(org.apache.hadoop.hbase.shaded.com.google.protobuf.RpcControllercontroller, org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.ExecProcedureRequestrequest) Triggers an asynchronous attempt to run a distributed procedure. - + org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.ExecProcedureResponse
[29/51] [partial] hbase-site git commit: Published site at 82d554e3783372cc6b05489452c815b57c06f6cd.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/0383a9c2/devapidocs/src-html/org/apache/hadoop/hbase/client/ConnectionImplementation.ServerErrorTracker.html -- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/client/ConnectionImplementation.ServerErrorTracker.html b/devapidocs/src-html/org/apache/hadoop/hbase/client/ConnectionImplementation.ServerErrorTracker.html index 6c200a1..e6f8c2e 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/client/ConnectionImplementation.ServerErrorTracker.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/client/ConnectionImplementation.ServerErrorTracker.html @@ -1350,726 +1350,719 @@ 1342 } 1343 1344 @Override -1345 public MasterProtos.DispatchMergingRegionsResponse dispatchMergingRegions( -1346 RpcController controller, MasterProtos.DispatchMergingRegionsRequest request) -1347 throws ServiceException { -1348return stub.dispatchMergingRegions(controller, request); -1349 } -1350 -1351 @Override -1352 public MasterProtos.AssignRegionResponse assignRegion(RpcController controller, -1353 MasterProtos.AssignRegionRequest request) throws ServiceException { -1354return stub.assignRegion(controller, request); -1355 } -1356 -1357 @Override -1358 public MasterProtos.UnassignRegionResponse unassignRegion(RpcController controller, -1359 MasterProtos.UnassignRegionRequest request) throws ServiceException { -1360return stub.unassignRegion(controller, request); -1361 } -1362 -1363 @Override -1364 public MasterProtos.OfflineRegionResponse offlineRegion(RpcController controller, -1365 MasterProtos.OfflineRegionRequest request) throws ServiceException { -1366return stub.offlineRegion(controller, request); -1367 } -1368 -1369 @Override -1370 public MasterProtos.SplitTableRegionResponse splitRegion(RpcController controller, -1371 MasterProtos.SplitTableRegionRequest request) throws ServiceException { -1372return stub.splitRegion(controller, request); -1373 } -1374 -1375 @Override -1376 public MasterProtos.DeleteTableResponse deleteTable(RpcController controller, -1377 MasterProtos.DeleteTableRequest request) throws ServiceException { -1378return stub.deleteTable(controller, request); -1379 } -1380 -1381 @Override -1382 public MasterProtos.TruncateTableResponse truncateTable(RpcController controller, -1383 MasterProtos.TruncateTableRequest request) throws ServiceException { -1384return stub.truncateTable(controller, request); -1385 } -1386 -1387 @Override -1388 public MasterProtos.EnableTableResponse enableTable(RpcController controller, -1389 MasterProtos.EnableTableRequest request) throws ServiceException { -1390return stub.enableTable(controller, request); -1391 } -1392 -1393 @Override -1394 public MasterProtos.DisableTableResponse disableTable(RpcController controller, -1395 MasterProtos.DisableTableRequest request) throws ServiceException { -1396return stub.disableTable(controller, request); -1397 } -1398 -1399 @Override -1400 public MasterProtos.ModifyTableResponse modifyTable(RpcController controller, -1401 MasterProtos.ModifyTableRequest request) throws ServiceException { -1402return stub.modifyTable(controller, request); -1403 } -1404 -1405 @Override -1406 public MasterProtos.CreateTableResponse createTable(RpcController controller, -1407 MasterProtos.CreateTableRequest request) throws ServiceException { -1408return stub.createTable(controller, request); -1409 } -1410 -1411 @Override -1412 public MasterProtos.ShutdownResponse shutdown(RpcController controller, -1413 MasterProtos.ShutdownRequest request) throws ServiceException { -1414return stub.shutdown(controller, request); -1415 } -1416 -1417 @Override -1418 public MasterProtos.StopMasterResponse stopMaster(RpcController controller, -1419 MasterProtos.StopMasterRequest request) throws ServiceException { -1420return stub.stopMaster(controller, request); +1345 public MasterProtos.AssignRegionResponse assignRegion(RpcController controller, +1346 MasterProtos.AssignRegionRequest request) throws ServiceException { +1347return stub.assignRegion(controller, request); +1348 } +1349 +1350 @Override +1351 public MasterProtos.UnassignRegionResponse unassignRegion(RpcController controller, +1352 MasterProtos.UnassignRegionRequest request) throws ServiceException { +1353return stub.unassignRegion(controller, request); +1354 } +1355 +1356 @Override +1357 public MasterProtos.OfflineRegionResponse
[30/51] [partial] hbase-site git commit: Published site at 82d554e3783372cc6b05489452c815b57c06f6cd.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/0383a9c2/devapidocs/src-html/org/apache/hadoop/hbase/client/ConnectionImplementation.ServerErrorTracker.ServerErrors.html -- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/client/ConnectionImplementation.ServerErrorTracker.ServerErrors.html b/devapidocs/src-html/org/apache/hadoop/hbase/client/ConnectionImplementation.ServerErrorTracker.ServerErrors.html index 6c200a1..e6f8c2e 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/client/ConnectionImplementation.ServerErrorTracker.ServerErrors.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/client/ConnectionImplementation.ServerErrorTracker.ServerErrors.html @@ -1350,726 +1350,719 @@ 1342 } 1343 1344 @Override -1345 public MasterProtos.DispatchMergingRegionsResponse dispatchMergingRegions( -1346 RpcController controller, MasterProtos.DispatchMergingRegionsRequest request) -1347 throws ServiceException { -1348return stub.dispatchMergingRegions(controller, request); -1349 } -1350 -1351 @Override -1352 public MasterProtos.AssignRegionResponse assignRegion(RpcController controller, -1353 MasterProtos.AssignRegionRequest request) throws ServiceException { -1354return stub.assignRegion(controller, request); -1355 } -1356 -1357 @Override -1358 public MasterProtos.UnassignRegionResponse unassignRegion(RpcController controller, -1359 MasterProtos.UnassignRegionRequest request) throws ServiceException { -1360return stub.unassignRegion(controller, request); -1361 } -1362 -1363 @Override -1364 public MasterProtos.OfflineRegionResponse offlineRegion(RpcController controller, -1365 MasterProtos.OfflineRegionRequest request) throws ServiceException { -1366return stub.offlineRegion(controller, request); -1367 } -1368 -1369 @Override -1370 public MasterProtos.SplitTableRegionResponse splitRegion(RpcController controller, -1371 MasterProtos.SplitTableRegionRequest request) throws ServiceException { -1372return stub.splitRegion(controller, request); -1373 } -1374 -1375 @Override -1376 public MasterProtos.DeleteTableResponse deleteTable(RpcController controller, -1377 MasterProtos.DeleteTableRequest request) throws ServiceException { -1378return stub.deleteTable(controller, request); -1379 } -1380 -1381 @Override -1382 public MasterProtos.TruncateTableResponse truncateTable(RpcController controller, -1383 MasterProtos.TruncateTableRequest request) throws ServiceException { -1384return stub.truncateTable(controller, request); -1385 } -1386 -1387 @Override -1388 public MasterProtos.EnableTableResponse enableTable(RpcController controller, -1389 MasterProtos.EnableTableRequest request) throws ServiceException { -1390return stub.enableTable(controller, request); -1391 } -1392 -1393 @Override -1394 public MasterProtos.DisableTableResponse disableTable(RpcController controller, -1395 MasterProtos.DisableTableRequest request) throws ServiceException { -1396return stub.disableTable(controller, request); -1397 } -1398 -1399 @Override -1400 public MasterProtos.ModifyTableResponse modifyTable(RpcController controller, -1401 MasterProtos.ModifyTableRequest request) throws ServiceException { -1402return stub.modifyTable(controller, request); -1403 } -1404 -1405 @Override -1406 public MasterProtos.CreateTableResponse createTable(RpcController controller, -1407 MasterProtos.CreateTableRequest request) throws ServiceException { -1408return stub.createTable(controller, request); -1409 } -1410 -1411 @Override -1412 public MasterProtos.ShutdownResponse shutdown(RpcController controller, -1413 MasterProtos.ShutdownRequest request) throws ServiceException { -1414return stub.shutdown(controller, request); -1415 } -1416 -1417 @Override -1418 public MasterProtos.StopMasterResponse stopMaster(RpcController controller, -1419 MasterProtos.StopMasterRequest request) throws ServiceException { -1420return stub.stopMaster(controller, request); +1345 public MasterProtos.AssignRegionResponse assignRegion(RpcController controller, +1346 MasterProtos.AssignRegionRequest request) throws ServiceException { +1347return stub.assignRegion(controller, request); +1348 } +1349 +1350 @Override +1351 public MasterProtos.UnassignRegionResponse unassignRegion(RpcController controller, +1352 MasterProtos.UnassignRegionRequest request) throws ServiceException { +1353return stub.unassignRegion(controller, request); +1354 } +1355 +1356 @Override +1357
[41/51] [partial] hbase-site git commit: Published site at 82d554e3783372cc6b05489452c815b57c06f6cd.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/0383a9c2/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 efbd96c..f36d9e6 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,"i58":6,"i59":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"; @@ -211,28 +211,18 @@ extends -long -dispatchMergingRegions(HRegionInforegion_a, - HRegionInforegion_b, - booleanforcible, - longnonceGroup, - longnonce) -Merge two regions. - - - void drainRegionServer(ServerNameserver) Mark a region server as draining to prevent additional regions from getting assigned to it. - + void enableReplicationPeer(http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">StringpeerId) Restart the replication stream to the specified peer - + long enableTable(TableNametableName, longnonceGroup, @@ -240,165 +230,165 @@ extends Enable an existing table - + AssignmentManager getAssignmentManager() - + CatalogJanitor getCatalogJanitor() - + ClusterSchema getClusterSchema() - + ExecutorService getExecutorService() - + FavoredNodesManager getFavoredNodesManager() - + ProcedureEvent getInitializedEvent() - + long getLastMajorCompactionTimestamp(TableNametable) - + long getLastMajorCompactionTimestampForRegion(byte[]regionName) - + LoadBalancer getLoadBalancer() - + LockManager getLockManager() - + MasterCoprocessorHost getMasterCoprocessorHost() - + MasterFileSystem getMasterFileSystem() - + MetricsMaster getMasterMetrics() - + ProcedureExecutorMasterProcedureEnv getMasterProcedureExecutor() - + MasterProcedureManagerHost getMasterProcedureManagerHost() - + MasterQuotaManager getMasterQuotaManager() - + MasterWalManager getMasterWalManager() - + RegionNormalizer getRegionNormalizer() - + http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String getRegionServerVersion(ServerNamesn) - + ReplicationPeerConfig getReplicationPeerConfig(http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">StringpeerId) Returns the configured ReplicationPeerConfig for the specified peer - + ServerManager getServerManager() - + SnapshotManager getSnapshotManager() - + TableDescriptors getTableDescriptors() - + TableStateManager getTableStateManager() - + boolean isActiveMaster() - + boolean isInitialized() - + boolean isInMaintenanceMode() - + boolean isServerCrashProcessingEnabled() - + boolean isSplitOrMergeEnabled(MasterSwitchTypeswitchType) - + boolean isStopping() - + http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true; title="class or interface in java.util">ListServerName listDrainingRegionServers() List region servers marked as draining to not get additional regions assigned to them. - + http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true; title="class or interface in java.util">ListLockInfo listLocks() List locks - + http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true; title="class or interface in java.util">ListProcedureInfo listProcedures() List procedures - + http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true; title="class or interface in java.util">ListReplicationPeerDescription
[48/51] [partial] hbase-site git commit: Published site at 82d554e3783372cc6b05489452c815b57c06f6cd.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/0383a9c2/devapidocs/org/apache/hadoop/hbase/class-use/HRegionInfo.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/class-use/HRegionInfo.html b/devapidocs/org/apache/hadoop/hbase/class-use/HRegionInfo.html index 2177b08..c5198f7 100644 --- a/devapidocs/org/apache/hadoop/hbase/class-use/HRegionInfo.html +++ b/devapidocs/org/apache/hadoop/hbase/class-use/HRegionInfo.html @@ -2523,24 +2523,6 @@ Input/OutputFormats, a table indexing MapReduce job, and utility methods. long -HMaster.dispatchMergingRegions(HRegionInforegionInfoA, - HRegionInforegionInfoB, - booleanforcible, - longnonceGroup, - longnonce) - - -long -MasterServices.dispatchMergingRegions(HRegionInforegion_a, - HRegionInforegion_b, - booleanforcible, - longnonceGroup, - longnonce) -Merge two regions. - - - -long HMaster.mergeRegions(HRegionInfo[]regionsToMerge, booleanforcible, longnonceGroup, @@ -2596,14 +2578,9 @@ Input/OutputFormats, a table indexing MapReduce job, and utility methods. void -MasterCoprocessorHost.postDispatchMerge(HRegionInforegionInfoA, - HRegionInforegionInfoB) - - -void MasterCoprocessorHost.postMergeRegions(HRegionInfo[]regionsToMerge) - + void MasterCoprocessorHost.postMergeRegionsCommit(HRegionInfo[]regionsToMerge, HRegionInfomergedRegion, @@ -2611,7 +2588,7 @@ Input/OutputFormats, a table indexing MapReduce job, and utility methods. Invoked after merge regions operation writes the new region to hbase:meta - + void MasterCoprocessorHost.postMergeRegionsCommit(HRegionInfo[]regionsToMerge, HRegionInfomergedRegion, @@ -2619,17 +2596,17 @@ Input/OutputFormats, a table indexing MapReduce job, and utility methods. Invoked after merge regions operation writes the new region to hbase:meta - + void MasterCoprocessorHost.postMove(HRegionInforegion, ServerNamesrcServer, ServerNamedestServer) - + void MasterCoprocessorHost.postRegionOffline(HRegionInforegionInfo) - + void MasterCoprocessorHost.postRequestLock(http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">Stringnamespace, TableNametableName, @@ -2637,38 +2614,33 @@ Input/OutputFormats, a table indexing MapReduce job, and utility methods. LockProcedure.LockTypetype, http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">Stringdescription) - + void MasterCoprocessorHost.postRollBackMergeRegionsAction(HRegionInfo[]regionsToMerge, Useruser) Invoked after rollback merge regions operation - + void MasterCoprocessorHost.postUnassign(HRegionInforegionInfo, booleanforce) - + boolean MasterCoprocessorHost.preAssign(HRegionInforegionInfo) - + void MasterCoprocessorHost.preCreateTable(HTableDescriptorhtd, HRegionInfo[]regions) - + void MasterCoprocessorHost.preCreateTableAction(HTableDescriptorhtd, HRegionInfo[]regions, Useruser) - -void -MasterCoprocessorHost.preDispatchMerge(HRegionInforegionInfoA, -HRegionInforegionInfoB) - void MasterCoprocessorHost.preMergeRegions(HRegionInfo[]regionsToMerge) @@ -2773,30 +2745,19 @@ Input/OutputFormats, a table indexing MapReduce job, and utility methods. void -ServerManager.sendRegionsMerge(ServerNameserver, -HRegionInforegion_a, -HRegionInforegion_b, -booleanforcible, -Useruser) -Sends an MERGE REGIONS RPC to the specified server to merge the specified - regions. - - - -void ServerManager.sendRegionWarmup(ServerNameserver, HRegionInforegion) Sends a WARMUP RPC to the specified server to warmup the specified region. - + long HMaster.splitRegion(HRegionInforegionInfo, byte[]splitRow, longnonceGroup, longnonce) - + long MasterServices.splitRegion(HRegionInforegionInfo, byte[]splitRow, @@ -4276,10 +4237,6 @@ Input/OutputFormats, a table indexing MapReduce job, and utility methods. private HRegionInfo RSProcedureDispatcher.RegionOperation.regionInfo - -private HRegionInfo[] -DispatchMergingRegionsProcedure.regionsToMerge - @@ -4439,29 +4396,23 @@ Input/OutputFormats, a table indexing MapReduce job, and utility methods. -private RegionLoad -DispatchMergingRegionsProcedure.getRegionLoad(MasterProcedureEnvenv, - ServerNamesn, - HRegionInfohri) - - private boolean
hbase-site git commit: INFRA-10751 Empty commit
Repository: hbase-site Updated Branches: refs/heads/asf-site 0383a9c24 -> 98e5da7db 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/98e5da7d Tree: http://git-wip-us.apache.org/repos/asf/hbase-site/tree/98e5da7d Diff: http://git-wip-us.apache.org/repos/asf/hbase-site/diff/98e5da7d Branch: refs/heads/asf-site Commit: 98e5da7db0be2fb0f1cdb20ddfb86b57b3913042 Parents: 0383a9c Author: jenkinsAuthored: Sun Jul 23 15:08:55 2017 + Committer: jenkins Committed: Sun Jul 23 15:08:55 2017 + -- --
[18/51] [partial] hbase-site git commit: Published site at 82d554e3783372cc6b05489452c815b57c06f6cd.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/0383a9c2/devapidocs/src-html/org/apache/hadoop/hbase/master/ServerManager.html -- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/master/ServerManager.html b/devapidocs/src-html/org/apache/hadoop/hbase/master/ServerManager.html index 15fec0a..d30e78b 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/master/ServerManager.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/master/ServerManager.html @@ -630,684 +630,653 @@ 622} 623 } 624 -625 /** -626 * Sends an MERGE REGIONS RPC to the specified server to merge the specified -627 * regions. -628 * p -629 * A region server could reject the close request because it either does not -630 * have the specified region. -631 * @param server server to merge regions -632 * @param region_a region to merge -633 * @param region_b region to merge -634 * @param forcible true if do a compulsory merge, otherwise we will only merge -635 * two adjacent regions -636 * @throws IOException -637 */ -638 public void sendRegionsMerge(ServerName server, HRegionInfo region_a, -639 HRegionInfo region_b, boolean forcible, final User user) throws IOException { -640if (server == null) -641 throw new NullPointerException("Passed server is null"); -642if (region_a == null || region_b == null) -643 throw new NullPointerException("Passed region is null"); -644AdminService.BlockingInterface admin = getRsAdmin(server); -645if (admin == null) { -646 throw new IOException("Attempting to send MERGE REGIONS RPC to server " -647 + server.toString() + " for region " -648 + region_a.getRegionNameAsString() + "," -649 + region_b.getRegionNameAsString() -650 + " failed because no RPC connection found to this server"); -651} -652HBaseRpcController controller = newRpcController(); -653ProtobufUtil.mergeRegions(controller, admin, region_a, region_b, forcible, user); -654 } -655 -656 @VisibleForTesting -657 public void moveFromOnlineToDeadServers(final ServerName sn) { -658synchronized (onlineServers) { -659 if (!this.onlineServers.containsKey(sn)) { -660LOG.warn("Expiration of " + sn + " but server not online"); -661 } -662 // Remove the server from the known servers lists and update load info BUT -663 // add to deadservers first; do this so it'll show in dead servers list if -664 // not in online servers list. -665 this.deadservers.add(sn); -666 this.onlineServers.remove(sn); -667 onlineServers.notifyAll(); -668} -669this.rsAdmins.remove(sn); -670 } -671 -672 public synchronized void processDeadServer(final ServerName serverName, boolean shouldSplitWal) { -673// When assignment manager is cleaning up the zookeeper nodes and rebuilding the -674// in-memory region states, region servers could be down. Meta table can and -675// should be re-assigned, log splitting can be done too. However, it is better to -676// wait till the cleanup is done before re-assigning user regions. -677// -678// We should not wait in the server shutdown handler thread since it can clog -679// the handler threads and meta table could not be re-assigned in case -680// the corresponding server is down. So we queue them up here instead. -681if (!master.getAssignmentManager().isFailoverCleanupDone()) { -682 requeuedDeadServers.put(serverName, shouldSplitWal); -683 return; -684} -685 -686this.deadservers.add(serverName); -687 master.getAssignmentManager().submitServerCrash(serverName, shouldSplitWal); -688 } -689 -690 /** -691 * Process the servers which died during master's initialization. It will be -692 * called after HMaster#assignMeta and AssignmentManager#joinCluster. -693 * */ -694 synchronized void processQueuedDeadServers() { -695if (!master.isServerCrashProcessingEnabled()) { -696 LOG.info("Master hasn't enabled ServerShutdownHandler"); -697} -698IteratorServerName serverIterator = queuedDeadServers.iterator(); -699while (serverIterator.hasNext()) { -700 ServerName tmpServerName = serverIterator.next(); -701 expireServer(tmpServerName); -702 serverIterator.remove(); -703 requeuedDeadServers.remove(tmpServerName); -704} -705 -706if (!master.getAssignmentManager().isFailoverCleanupDone()) { -707 LOG.info("AssignmentManager hasn't finished failover cleanup; waiting"); -708} -709 -710for (Map.EntryServerName, Boolean entry : requeuedDeadServers.entrySet()) { -711 processDeadServer(entry.getKey(), entry.getValue()); -712} -713requeuedDeadServers.clear(); -714 } -715 -716 /* -717 * Remove the server from the drain list. -718 */ -719 public boolean removeServerFromDrainList(final ServerName sn) { -720// Warn
[11/51] [partial] hbase-site git commit: Published site at 82d554e3783372cc6b05489452c815b57c06f6cd.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/0383a9c2/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RSRpcServices.RegionScannerHolder.html -- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RSRpcServices.RegionScannerHolder.html b/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RSRpcServices.RegionScannerHolder.html index a945b54..422c076 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RSRpcServices.RegionScannerHolder.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RSRpcServices.RegionScannerHolder.html @@ -92,3454 +92,3410 @@ 084import org.apache.hadoop.hbase.client.VersionInfoUtil; 085import org.apache.hadoop.hbase.conf.ConfigurationObserver; 086import org.apache.hadoop.hbase.exceptions.FailedSanityCheckException; -087import org.apache.hadoop.hbase.exceptions.MergeRegionException; -088import org.apache.hadoop.hbase.exceptions.OutOfOrderScannerNextException; -089import org.apache.hadoop.hbase.exceptions.ScannerResetException; -090import org.apache.hadoop.hbase.filter.ByteArrayComparable; -091import org.apache.hadoop.hbase.filter.CompareFilter.CompareOp; -092import org.apache.hadoop.hbase.ipc.HBaseRPCErrorHandler; -093import org.apache.hadoop.hbase.ipc.HBaseRpcController; -094import org.apache.hadoop.hbase.ipc.PriorityFunction; -095import org.apache.hadoop.hbase.ipc.QosPriority; -096import org.apache.hadoop.hbase.ipc.RpcCallContext; -097import org.apache.hadoop.hbase.ipc.RpcCallback; -098import org.apache.hadoop.hbase.ipc.RpcServer; -099import org.apache.hadoop.hbase.ipc.RpcServer.BlockingServiceAndInterface; -100import org.apache.hadoop.hbase.ipc.RpcServerFactory; -101import org.apache.hadoop.hbase.ipc.RpcServerInterface; -102import org.apache.hadoop.hbase.ipc.ServerNotRunningYetException; -103import org.apache.hadoop.hbase.ipc.ServerRpcController; -104import org.apache.hadoop.hbase.master.MasterRpcServices; -105import org.apache.hadoop.hbase.quotas.ActivePolicyEnforcement; -106import org.apache.hadoop.hbase.quotas.OperationQuota; -107import org.apache.hadoop.hbase.quotas.QuotaUtil; -108import org.apache.hadoop.hbase.quotas.RegionServerRpcQuotaManager; -109import org.apache.hadoop.hbase.quotas.RegionServerSpaceQuotaManager; -110import org.apache.hadoop.hbase.quotas.SpaceQuotaSnapshot; -111import org.apache.hadoop.hbase.quotas.SpaceViolationPolicyEnforcement; -112import org.apache.hadoop.hbase.regionserver.HRegion.RegionScannerImpl; -113import org.apache.hadoop.hbase.regionserver.Leases.Lease; -114import org.apache.hadoop.hbase.regionserver.Leases.LeaseStillHeldException; -115import org.apache.hadoop.hbase.regionserver.Region.Operation; -116import org.apache.hadoop.hbase.regionserver.ScannerContext.LimitScope; -117import org.apache.hadoop.hbase.regionserver.handler.OpenMetaHandler; -118import org.apache.hadoop.hbase.regionserver.handler.OpenPriorityRegionHandler; -119import org.apache.hadoop.hbase.regionserver.handler.OpenRegionHandler; -120import org.apache.hadoop.hbase.regionserver.wal.WALEdit; -121import org.apache.hadoop.hbase.security.Superusers; -122import org.apache.hadoop.hbase.security.User; -123import org.apache.hadoop.hbase.shaded.com.google.protobuf.ByteString; -124import org.apache.hadoop.hbase.shaded.com.google.protobuf.Message; -125import org.apache.hadoop.hbase.shaded.com.google.protobuf.RpcController; -126import org.apache.hadoop.hbase.shaded.com.google.protobuf.ServiceException; -127import org.apache.hadoop.hbase.shaded.com.google.protobuf.TextFormat; -128import org.apache.hadoop.hbase.shaded.com.google.protobuf.UnsafeByteOperations; -129import org.apache.hadoop.hbase.shaded.protobuf.ProtobufUtil; -130import org.apache.hadoop.hbase.shaded.protobuf.RequestConverter; -131import org.apache.hadoop.hbase.shaded.protobuf.ResponseConverter; -132import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.AdminService; -133import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.ClearCompactionQueuesRequest; -134import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.ClearCompactionQueuesResponse; -135import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CloseRegionRequest; -136import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CloseRegionResponse; -137import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CompactRegionRequest; -138import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CompactRegionResponse; -139import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.ExecuteProceduresRequest; -140import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.ExecuteProceduresResponse; -141import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.FlushRegionRequest; -142import
[19/51] [partial] hbase-site git commit: Published site at 82d554e3783372cc6b05489452c815b57c06f6cd.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/0383a9c2/devapidocs/src-html/org/apache/hadoop/hbase/master/MasterRpcServices.BalanceSwitchMode.html -- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/master/MasterRpcServices.BalanceSwitchMode.html b/devapidocs/src-html/org/apache/hadoop/hbase/master/MasterRpcServices.BalanceSwitchMode.html index 1460e0e..826e912 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/master/MasterRpcServices.BalanceSwitchMode.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/master/MasterRpcServices.BalanceSwitchMode.html @@ -2017,37 +2017,7 @@ 2009 throw new ServiceException(e); 2010} 2011 } -2012 -2013 @Override -2014 public DispatchMergingRegionsResponse dispatchMergingRegions(RpcController controller, -2015 DispatchMergingRegionsRequest request) throws ServiceException { -2016final byte[] encodedNameOfRegionA = request.getRegionA().getValue().toByteArray(); -2017final byte[] encodedNameOfRegionB = request.getRegionB().getValue().toByteArray(); -2018if (request.getRegionA().getType() != RegionSpecifierType.ENCODED_REGION_NAME || -2019request.getRegionB().getType() != RegionSpecifierType.ENCODED_REGION_NAME) { -2020 LOG.warn("mergeRegions specifier type: expected: " + RegionSpecifierType.ENCODED_REGION_NAME + -2021 " actual: region_a=" + -2022 request.getRegionA().getType() + ", region_b=" + -2023 request.getRegionB().getType()); -2024} -2025RegionStates regionStates = master.getAssignmentManager().getRegionStates(); -2026RegionState regionStateA = regionStates.getRegionState(Bytes.toString(encodedNameOfRegionA)); -2027RegionState regionStateB = regionStates.getRegionState(Bytes.toString(encodedNameOfRegionB)); -2028if (regionStateA == null || regionStateB == null) { -2029 throw new ServiceException(new UnknownRegionException( -2030 Bytes.toStringBinary(regionStateA == null? encodedNameOfRegionA: encodedNameOfRegionB))); -2031} -2032final HRegionInfo regionInfoA = regionStateA.getRegion(); -2033final HRegionInfo regionInfoB = regionStateB.getRegion(); -2034try { -2035 long procId = master.dispatchMergingRegions(regionInfoA, regionInfoB, request.getForcible(), -2036 request.getNonceGroup(), request.getNonce()); -2037 return DispatchMergingRegionsResponse.newBuilder().setProcId(procId).build(); -2038} catch (IOException ioe) { -2039 throw new ServiceException(ioe); -2040} -2041 } -2042} +2012} http://git-wip-us.apache.org/repos/asf/hbase-site/blob/0383a9c2/devapidocs/src-html/org/apache/hadoop/hbase/master/MasterRpcServices.html -- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/master/MasterRpcServices.html b/devapidocs/src-html/org/apache/hadoop/hbase/master/MasterRpcServices.html index 1460e0e..826e912 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/master/MasterRpcServices.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/master/MasterRpcServices.html @@ -2017,37 +2017,7 @@ 2009 throw new ServiceException(e); 2010} 2011 } -2012 -2013 @Override -2014 public DispatchMergingRegionsResponse dispatchMergingRegions(RpcController controller, -2015 DispatchMergingRegionsRequest request) throws ServiceException { -2016final byte[] encodedNameOfRegionA = request.getRegionA().getValue().toByteArray(); -2017final byte[] encodedNameOfRegionB = request.getRegionB().getValue().toByteArray(); -2018if (request.getRegionA().getType() != RegionSpecifierType.ENCODED_REGION_NAME || -2019request.getRegionB().getType() != RegionSpecifierType.ENCODED_REGION_NAME) { -2020 LOG.warn("mergeRegions specifier type: expected: " + RegionSpecifierType.ENCODED_REGION_NAME + -2021 " actual: region_a=" + -2022 request.getRegionA().getType() + ", region_b=" + -2023 request.getRegionB().getType()); -2024} -2025RegionStates regionStates = master.getAssignmentManager().getRegionStates(); -2026RegionState regionStateA = regionStates.getRegionState(Bytes.toString(encodedNameOfRegionA)); -2027RegionState regionStateB = regionStates.getRegionState(Bytes.toString(encodedNameOfRegionB)); -2028if (regionStateA == null || regionStateB == null) { -2029 throw new ServiceException(new UnknownRegionException( -2030 Bytes.toStringBinary(regionStateA == null? encodedNameOfRegionA: encodedNameOfRegionB))); -2031} -2032final HRegionInfo regionInfoA = regionStateA.getRegion(); -2033final HRegionInfo regionInfoB = regionStateB.getRegion(); -2034try { -2035 long procId = master.dispatchMergingRegions(regionInfoA, regionInfoB, request.getForcible(), -2036 request.getNonceGroup(), request.getNonce()); -2037
[47/51] [partial] hbase-site git commit: Published site at 82d554e3783372cc6b05489452c815b57c06f6cd.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/0383a9c2/devapidocs/org/apache/hadoop/hbase/client/ConnectionImplementation.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/client/ConnectionImplementation.html b/devapidocs/org/apache/hadoop/hbase/client/ConnectionImplementation.html index e0614ca..9e5547f 100644 --- a/devapidocs/org/apache/hadoop/hbase/client/ConnectionImplementation.html +++ b/devapidocs/org/apache/hadoop/hbase/client/ConnectionImplementation.html @@ -2218,7 +2218,7 @@ publicboolean release -private staticvoidrelease(ConnectionImplementation.MasterServiceStatemss) +private staticvoidrelease(ConnectionImplementation.MasterServiceStatemss) @@ -2227,7 +2227,7 @@ publicboolean isKeepAliveMasterConnectedAndRunning -privatebooleanisKeepAliveMasterConnectedAndRunning(ConnectionImplementation.MasterServiceStatemss) +privatebooleanisKeepAliveMasterConnectedAndRunning(ConnectionImplementation.MasterServiceStatemss) @@ -2236,7 +2236,7 @@ publicboolean releaseMaster -voidreleaseMaster(ConnectionImplementation.MasterServiceStatemss) +voidreleaseMaster(ConnectionImplementation.MasterServiceStatemss) @@ -2245,7 +2245,7 @@ publicboolean closeMasterService -privatevoidcloseMasterService(ConnectionImplementation.MasterServiceStatemss) +privatevoidcloseMasterService(ConnectionImplementation.MasterServiceStatemss) @@ -2254,7 +2254,7 @@ publicboolean closeMaster -privatevoidcloseMaster() +privatevoidcloseMaster() Immediate close of the shared master. Can be by the delayed close or when closing the connection itself. @@ -2265,7 +2265,7 @@ publicboolean updateCachedLocation -voidupdateCachedLocation(HRegionInfohri, +voidupdateCachedLocation(HRegionInfohri, ServerNamesource, ServerNameserverName, longseqNum) @@ -2277,7 +2277,7 @@ publicboolean deleteCachedRegionLocation -publicvoiddeleteCachedRegionLocation(HRegionLocationlocation) +publicvoiddeleteCachedRegionLocation(HRegionLocationlocation) Description copied from interface:ClusterConnection Deletes cached locations for the specific region. @@ -2294,7 +2294,7 @@ publicboolean updateCachedLocations -publicvoidupdateCachedLocations(TableNametableName, +publicvoidupdateCachedLocations(TableNametableName, byte[]regionName, byte[]rowkey, http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true; title="class or interface in java.lang">Objectexception, @@ -2321,7 +2321,7 @@ publicboolean getAsyncProcess -publicAsyncProcessgetAsyncProcess() +publicAsyncProcessgetAsyncProcess() Specified by: getAsyncProcessin interfaceClusterConnection @@ -2336,7 +2336,7 @@ publicboolean getStatisticsTracker -publicServerStatisticTrackergetStatisticsTracker() +publicServerStatisticTrackergetStatisticsTracker() Specified by: getStatisticsTrackerin interfaceClusterConnection @@ -2351,7 +2351,7 @@ publicboolean getBackoffPolicy -publicClientBackoffPolicygetBackoffPolicy() +publicClientBackoffPolicygetBackoffPolicy() Specified by: getBackoffPolicyin interfaceClusterConnection @@ -2366,7 +2366,7 @@ publicboolean getNumberOfCachedRegionLocations -intgetNumberOfCachedRegionLocations(TableNametableName) +intgetNumberOfCachedRegionLocations(TableNametableName) @@ -2375,7 +2375,7 @@ publicboolean abort -publicvoidabort(http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">Stringmsg, +publicvoidabort(http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">Stringmsg, http://docs.oracle.com/javase/8/docs/api/java/lang/Throwable.html?is-external=true; title="class or interface in java.lang">Throwablet) Description copied from interface:Abortable Abort the server or client. @@ -2394,7 +2394,7 @@ publicboolean isClosed -publicbooleanisClosed() +publicbooleanisClosed() Description copied from interface:Connection Returns whether the connection is closed or not. @@ -2411,7 +2411,7 @@ publicboolean isAborted -publicbooleanisAborted() +publicbooleanisAborted() Description copied from interface:Abortable Check if the server or client was aborted. @@ -2428,7 +2428,7 @@ publicboolean getCurrentNrHRS -publicintgetCurrentNrHRS() +publicintgetCurrentNrHRS() throws http://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true; title="class or interface in java.io">IOException Specified by: @@ -2446,7 +2446,7 @@ publicboolean close -publicvoidclose() +publicvoidclose() Specified by: http://docs.oracle.com/javase/8/docs/api/java/io/Closeable.html?is-external=true#close--; title="class or interface in
[44/51] [partial] hbase-site git commit: Published site at 82d554e3783372cc6b05489452c815b57c06f6cd.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/0383a9c2/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 eecc848..493d5f8 100644 --- a/devapidocs/org/apache/hadoop/hbase/master/HMasterCommandLine.LocalHMaster.html +++ b/devapidocs/org/apache/hadoop/hbase/master/HMasterCommandLine.LocalHMaster.html @@ -248,7 +248,7 @@ extends Methods inherited from classorg.apache.hadoop.hbase.master.HMaster -abort, abortProcedure, addColumn, addReplicationPeer, balance, balance, balanceSwitch, canCreateBaseZNode, canUpdateTableDescriptor, checkIfShouldMoveSystemRegionAsync, checkInitialized, checkServiceStarted, checkTableModifiable, configureInfoServer, construct Master, createMetaBootstrap, createNamespace, createQuotaSnapshotNotifier, createRpcServices, createServerManager, createSystemTable, createTable, deleteColumn, deleteNamespace, deleteTable, disableReplicationPeer, disableTable, dispatc hMergingRegions, drainRegionServer, enableReplicationPeer, enableTable, getAssignmentManager, getAverageLoad, getCatalogJanitor, getClientIdAuditPrefix, getCl usterSchema, getClusterStatus, getDumpServlet, getFavoredNodesManager, getFsTableDescriptors, getHFileCleaner, getInitializedEvent, getLastMajorCompactionTimestamp, getLast MajorCompactionTimestampForRegion, getLoadBalancer, getLoadBalancerClassName, getLoadedCoprocessors, getLockManager, getLogCleaner, getMasterActiveTime, getMasterCoprocessorHost, getMasterCoprocessors, getMasterFileSystem, getMasterMetrics, getMasterProcedureExecutor, getMasterProcedureManagerHost, getMasterQuotaManager, getMasterRpcServices, getMasterStartTime, getMasterWalManager, getMergePlanCount, getMobCompactionState, getNamespace, getNamespaces, getNumWALFiles, getProcessName, getQuotaObserverChore, getRegionNormalizer, getRegionNormalizerTracker, < a href="../../../../../org/apache/hadoop/hbase/master/HMaster.html#getRegionServerFatalLogBuffer--">getRegionServerFatalLogBuffer, getRegionServerInfoPort, getRegionServerVersion, getRemoteInetAddress, getReplicationPeerConfig, getServerCrashProcessingEnabledEvent, getServerManager, getServerName, getSnapshotManager, getSpaceQuotaSnapshotNotifier, getSplitOrMergeTracker, getSplitPlanCount, getTableDescriptors, getTableRegionForRow, getTableStateManager, getWalProcedureStore, getZooKeeper, initClusterSchemaService, initializeZKBasedSystemTrackers, initQuotaManager, isActiveMaster, isBalancerOn, isCatalogJanitorEnabled, isCleanerChor eEnabled, isInitializationStartsMetaRegionAssignment, isInitialized, isInMaintenanceMode, isNormalizerOn, isServerCrashProcessingEnabled, isSplitOrMergeEnabled, listDrainingRegionServers, listLocks, listProcedures, listReplicationPeers, listTableDescriptors, listTableDescriptorsByNamespace, listTableNames, listTableNamesByNamespace, login, main, mergeRegions, modifyColumn, modifyNamespace, modifyTable, move, normalizeRegions, registerService, removeDrainFromRegionServer, removeReplicationPeer, reportMobCompactionEnd, reportMobCompactionStart, requestMobCompaction, restoreSnapshot, setCatalogJanitorEnabled, setInitialized, setServerCrashProcessingEnabled, shutdown, splitRegion, stopMaster, stopServiceThreads, truncateTable, updateConfigurationForSpaceQuotaObserver, updateReplicationPeerConfig, waitForMasterActive +abort, abortProcedure, addColumn, addReplicationPeer, balance, balance, balanceSwitch, canCreateBaseZNode, canUpdateTableDescriptor, checkIfShouldMoveSystemRegionAsync, checkInitialized, checkServiceStarted, checkTableModifiable, configureInfoServer, construct Master, createMetaBootstrap, createNamespace, createQuotaSnapshotNotifier, createRpcServices, createServerManager, createSystemTable, createTable, deleteColumn, deleteNamespace, deleteTable, disableReplicationPeer, disableTable, drainRegionServer, enableReplicationPeer, enableTable, getAssignmentManager, getAverageLoad, getCatalogJanitor, getClientIdAuditPrefix, getClusterSchema, getClusterStatus, getDumpServlet, getFavoredNodesManager, getFsTableDescriptors, getHFileCleaner, getInitializedEvent, getLastMajorCompactionTimestamp, getLastMajorCompactionTimestampForRegion, getLoadBalancer, getLoadBalancerClassName, getLoadedCoprocessors, getLockManager, getLogCleaner, getMasterActiveTime, getMasterCoprocessorHost, getMasterCoprocessors, getMasterFileSystem, getMasterMetrics, getMasterProcedureExecutor, getMasterProcedureManagerHost, getMasterQuotaManager, getMasterRpcServices, getMasterStartTime, getMasterWalManager, getMergePlanCount, getMobCompactionState, getNamespace, getNamespaces,
[34/51] [partial] hbase-site git commit: Published site at 82d554e3783372cc6b05489452c815b57c06f6cd.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/0383a9c2/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 c99c156..88b693b 100644 --- a/devapidocs/org/apache/hadoop/hbase/regionserver/RSRpcServices.html +++ b/devapidocs/org/apache/hadoop/hbase/regionserver/RSRpcServices.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":9,"i30":10,"i31":10,"i32":10,"i33":10,"i34":10,"i35":9,"i36":10,"i37":10,"i38":10,"i39":10,"i40":10,"i41":10,"i42":10,"i43":9,"i44":9,"i45":9,"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}; +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":9,"i30":10,"i31":10,"i32":10,"i33":10,"i34":10,"i35":9,"i36":10,"i37":10,"i38":10,"i39":10,"i40":10,"i41":10,"i42":10,"i43":9,"i44":9,"i45":9,"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}; var tabs = {65535:["t0","All Methods"],1:["t1","Static Methods"],2:["t2","Instance Methods"],8:["t4","Concrete Methods"]}; var altColor = "altColor"; var rowColor = "rowColor"; @@ -118,7 +118,7 @@ var activeTableTab = "activeTableTab"; @InterfaceAudience.Private -public class RSRpcServices +public class RSRpcServices extends http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true; title="class or interface in java.lang">Object implements 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. @@ -726,27 +726,20 @@ implements isClientCellBlockSupport(RpcCallContextcontext) -org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.MergeRegionsResponse -mergeRegions(org.apache.hadoop.hbase.shaded.com.google.protobuf.RpcControllercontroller, - org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.MergeRegionsRequestrequest) -Merge regions on the region server. - - - org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.MultiResponse multi(org.apache.hadoop.hbase.shaded.com.google.protobuf.RpcControllerrpcc, org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.MultiRequestrequest) Execute multiple actions on a table: get, mutate, and/or execCoprocessor - + org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.MutateResponse mutate(org.apache.hadoop.hbase.shaded.com.google.protobuf.RpcControllerrpcc, org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.MutateRequestrequest) Mutate data in a table. - + private void mutateRows(Regionregion, http://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.ClientProtos.Actionactions, @@ -755,52 +748,52 @@ implements Mutate a list of rows atomically. - + private RSRpcServices.RegionScannerHolder newRegionScanner(org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ScanRequestrequest, org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ScanResponse.Builderbuilder) - + void onConfigurationChange(org.apache.hadoop.conf.ConfigurationnewConf) This method would be called by the ConfigurationManager object when the Configuration object is reloaded from disk. - + org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.OpenRegionResponse openRegion(org.apache.hadoop.hbase.shaded.com.google.protobuf.RpcControllercontroller, org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.OpenRegionRequestrequest) Open asynchronously a region or a set of regions on
[39/51] [partial] hbase-site git commit: Published site at 82d554e3783372cc6b05489452c815b57c06f6cd.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/0383a9c2/devapidocs/org/apache/hadoop/hbase/master/procedure/DispatchMergingRegionsProcedure.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/master/procedure/DispatchMergingRegionsProcedure.html b/devapidocs/org/apache/hadoop/hbase/master/procedure/DispatchMergingRegionsProcedure.html deleted file mode 100644 index 1e7fc5d..000 --- a/devapidocs/org/apache/hadoop/hbase/master/procedure/DispatchMergingRegionsProcedure.html +++ /dev/null @@ -1,1118 +0,0 @@ -http://www.w3.org/TR/html4/loose.dtd;> - - - - - -DispatchMergingRegionsProcedure (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,"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}; -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.procedure -Class DispatchMergingRegionsProcedure - - - -http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true; title="class or interface in java.lang">java.lang.Object - - -org.apache.hadoop.hbase.procedure2.ProcedureTEnvironment - - -org.apache.hadoop.hbase.procedure2.StateMachineProcedureMasterProcedureEnv,TState - - -org.apache.hadoop.hbase.master.procedure.AbstractStateMachineTableProcedureorg.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.DispatchMergingRegionsState - - -org.apache.hadoop.hbase.master.procedure.DispatchMergingRegionsProcedure - - - - - - - - - - - - - -All Implemented Interfaces: -http://docs.oracle.com/javase/8/docs/api/java/lang/Comparable.html?is-external=true; title="class or interface in java.lang">ComparableProcedureMasterProcedureEnv, TableProcedureInterface - - - -@InterfaceAudience.Private -public class DispatchMergingRegionsProcedure -extends AbstractStateMachineTableProcedureorg.apache.hadoop.hbase.shaded.protobuf.generated.MasterProcedureProtos.DispatchMergingRegionsState -The procedure to Merge a region in a table. - - - - - - - - - - - -Nested Class Summary - - - - -Nested classes/interfaces inherited from classorg.apache.hadoop.hbase.procedure2.StateMachineProcedure -StateMachineProcedure.Flow - - - - - -Nested classes/interfaces inherited from classorg.apache.hadoop.hbase.procedure2.Procedure -Procedure.LockState - - - - - -Nested classes/interfaces inherited from interfaceorg.apache.hadoop.hbase.master.procedure.TableProcedureInterface -TableProcedureInterface.TableOperationType - - - - - - - - -Field Summary - -Fields - -Modifier and Type -Field and Description - - -private http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/atomic/AtomicBoolean.html?is-external=true; title="class or interface in java.util.concurrent.atomic">AtomicBoolean -aborted - - -private AssignmentManager -assignmentManager - - -private boolean -forcible - - -private static org.apache.commons.logging.Log -LOG - - -private ServerName -regionLocation - - -private HRegionInfo[] -regionsToMerge - - -private http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String -regionsToMergeListEncodedName - - -private http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String -regionsToMergeListFullName - - -private TableName -tableName - - -private int -timeout - - -private http://docs.oracle.com/javase/8/docs/api/java/lang/Boolean.html?is-external=true; title="class or interface in java.lang">Boolean -traceEnabled - - - - - - -Fields inherited from classorg.apache.hadoop.hbase.procedure2.Procedure -NO_PROC_ID, NO_TIMEOUT - - - - - - - - -Constructor Summary - -Constructors - -Constructor and Description - - -DispatchMergingRegionsProcedure() - - -DispatchMergingRegionsProcedure(MasterProcedureEnvenv, - TableNametableName, -
[13/51] [partial] hbase-site git commit: Published site at 82d554e3783372cc6b05489452c815b57c06f6cd.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/0383a9c2/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RSRpcServices.LogDelegate.html -- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RSRpcServices.LogDelegate.html b/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RSRpcServices.LogDelegate.html index a945b54..422c076 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RSRpcServices.LogDelegate.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RSRpcServices.LogDelegate.html @@ -92,3454 +92,3410 @@ 084import org.apache.hadoop.hbase.client.VersionInfoUtil; 085import org.apache.hadoop.hbase.conf.ConfigurationObserver; 086import org.apache.hadoop.hbase.exceptions.FailedSanityCheckException; -087import org.apache.hadoop.hbase.exceptions.MergeRegionException; -088import org.apache.hadoop.hbase.exceptions.OutOfOrderScannerNextException; -089import org.apache.hadoop.hbase.exceptions.ScannerResetException; -090import org.apache.hadoop.hbase.filter.ByteArrayComparable; -091import org.apache.hadoop.hbase.filter.CompareFilter.CompareOp; -092import org.apache.hadoop.hbase.ipc.HBaseRPCErrorHandler; -093import org.apache.hadoop.hbase.ipc.HBaseRpcController; -094import org.apache.hadoop.hbase.ipc.PriorityFunction; -095import org.apache.hadoop.hbase.ipc.QosPriority; -096import org.apache.hadoop.hbase.ipc.RpcCallContext; -097import org.apache.hadoop.hbase.ipc.RpcCallback; -098import org.apache.hadoop.hbase.ipc.RpcServer; -099import org.apache.hadoop.hbase.ipc.RpcServer.BlockingServiceAndInterface; -100import org.apache.hadoop.hbase.ipc.RpcServerFactory; -101import org.apache.hadoop.hbase.ipc.RpcServerInterface; -102import org.apache.hadoop.hbase.ipc.ServerNotRunningYetException; -103import org.apache.hadoop.hbase.ipc.ServerRpcController; -104import org.apache.hadoop.hbase.master.MasterRpcServices; -105import org.apache.hadoop.hbase.quotas.ActivePolicyEnforcement; -106import org.apache.hadoop.hbase.quotas.OperationQuota; -107import org.apache.hadoop.hbase.quotas.QuotaUtil; -108import org.apache.hadoop.hbase.quotas.RegionServerRpcQuotaManager; -109import org.apache.hadoop.hbase.quotas.RegionServerSpaceQuotaManager; -110import org.apache.hadoop.hbase.quotas.SpaceQuotaSnapshot; -111import org.apache.hadoop.hbase.quotas.SpaceViolationPolicyEnforcement; -112import org.apache.hadoop.hbase.regionserver.HRegion.RegionScannerImpl; -113import org.apache.hadoop.hbase.regionserver.Leases.Lease; -114import org.apache.hadoop.hbase.regionserver.Leases.LeaseStillHeldException; -115import org.apache.hadoop.hbase.regionserver.Region.Operation; -116import org.apache.hadoop.hbase.regionserver.ScannerContext.LimitScope; -117import org.apache.hadoop.hbase.regionserver.handler.OpenMetaHandler; -118import org.apache.hadoop.hbase.regionserver.handler.OpenPriorityRegionHandler; -119import org.apache.hadoop.hbase.regionserver.handler.OpenRegionHandler; -120import org.apache.hadoop.hbase.regionserver.wal.WALEdit; -121import org.apache.hadoop.hbase.security.Superusers; -122import org.apache.hadoop.hbase.security.User; -123import org.apache.hadoop.hbase.shaded.com.google.protobuf.ByteString; -124import org.apache.hadoop.hbase.shaded.com.google.protobuf.Message; -125import org.apache.hadoop.hbase.shaded.com.google.protobuf.RpcController; -126import org.apache.hadoop.hbase.shaded.com.google.protobuf.ServiceException; -127import org.apache.hadoop.hbase.shaded.com.google.protobuf.TextFormat; -128import org.apache.hadoop.hbase.shaded.com.google.protobuf.UnsafeByteOperations; -129import org.apache.hadoop.hbase.shaded.protobuf.ProtobufUtil; -130import org.apache.hadoop.hbase.shaded.protobuf.RequestConverter; -131import org.apache.hadoop.hbase.shaded.protobuf.ResponseConverter; -132import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.AdminService; -133import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.ClearCompactionQueuesRequest; -134import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.ClearCompactionQueuesResponse; -135import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CloseRegionRequest; -136import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CloseRegionResponse; -137import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CompactRegionRequest; -138import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CompactRegionResponse; -139import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.ExecuteProceduresRequest; -140import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.ExecuteProceduresResponse; -141import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.FlushRegionRequest; -142import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.FlushRegionResponse; -143import
[49/51] [partial] hbase-site git commit: Published site at 82d554e3783372cc6b05489452c815b57c06f6cd.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/0383a9c2/checkstyle.rss -- diff --git a/checkstyle.rss b/checkstyle.rss index 38e6b6a..cf4b280 100644 --- a/checkstyle.rss +++ b/checkstyle.rss @@ -25,8 +25,8 @@ under the License. en-us 2007 - 2017 The Apache Software Foundation - File: 2247, - Errors: 14922, + File: 2246, + Errors: 14830, Warnings: 0, Infos: 0 @@ -4540,20 +4540,6 @@ under the License. - http://hbase.apache.org/checkstyle.html#org.apache.hadoop.hbase.master.procedure.DispatchMergingRegionsProcedure.java;>org/apache/hadoop/hbase/master/procedure/DispatchMergingRegionsProcedure.java - - - 0 - - - 0 - - - 60 - - - - http://hbase.apache.org/checkstyle.html#org.apache.hadoop.hbase.rest.model.ColumnSchemaModel.java;>org/apache/hadoop/hbase/rest/model/ColumnSchemaModel.java @@ -8567,7 +8553,7 @@ under the License. 0 - 38 + 36 @@ -11059,7 +11045,7 @@ under the License. 0 - 44 + 43 @@ -19207,7 +19193,7 @@ under the License. 0 - 270 + 253 @@ -22147,7 +22133,7 @@ under the License. 0 - 227 + 216 @@ -24135,7 +24121,7 @@ under the License. 0 - 134 + 133 http://git-wip-us.apache.org/repos/asf/hbase-site/blob/0383a9c2/coc.html -- diff --git a/coc.html b/coc.html index 0d1274e..66057ee 100644 --- a/coc.html +++ b/coc.html @@ -7,7 +7,7 @@ - + Apache HBase Code of Conduct Policy @@ -380,7 +380,7 @@ email to mailto:priv...@hbase.apache.org;>the priv https://www.apache.org/;>The Apache Software Foundation. All rights reserved. - Last Published: 2017-07-22 + Last Published: 2017-07-23 http://git-wip-us.apache.org/repos/asf/hbase-site/blob/0383a9c2/cygwin.html -- diff --git a/cygwin.html b/cygwin.html index 8d2803f..be73ac5 100644 --- a/cygwin.html +++ b/cygwin.html @@ -7,7 +7,7 @@ - + Apache HBase Installing Apache HBase (TM) on Windows using Cygwin @@ -679,7 +679,7 @@ Now your HBase server is running, start coding and build that next https://www.apache.org/;>The Apache Software Foundation. All rights reserved. - Last Published: 2017-07-22 + Last Published: 2017-07-23 http://git-wip-us.apache.org/repos/asf/hbase-site/blob/0383a9c2/dependencies.html -- diff --git a/dependencies.html b/dependencies.html index 4c094be..05cb583 100644 --- a/dependencies.html +++ b/dependencies.html @@ -7,7 +7,7 @@ - + Apache HBase Project Dependencies @@ -527,7 +527,7 @@ https://www.apache.org/;>The Apache Software Foundation. All rights reserved. - Last Published: 2017-07-22 + Last Published: 2017-07-23 http://git-wip-us.apache.org/repos/asf/hbase-site/blob/0383a9c2/dependency-convergence.html -- diff --git a/dependency-convergence.html b/dependency-convergence.html index 7c4dedb..d43a3f5 100644 --- a/dependency-convergence.html +++ b/dependency-convergence.html @@ -7,7 +7,7 @@ - + Apache HBase Reactor Dependency Convergence @@ -724,7 +724,7 @@ https://www.apache.org/;>The Apache Software Foundation. All
[03/51] [partial] hbase-site git commit: Published site at 82d554e3783372cc6b05489452c815b57c06f6cd.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/0383a9c2/testdevapidocs/org/apache/hadoop/hbase/IntegrationTestDDLMasterFailover.CreateTableAction.html -- diff --git a/testdevapidocs/org/apache/hadoop/hbase/IntegrationTestDDLMasterFailover.CreateTableAction.html b/testdevapidocs/org/apache/hadoop/hbase/IntegrationTestDDLMasterFailover.CreateTableAction.html index c3dc6a0..9d3fdd0 100644 --- a/testdevapidocs/org/apache/hadoop/hbase/IntegrationTestDDLMasterFailover.CreateTableAction.html +++ b/testdevapidocs/org/apache/hadoop/hbase/IntegrationTestDDLMasterFailover.CreateTableAction.html @@ -123,7 +123,7 @@ var activeTableTab = "activeTableTab"; -private class IntegrationTestDDLMasterFailover.CreateTableAction +private class IntegrationTestDDLMasterFailover.CreateTableAction extends IntegrationTestDDLMasterFailover.TableAction @@ -178,7 +178,7 @@ extends Method and Description -private org.apache.hadoop.hbase.HTableDescriptor +private org.apache.hadoop.hbase.client.TableDescriptor createTableDesc() @@ -220,7 +220,7 @@ extends CreateTableAction -privateCreateTableAction() +privateCreateTableAction() @@ -237,7 +237,7 @@ extends perform -voidperform() +voidperform() throws http://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true; title="class or interface in java.io">IOException Specified by: @@ -253,7 +253,7 @@ extends createTableDesc -privateorg.apache.hadoop.hbase.HTableDescriptorcreateTableDesc() +privateorg.apache.hadoop.hbase.client.TableDescriptorcreateTableDesc() http://git-wip-us.apache.org/repos/asf/hbase-site/blob/0383a9c2/testdevapidocs/org/apache/hadoop/hbase/IntegrationTestDDLMasterFailover.DeleteColumnFamilyAction.html -- diff --git a/testdevapidocs/org/apache/hadoop/hbase/IntegrationTestDDLMasterFailover.DeleteColumnFamilyAction.html b/testdevapidocs/org/apache/hadoop/hbase/IntegrationTestDDLMasterFailover.DeleteColumnFamilyAction.html index a0bb650..1504c33 100644 --- a/testdevapidocs/org/apache/hadoop/hbase/IntegrationTestDDLMasterFailover.DeleteColumnFamilyAction.html +++ b/testdevapidocs/org/apache/hadoop/hbase/IntegrationTestDDLMasterFailover.DeleteColumnFamilyAction.html @@ -128,7 +128,7 @@ var activeTableTab = "activeTableTab"; -private class IntegrationTestDDLMasterFailover.DeleteColumnFamilyAction +private class IntegrationTestDDLMasterFailover.DeleteColumnFamilyAction extends IntegrationTestDDLMasterFailover.ColumnAction @@ -192,7 +192,7 @@ extends IntegrationTestDDLMasterFailover.ColumnAction -selectFamily +selectFamily @@ -228,7 +228,7 @@ extends DeleteColumnFamilyAction -privateDeleteColumnFamilyAction() +privateDeleteColumnFamilyAction() @@ -245,7 +245,7 @@ extends perform -voidperform() +voidperform() throws http://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true; title="class or interface in java.io">IOException Specified by: http://git-wip-us.apache.org/repos/asf/hbase-site/blob/0383a9c2/testdevapidocs/org/apache/hadoop/hbase/IntegrationTestDDLMasterFailover.DeleteNamespaceAction.html -- diff --git a/testdevapidocs/org/apache/hadoop/hbase/IntegrationTestDDLMasterFailover.DeleteNamespaceAction.html b/testdevapidocs/org/apache/hadoop/hbase/IntegrationTestDDLMasterFailover.DeleteNamespaceAction.html index eced443..4f87dc3 100644 --- a/testdevapidocs/org/apache/hadoop/hbase/IntegrationTestDDLMasterFailover.DeleteNamespaceAction.html +++ b/testdevapidocs/org/apache/hadoop/hbase/IntegrationTestDDLMasterFailover.DeleteNamespaceAction.html @@ -123,7 +123,7 @@ var activeTableTab = "activeTableTab"; -private class IntegrationTestDDLMasterFailover.DeleteNamespaceAction +private class IntegrationTestDDLMasterFailover.DeleteNamespaceAction extends IntegrationTestDDLMasterFailover.NamespaceAction @@ -223,7 +223,7 @@ extends DeleteNamespaceAction -privateDeleteNamespaceAction() +privateDeleteNamespaceAction() @@ -240,7 +240,7 @@ extends perform -voidperform() +voidperform() throws http://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true; title="class or interface in java.io">IOException Specified by: http://git-wip-us.apache.org/repos/asf/hbase-site/blob/0383a9c2/testdevapidocs/org/apache/hadoop/hbase/IntegrationTestDDLMasterFailover.MasterAction.html -- diff --git a/testdevapidocs/org/apache/hadoop/hbase/IntegrationTestDDLMasterFailover.MasterAction.html b/testdevapidocs/org/apache/hadoop/hbase/IntegrationTestDDLMasterFailover.MasterAction.html index 884dcec..2907faa 100644 --- a/testdevapidocs/org/apache/hadoop/hbase/IntegrationTestDDLMasterFailover.MasterAction.html +++
[23/51] [partial] hbase-site git commit: Published site at 82d554e3783372cc6b05489452c815b57c06f6cd.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/0383a9c2/devapidocs/src-html/org/apache/hadoop/hbase/master/MasterCoprocessorHost.CoprocessorOperation.html -- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/master/MasterCoprocessorHost.CoprocessorOperation.html b/devapidocs/src-html/org/apache/hadoop/hbase/master/MasterCoprocessorHost.CoprocessorOperation.html index e690c2d..ec75aa9 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/master/MasterCoprocessorHost.CoprocessorOperation.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/master/MasterCoprocessorHost.CoprocessorOperation.html @@ -818,1092 +818,1070 @@ 810}); 811 } 812 -813 public void preDispatchMerge(final HRegionInfo regionInfoA, final HRegionInfo regionInfoB) -814 throws IOException { +813 public void preMergeRegions(final HRegionInfo[] regionsToMerge) +814 throws IOException { 815execOperation(coprocessors.isEmpty() ? null : new CoprocessorOperation() { 816 @Override 817 public void call(MasterObserver oserver, ObserverContextMasterCoprocessorEnvironment ctx) 818 throws IOException { -819oserver.preDispatchMerge(ctx, regionInfoA, regionInfoB); +819oserver.preMergeRegions(ctx, regionsToMerge); 820 } 821}); 822 } 823 -824 public void postDispatchMerge(final HRegionInfo regionInfoA, final HRegionInfo regionInfoB) -825 throws IOException { +824 public void postMergeRegions(final HRegionInfo[] regionsToMerge) +825 throws IOException { 826execOperation(coprocessors.isEmpty() ? null : new CoprocessorOperation() { 827 @Override 828 public void call(MasterObserver oserver, ObserverContextMasterCoprocessorEnvironment ctx) 829 throws IOException { -830oserver.postDispatchMerge(ctx, regionInfoA, regionInfoB); +830oserver.postMergeRegions(ctx, regionsToMerge); 831 } 832}); 833 } 834 -835 public void preMergeRegions(final HRegionInfo[] regionsToMerge) -836 throws IOException { -837execOperation(coprocessors.isEmpty() ? null : new CoprocessorOperation() { -838 @Override -839 public void call(MasterObserver oserver, ObserverContextMasterCoprocessorEnvironment ctx) -840 throws IOException { -841oserver.preMergeRegions(ctx, regionsToMerge); -842 } -843}); -844 } -845 -846 public void postMergeRegions(final HRegionInfo[] regionsToMerge) -847 throws IOException { -848execOperation(coprocessors.isEmpty() ? null : new CoprocessorOperation() { -849 @Override -850 public void call(MasterObserver oserver, ObserverContextMasterCoprocessorEnvironment ctx) -851 throws IOException { -852oserver.postMergeRegions(ctx, regionsToMerge); -853 } -854}); -855 } -856 -857 public boolean preBalance() throws IOException { -858return execOperation(coprocessors.isEmpty() ? null : new CoprocessorOperation() { -859 @Override -860 public void call(MasterObserver oserver, ObserverContextMasterCoprocessorEnvironment ctx) -861 throws IOException { -862oserver.preBalance(ctx); -863 } -864}); -865 } -866 -867 public void postBalance(final ListRegionPlan plans) throws IOException { +835 public boolean preBalance() throws IOException { +836return execOperation(coprocessors.isEmpty() ? null : new CoprocessorOperation() { +837 @Override +838 public void call(MasterObserver oserver, ObserverContextMasterCoprocessorEnvironment ctx) +839 throws IOException { +840oserver.preBalance(ctx); +841 } +842}); +843 } +844 +845 public void postBalance(final ListRegionPlan plans) throws IOException { +846execOperation(coprocessors.isEmpty() ? null : new CoprocessorOperation() { +847 @Override +848 public void call(MasterObserver oserver, ObserverContextMasterCoprocessorEnvironment ctx) +849 throws IOException { +850oserver.postBalance(ctx, plans); +851 } +852}); +853 } +854 +855 public boolean preSetSplitOrMergeEnabled(final boolean newValue, +856 final MasterSwitchType switchType) throws IOException { +857return execOperation(coprocessors.isEmpty() ? null : new CoprocessorOperation() { +858 @Override +859 public void call(MasterObserver oserver, ObserverContextMasterCoprocessorEnvironment ctx) +860 throws IOException { +861 oserver.preSetSplitOrMergeEnabled(ctx, newValue, switchType); +862 } +863}); +864 } +865 +866 public void postSetSplitOrMergeEnabled(final boolean newValue, +867 final MasterSwitchType switchType) throws IOException { 868execOperation(coprocessors.isEmpty() ? null : new CoprocessorOperation() { 869 @Override 870 public void call(MasterObserver oserver, ObserverContextMasterCoprocessorEnvironment ctx) 871 throws
[25/51] [partial] hbase-site git commit: Published site at 82d554e3783372cc6b05489452c815b57c06f6cd.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/0383a9c2/devapidocs/src-html/org/apache/hadoop/hbase/master/HMaster.RedirectServlet.html -- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/master/HMaster.RedirectServlet.html b/devapidocs/src-html/org/apache/hadoop/hbase/master/HMaster.RedirectServlet.html index 5479fb1..49ef112 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/master/HMaster.RedirectServlet.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/master/HMaster.RedirectServlet.html @@ -123,3388 +123,3334 @@ 115import org.apache.hadoop.hbase.master.procedure.DeleteColumnFamilyProcedure; 116import org.apache.hadoop.hbase.master.procedure.DeleteTableProcedure; 117import org.apache.hadoop.hbase.master.procedure.DisableTableProcedure; -118import org.apache.hadoop.hbase.master.procedure.DispatchMergingRegionsProcedure; -119import org.apache.hadoop.hbase.master.procedure.EnableTableProcedure; -120import org.apache.hadoop.hbase.master.procedure.MasterProcedureConstants; -121import org.apache.hadoop.hbase.master.procedure.MasterProcedureEnv; -122import org.apache.hadoop.hbase.master.procedure.MasterProcedureScheduler; -123import org.apache.hadoop.hbase.master.procedure.MasterProcedureUtil; -124import org.apache.hadoop.hbase.master.procedure.ModifyColumnFamilyProcedure; -125import org.apache.hadoop.hbase.master.procedure.ModifyTableProcedure; -126import org.apache.hadoop.hbase.master.procedure.ProcedurePrepareLatch; -127import org.apache.hadoop.hbase.master.procedure.TruncateTableProcedure; -128import org.apache.hadoop.hbase.master.replication.ReplicationManager; -129import org.apache.hadoop.hbase.master.snapshot.SnapshotManager; -130import org.apache.hadoop.hbase.mob.MobConstants; -131import org.apache.hadoop.hbase.monitoring.MemoryBoundedLogMessageBuffer; -132import org.apache.hadoop.hbase.monitoring.MonitoredTask; -133import org.apache.hadoop.hbase.monitoring.TaskMonitor; -134import org.apache.hadoop.hbase.procedure.MasterProcedureManagerHost; -135import org.apache.hadoop.hbase.procedure.flush.MasterFlushTableProcedureManager; -136import org.apache.hadoop.hbase.procedure2.LockInfo; -137import org.apache.hadoop.hbase.procedure2.ProcedureEvent; -138import org.apache.hadoop.hbase.procedure2.ProcedureExecutor; -139import org.apache.hadoop.hbase.procedure2.store.wal.WALProcedureStore; -140import org.apache.hadoop.hbase.quotas.MasterQuotaManager; -141import org.apache.hadoop.hbase.quotas.MasterSpaceQuotaObserver; -142import org.apache.hadoop.hbase.quotas.QuotaObserverChore; -143import org.apache.hadoop.hbase.quotas.QuotaUtil; -144import org.apache.hadoop.hbase.quotas.SnapshotQuotaObserverChore; -145import org.apache.hadoop.hbase.quotas.SpaceQuotaSnapshotNotifier; -146import org.apache.hadoop.hbase.quotas.SpaceQuotaSnapshotNotifierFactory; -147import org.apache.hadoop.hbase.regionserver.DefaultStoreEngine; -148import org.apache.hadoop.hbase.regionserver.HRegionServer; -149import org.apache.hadoop.hbase.regionserver.HStore; -150import org.apache.hadoop.hbase.regionserver.RSRpcServices; -151import org.apache.hadoop.hbase.regionserver.RegionCoprocessorHost; -152import org.apache.hadoop.hbase.regionserver.RegionSplitPolicy; -153import org.apache.hadoop.hbase.regionserver.compactions.ExploringCompactionPolicy; -154import org.apache.hadoop.hbase.regionserver.compactions.FIFOCompactionPolicy; -155import org.apache.hadoop.hbase.replication.ReplicationException; -156import org.apache.hadoop.hbase.replication.ReplicationFactory; -157import org.apache.hadoop.hbase.replication.ReplicationPeerConfig; -158import org.apache.hadoop.hbase.replication.ReplicationPeerDescription; -159import org.apache.hadoop.hbase.replication.ReplicationQueuesZKImpl; -160import org.apache.hadoop.hbase.replication.master.TableCFsUpdater; -161import org.apache.hadoop.hbase.replication.regionserver.Replication; -162import org.apache.hadoop.hbase.security.AccessDeniedException; -163import org.apache.hadoop.hbase.security.UserProvider; -164import org.apache.hadoop.hbase.shaded.protobuf.ProtobufUtil; -165import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.GetRegionInfoResponse.CompactionState; -166import org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.RegionServerInfo; -167import org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.Quotas; -168import org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.SpaceViolationPolicy; -169import org.apache.hadoop.hbase.shaded.protobuf.generated.SnapshotProtos.SnapshotDescription; -170import org.apache.hadoop.hbase.shaded.protobuf.generated.WALProtos; -171import org.apache.hadoop.hbase.util.Addressing; -172import org.apache.hadoop.hbase.util.Bytes; -173import org.apache.hadoop.hbase.util.CompressionTest; -174import org.apache.hadoop.hbase.util.EncryptionTest; -175import
[16/51] [partial] hbase-site git commit: Published site at 82d554e3783372cc6b05489452c815b57c06f6cd.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/0383a9c2/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/CompactSplit.CompactionRunner.html -- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/CompactSplit.CompactionRunner.html b/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/CompactSplit.CompactionRunner.html index 06b7a03..7dabb5e 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/CompactSplit.CompactionRunner.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/CompactSplit.CompactionRunner.html @@ -216,519 +216,505 @@ 208return queueLists.toString(); 209 } 210 -211 public synchronized void requestRegionsMerge(final Region a, -212 final Region b, final boolean forcible, long masterSystemTime, User user) { -213try { -214 mergePool.execute(new RegionMergeRequest(a, b, this.server, forcible, masterSystemTime,user)); -215 if (LOG.isDebugEnabled()) { -216LOG.debug("Region merge requested for " + a + "," + b + ", forcible=" -217+ forcible + ". " + this); +211 public synchronized boolean requestSplit(final Region r) { +212// don't split regions that are blocking +213if (shouldSplitRegion() ((HRegion)r).getCompactPriority() = Store.PRIORITY_USER) { +214 byte[] midKey = ((HRegion)r).checkSplit(); +215 if (midKey != null) { +216requestSplit(r, midKey); +217return true; 218 } -219} catch (RejectedExecutionException ree) { -220 LOG.warn("Could not execute merge for " + a + "," + b + ", forcible=" -221 + forcible, ree); -222} -223 } -224 -225 public synchronized boolean requestSplit(final Region r) { -226// don't split regions that are blocking -227if (shouldSplitRegion() ((HRegion)r).getCompactPriority() = Store.PRIORITY_USER) { -228 byte[] midKey = ((HRegion)r).checkSplit(); -229 if (midKey != null) { -230requestSplit(r, midKey); -231return true; -232 } -233} -234return false; -235 } -236 -237 public synchronized void requestSplit(final Region r, byte[] midKey) { -238requestSplit(r, midKey, null); -239 } -240 -241 /* -242 * The User parameter allows the split thread to assume the correct user identity -243 */ -244 public synchronized void requestSplit(final Region r, byte[] midKey, User user) { -245if (midKey == null) { -246 LOG.debug("Region " + r.getRegionInfo().getRegionNameAsString() + -247" not splittable because midkey=null"); -248 if (((HRegion)r).shouldForceSplit()) { -249((HRegion)r).clearSplit(); -250 } -251 return; -252} -253try { -254 this.splits.execute(new SplitRequest(r, midKey, this.server, user)); -255 if (LOG.isDebugEnabled()) { -256LOG.debug("Splitting " + r + ", " + this); -257 } -258} catch (RejectedExecutionException ree) { -259 LOG.info("Could not execute split for " + r, ree); -260} -261 } -262 -263 @Override -264 public synchronized ListCompactionRequest requestCompaction(final Region r, final String why) -265 throws IOException { -266return requestCompaction(r, why, null); -267 } -268 -269 @Override -270 public synchronized ListCompactionRequest requestCompaction(final Region r, final String why, -271 ListPairCompactionRequest, Store requests) throws IOException { -272return requestCompaction(r, why, Store.NO_PRIORITY, requests, null); -273 } -274 -275 @Override -276 public synchronized CompactionRequest requestCompaction(final Region r, final Store s, -277 final String why, CompactionRequest request) throws IOException { -278return requestCompaction(r, s, why, Store.NO_PRIORITY, request, null); -279 } -280 -281 @Override -282 public synchronized ListCompactionRequest requestCompaction(final Region r, final String why, -283 int p, ListPairCompactionRequest, Store requests, User user) throws IOException { -284return requestCompactionInternal(r, why, p, requests, true, user); -285 } -286 -287 private ListCompactionRequest requestCompactionInternal(final Region r, final String why, -288 int p, ListPairCompactionRequest, Store requests, boolean selectNow, User user) -289 throws IOException { -290// not a special compaction request, so make our own list -291ListCompactionRequest ret = null; -292if (requests == null) { -293 ret = selectNow ? new ArrayListCompactionRequest(r.getStores().size()) : null; -294 for (Store s : r.getStores()) { -295CompactionRequest cr = requestCompactionInternal(r, s, why, p, null, selectNow, user); -296if (selectNow) ret.add(cr); -297 } -298} else { -299 Preconditions.checkArgument(selectNow); // only system requests have selectNow == false -300 ret = new
[38/51] [partial] hbase-site git commit: Published site at 82d554e3783372cc6b05489452c815b57c06f6cd.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/0383a9c2/devapidocs/org/apache/hadoop/hbase/master/procedure/EnableTableProcedure.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/master/procedure/EnableTableProcedure.html b/devapidocs/org/apache/hadoop/hbase/master/procedure/EnableTableProcedure.html index efcee16..6937b4d 100644 --- a/devapidocs/org/apache/hadoop/hbase/master/procedure/EnableTableProcedure.html +++ b/devapidocs/org/apache/hadoop/hbase/master/procedure/EnableTableProcedure.html @@ -49,7 +49,7 @@ var activeTableTab = "activeTableTab"; -PrevClass +PrevClass NextClass @@ -857,7 +857,7 @@ extends -PrevClass +PrevClass NextClass http://git-wip-us.apache.org/repos/asf/hbase-site/blob/0383a9c2/devapidocs/org/apache/hadoop/hbase/master/procedure/TableProcedureInterface.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/master/procedure/TableProcedureInterface.html b/devapidocs/org/apache/hadoop/hbase/master/procedure/TableProcedureInterface.html index 01125a0..f09a814 100644 --- a/devapidocs/org/apache/hadoop/hbase/master/procedure/TableProcedureInterface.html +++ b/devapidocs/org/apache/hadoop/hbase/master/procedure/TableProcedureInterface.html @@ -101,7 +101,7 @@ var activeTableTab = "activeTableTab"; All Known Implementing Classes: -AbstractStateMachineNamespaceProcedure, AbstractStateMachineRegionProcedure, AbstractStateMachineTableProcedure, AddColumnFamilyProcedure, AssignProcedure, CloneSnapshotProcedure, CreateNamespaceProcedure, CreateTableProcedure, DeleteColumnFamilyProcedure, DeleteNamespaceProcedure, DeleteTableProcedure, DisableTableProcedure, DispatchMergingRegionsProcedure, EnableTableProcedure, GCMergedRegionsProcedure, GCRegionProcedure, LockProcedure, MergeTableRegionsProcedure, ModifyColumnFamilyProcedure, ModifyNamespaceProcedure, ModifyTableProcedure, MoveRegionProcedure, RegionTransitionProcedure, RestoreSnapshotProcedure, SplitTableRegionProcedure, TruncateTableProcedure, UnassignProcedure +AbstractStateMachineNamespaceProcedure, AbstractStateMachineRegionProcedure, AbstractStateMachineTableProcedure, AddColumnFamilyProcedure, AssignProcedure, CloneSnapshotProcedure, CreateNamespaceProcedure, CreateTableProcedure, DeleteColumnFamilyProcedure, DeleteNamespaceProcedure, DeleteTableProcedure, DisableTableProcedure, EnableTableProcedure, GCMergedRegionsProcedure, GCRegionProcedure, LockProcedure, MergeTableRegionsProcedure, ModifyColumnFamilyProcedure, ModifyNamespaceProcedure, ModifyTableProcedure, MoveRegionProcedure, RegionTransitionProcedure, RestoreSnapshotProcedure, SplitTableRegionProcedure, TruncateTableProcedure, UnassignProcedure http://git-wip-us.apache.org/repos/asf/hbase-site/blob/0383a9c2/devapidocs/org/apache/hadoop/hbase/master/procedure/class-use/AbstractStateMachineTableProcedure.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/master/procedure/class-use/AbstractStateMachineTableProcedure.html b/devapidocs/org/apache/hadoop/hbase/master/procedure/class-use/AbstractStateMachineTableProcedure.html index 3f927fe..32c4446 100644 --- a/devapidocs/org/apache/hadoop/hbase/master/procedure/class-use/AbstractStateMachineTableProcedure.html +++ b/devapidocs/org/apache/hadoop/hbase/master/procedure/class-use/AbstractStateMachineTableProcedure.html @@ -186,29 +186,23 @@ class -DispatchMergingRegionsProcedure -The procedure to Merge a region in a table. - - - -class EnableTableProcedure - + class ModifyColumnFamilyProcedure The procedure to modify a column family from an existing table. - + class ModifyTableProcedure - + class RestoreSnapshotProcedure - + class TruncateTableProcedure http://git-wip-us.apache.org/repos/asf/hbase-site/blob/0383a9c2/devapidocs/org/apache/hadoop/hbase/master/procedure/class-use/DispatchMergingRegionsProcedure.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/master/procedure/class-use/DispatchMergingRegionsProcedure.html b/devapidocs/org/apache/hadoop/hbase/master/procedure/class-use/DispatchMergingRegionsProcedure.html deleted file mode 100644 index d50b32b..000 --- a/devapidocs/org/apache/hadoop/hbase/master/procedure/class-use/DispatchMergingRegionsProcedure.html +++ /dev/null @@ -1,125 +0,0 @@ -http://www.w3.org/TR/html4/loose.dtd;> - - - - - -Uses of Class org.apache.hadoop.hbase.master.procedure.DispatchMergingRegionsProcedure (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,"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}; var tabs = {65535:["t0","All Methods"],2:["t2","Instance Methods"],8:["t4","Concrete Methods"]}; var altColor = "altColor"; var rowColor = "rowColor"; @@ -406,40 +406,32 @@ implements Useruser) -void -requestRegionsMerge(Regiona, - Regionb, - booleanforcible, - longmasterSystemTime, - Useruser) - - boolean requestSplit(Regionr) - + void requestSplit(Regionr, byte[]midKey) - + void requestSplit(Regionr, byte[]midKey, Useruser) - + void requestSystemCompaction(Regionr, Stores, http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">Stringwhy) - + void requestSystemCompaction(Regionr, http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">Stringwhy) - + private CompactionContext selectCompaction(Regionr, Stores, @@ -447,19 +439,19 @@ implements CompactionRequestrequest, Useruser) - + private boolean shouldSplitRegion() - + (package private) void shutdownLongCompactions() - + http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String toString() - + private void waitFor(http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/ThreadPoolExecutor.html?is-external=true; title="class or interface in java.util.concurrent">ThreadPoolExecutort, http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">Stringname) @@ -751,26 +743,13 @@ implements http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">StringdumpQueue() - - - - - -requestRegionsMerge -publicvoidrequestRegionsMerge(Regiona, -Regionb, -booleanforcible, -longmasterSystemTime, -Useruser) - - requestSplit -publicbooleanrequestSplit(Regionr) +publicbooleanrequestSplit(Regionr) @@ -779,7 +758,7 @@ implements requestSplit -publicvoidrequestSplit(Regionr, +publicvoidrequestSplit(Regionr, byte[]midKey) @@ -789,7 +768,7 @@ implements requestSplit -publicvoidrequestSplit(Regionr, +publicvoidrequestSplit(Regionr, byte[]midKey, Useruser) @@ -800,7 +779,7 @@ implements requestCompaction -publichttp://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true; title="class or interface in java.util">ListCompactionRequestrequestCompaction(Regionr, +publichttp://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true; title="class or interface in java.util">ListCompactionRequestrequestCompaction(Regionr, http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">Stringwhy) throws http://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true; title="class or interface in java.io">IOException @@ -823,7 +802,7 @@ implements requestCompaction -publichttp://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true; title="class or interface in java.util">ListCompactionRequestrequestCompaction(Regionr, +publichttp://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true; title="class or interface in
[43/51] [partial] hbase-site git commit: Published site at 82d554e3783372cc6b05489452c815b57c06f6cd.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/0383a9c2/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 60b4d76..df74f06 100644 --- a/devapidocs/org/apache/hadoop/hbase/master/MasterCoprocessorHost.html +++ b/devapidocs/org/apache/hadoop/hbase/master/MasterCoprocessorHost.html @@ -18,7 +18,7 @@ catch(err) { } //--> -var methods = {"i0":10,"i1":10,"i2":10,"i3":10,"i4":10,"i5":10,"i6":10,"i7":10,"i8":10,"i9":10,"i10":10,"i11":10,"i12":10,"i13":10,"i14":10,"i15":10,"i16":10,"i17":10,"i18":10,"i19":10,"i20":10,"i21":10,"i22":10,"i23":10,"i24":10,"i25":10,"i26":10,"i27":10,"i28":10,"i29":10,"i30":10,"i31":10,"i32":10,"i33":10,"i34":10,"i35":10,"i36":10,"i37":10,"i38":10,"i39":10,"i40":10,"i41":10,"i42":10,"i43":10,"i44":10,"i45":10,"i46":10,"i47":10,"i48":10,"i49":10,"i50":10,"i51":10,"i52":10,"i53":10,"i54":10,"i55":10,"i56":10,"i57":10,"i58":10,"i59":10,"i60":10,"i61":10,"i62":10,"i63":10,"i64":10,"i65":10,"i66":10,"i67":10,"i68":10,"i69":10,"i70":10,"i71":10,"i72":10,"i73":10,"i74":10,"i75":10,"i76":10,"i77":10,"i78":10,"i79":10,"i80":10,"i81":10,"i82":10,"i83":10,"i84":10,"i85":10,"i86":10,"i87":10,"i88":10,"i89":10,"i90":10,"i91":10,"i92":10,"i93":10,"i94":10,"i95":10,"i96":10,"i97":10,"i98":10,"i99":10,"i100":10,"i101":10,"i102":10,"i103":10,"i104":10,"i105":10,"i106":10,"i107":10,"i108":10,"i 109":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 methods = {"i0":10,"i1":10,"i2":10,"i3":10,"i4":10,"i5":10,"i6":10,"i7":10,"i8":10,"i9":10,"i10":10,"i11":10,"i12":10,"i13":10,"i14":10,"i15":10,"i16":10,"i17":10,"i18":10,"i19":10,"i20":10,"i21":10,"i22":10,"i23":10,"i24":10,"i25":10,"i26":10,"i27":10,"i28":10,"i29":10,"i30":10,"i31":10,"i32":10,"i33":10,"i34":10,"i35":10,"i36":10,"i37":10,"i38":10,"i39":10,"i40":10,"i41":10,"i42":10,"i43":10,"i44":10,"i45":10,"i46":10,"i47":10,"i48":10,"i49":10,"i50":10,"i51":10,"i52":10,"i53":10,"i54":10,"i55":10,"i56":10,"i57":10,"i58":10,"i59":10,"i60":10,"i61":10,"i62":10,"i63":10,"i64":10,"i65":10,"i66":10,"i67":10,"i68":10,"i69":10,"i70":10,"i71":10,"i72":10,"i73":10,"i74":10,"i75":10,"i76":10,"i77":10,"i78":10,"i79":10,"i80":10,"i81":10,"i82":10,"i83":10,"i84":10,"i85":10,"i86":10,"i87":10,"i88":10,"i89":10,"i90":10,"i91":10,"i92":10,"i93":10,"i94":10,"i95":10,"i96":10,"i97":10,"i98":10,"i99":10,"i100":10,"i101":10,"i102":10,"i103":10,"i104":10,"i105":10,"i106":10,"i107":10,"i108":10,"i 109":10,"i110":10,"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}; var tabs = {65535:["t0","All Methods"],2:["t2","Instance Methods"],8:["t4","Concrete Methods"]}; var altColor = "altColor"; var rowColor = "rowColor"; @@ -392,66 +392,61 @@ extends void -postDispatchMerge(HRegionInforegionInfoA, - HRegionInforegionInfoB) - - -void postEnableReplicationPeer(http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">StringpeerId) - + void postEnableTable(TableNametableName) - + void postGetNamespaceDescriptor(NamespaceDescriptorns) - + void postGetReplicationPeerConfig(http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">StringpeerId) - + void postGetTableDescriptors(http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true; title="class or interface in java.util">ListTableNametableNamesList, http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true; title="class or interface in java.util">ListHTableDescriptordescriptors, http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">Stringregex) - + void postGetTableNames(http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true; title="class or interface in java.util">ListHTableDescriptordescriptors, http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">Stringregex) - + void
[14/51] [partial] hbase-site git commit: Published site at 82d554e3783372cc6b05489452c815b57c06f6cd.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/0383a9c2/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/CompactSplit.html -- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/CompactSplit.html b/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/CompactSplit.html index 06b7a03..7dabb5e 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/CompactSplit.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/CompactSplit.html @@ -216,519 +216,505 @@ 208return queueLists.toString(); 209 } 210 -211 public synchronized void requestRegionsMerge(final Region a, -212 final Region b, final boolean forcible, long masterSystemTime, User user) { -213try { -214 mergePool.execute(new RegionMergeRequest(a, b, this.server, forcible, masterSystemTime,user)); -215 if (LOG.isDebugEnabled()) { -216LOG.debug("Region merge requested for " + a + "," + b + ", forcible=" -217+ forcible + ". " + this); +211 public synchronized boolean requestSplit(final Region r) { +212// don't split regions that are blocking +213if (shouldSplitRegion() ((HRegion)r).getCompactPriority() = Store.PRIORITY_USER) { +214 byte[] midKey = ((HRegion)r).checkSplit(); +215 if (midKey != null) { +216requestSplit(r, midKey); +217return true; 218 } -219} catch (RejectedExecutionException ree) { -220 LOG.warn("Could not execute merge for " + a + "," + b + ", forcible=" -221 + forcible, ree); -222} -223 } -224 -225 public synchronized boolean requestSplit(final Region r) { -226// don't split regions that are blocking -227if (shouldSplitRegion() ((HRegion)r).getCompactPriority() = Store.PRIORITY_USER) { -228 byte[] midKey = ((HRegion)r).checkSplit(); -229 if (midKey != null) { -230requestSplit(r, midKey); -231return true; -232 } -233} -234return false; -235 } -236 -237 public synchronized void requestSplit(final Region r, byte[] midKey) { -238requestSplit(r, midKey, null); -239 } -240 -241 /* -242 * The User parameter allows the split thread to assume the correct user identity -243 */ -244 public synchronized void requestSplit(final Region r, byte[] midKey, User user) { -245if (midKey == null) { -246 LOG.debug("Region " + r.getRegionInfo().getRegionNameAsString() + -247" not splittable because midkey=null"); -248 if (((HRegion)r).shouldForceSplit()) { -249((HRegion)r).clearSplit(); -250 } -251 return; -252} -253try { -254 this.splits.execute(new SplitRequest(r, midKey, this.server, user)); -255 if (LOG.isDebugEnabled()) { -256LOG.debug("Splitting " + r + ", " + this); -257 } -258} catch (RejectedExecutionException ree) { -259 LOG.info("Could not execute split for " + r, ree); -260} -261 } -262 -263 @Override -264 public synchronized ListCompactionRequest requestCompaction(final Region r, final String why) -265 throws IOException { -266return requestCompaction(r, why, null); -267 } -268 -269 @Override -270 public synchronized ListCompactionRequest requestCompaction(final Region r, final String why, -271 ListPairCompactionRequest, Store requests) throws IOException { -272return requestCompaction(r, why, Store.NO_PRIORITY, requests, null); -273 } -274 -275 @Override -276 public synchronized CompactionRequest requestCompaction(final Region r, final Store s, -277 final String why, CompactionRequest request) throws IOException { -278return requestCompaction(r, s, why, Store.NO_PRIORITY, request, null); -279 } -280 -281 @Override -282 public synchronized ListCompactionRequest requestCompaction(final Region r, final String why, -283 int p, ListPairCompactionRequest, Store requests, User user) throws IOException { -284return requestCompactionInternal(r, why, p, requests, true, user); -285 } -286 -287 private ListCompactionRequest requestCompactionInternal(final Region r, final String why, -288 int p, ListPairCompactionRequest, Store requests, boolean selectNow, User user) -289 throws IOException { -290// not a special compaction request, so make our own list -291ListCompactionRequest ret = null; -292if (requests == null) { -293 ret = selectNow ? new ArrayListCompactionRequest(r.getStores().size()) : null; -294 for (Store s : r.getStores()) { -295CompactionRequest cr = requestCompactionInternal(r, s, why, p, null, selectNow, user); -296if (selectNow) ret.add(cr); -297 } -298} else { -299 Preconditions.checkArgument(selectNow); // only system requests have selectNow == false -300 ret = new ArrayListCompactionRequest(requests.size()); -301 for (PairCompactionRequest, Store pair : requests) { -302
[33/51] [partial] hbase-site git commit: Published site at 82d554e3783372cc6b05489452c815b57c06f6cd.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/0383a9c2/devapidocs/org/apache/hadoop/hbase/regionserver/class-use/Region.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/regionserver/class-use/Region.html b/devapidocs/org/apache/hadoop/hbase/regionserver/class-use/Region.html index 744adb8..0753549 100644 --- a/devapidocs/org/apache/hadoop/hbase/regionserver/class-use/Region.html +++ b/devapidocs/org/apache/hadoop/hbase/regionserver/class-use/Region.html @@ -897,45 +897,37 @@ booleanforceFlushAllStores) -void -CompactSplit.requestRegionsMerge(Regiona, - Regionb, - booleanforcible, - longmasterSystemTime, - Useruser) - - boolean CompactSplit.requestSplit(Regionr) - + void CompactSplit.requestSplit(Regionr, byte[]midKey) - + void CompactSplit.requestSplit(Regionr, byte[]midKey, Useruser) - + void CompactSplit.requestSystemCompaction(Regionr, Stores, http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">Stringwhy) - + void CompactSplit.requestSystemCompaction(Regionr, http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">Stringwhy) - + http://docs.oracle.com/javase/8/docs/api/java/util/Map.html?is-external=true; title="class or interface in java.util">Mapbyte[],http://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 SecureBulkLoadManager.secureBulkLoadHFiles(Regionregion, org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.BulkLoadHFileRequestrequest) - + private CompactionContext CompactSplit.selectCompaction(Regionr, Stores, @@ -943,7 +935,7 @@ CompactionRequestrequest, Useruser) - + private void HRegionServer.updateRecoveringRegionLastFlushedSequenceId(Regionr) A helper function to store the last flushed sequence Id with the previous failed RS for a http://git-wip-us.apache.org/repos/asf/hbase-site/blob/0383a9c2/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 0006a5a..22817f5 100644 --- a/devapidocs/org/apache/hadoop/hbase/regionserver/package-tree.html +++ b/devapidocs/org/apache/hadoop/hbase/regionserver/package-tree.html @@ -692,20 +692,20 @@ java.lang.http://docs.oracle.com/javase/8/docs/api/java/lang/Enum.html?is-external=true; title="class or interface in java.lang">EnumE (implements java.lang.http://docs.oracle.com/javase/8/docs/api/java/lang/Comparable.html?is-external=true; title="class or interface in java.lang">ComparableT, java.io.http://docs.oracle.com/javase/8/docs/api/java/io/Serializable.html?is-external=true; title="class or interface in java.io">Serializable) +org.apache.hadoop.hbase.regionserver.ScanType org.apache.hadoop.hbase.regionserver.DefaultHeapMemoryTuner.StepDirection -org.apache.hadoop.hbase.regionserver.CompactingMemStore.IndexType -org.apache.hadoop.hbase.regionserver.FlushType -org.apache.hadoop.hbase.regionserver.RegionOpeningState +org.apache.hadoop.hbase.regionserver.BloomType +org.apache.hadoop.hbase.regionserver.Region.FlushResult.Result +org.apache.hadoop.hbase.regionserver.Region.Operation org.apache.hadoop.hbase.regionserver.ScannerContext.LimitScope +org.apache.hadoop.hbase.regionserver.ScannerContext.NextState org.apache.hadoop.hbase.regionserver.MetricsRegionServerSourceFactoryImpl.FactoryStorage -org.apache.hadoop.hbase.regionserver.StoreScanner.StoreScannerCompactionRace +org.apache.hadoop.hbase.regionserver.CompactingMemStore.IndexType org.apache.hadoop.hbase.regionserver.MemStoreCompactor.Action org.apache.hadoop.hbase.regionserver.SplitLogWorker.TaskExecutor.Status -org.apache.hadoop.hbase.regionserver.Region.FlushResult.Result -org.apache.hadoop.hbase.regionserver.ScanType -org.apache.hadoop.hbase.regionserver.Region.Operation -org.apache.hadoop.hbase.regionserver.BloomType -org.apache.hadoop.hbase.regionserver.ScannerContext.NextState +org.apache.hadoop.hbase.regionserver.RegionOpeningState +org.apache.hadoop.hbase.regionserver.FlushType +org.apache.hadoop.hbase.regionserver.StoreScanner.StoreScannerCompactionRace http://git-wip-us.apache.org/repos/asf/hbase-site/blob/0383a9c2/devapidocs/org/apache/hadoop/hbase/regionserver/querymatcher/package-tree.html -- diff --git
[02/51] [partial] hbase-site git commit: Published site at 82d554e3783372cc6b05489452c815b57c06f6cd.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/0383a9c2/testdevapidocs/org/apache/hadoop/hbase/chaos/actions/Action.html -- diff --git a/testdevapidocs/org/apache/hadoop/hbase/chaos/actions/Action.html b/testdevapidocs/org/apache/hadoop/hbase/chaos/actions/Action.html index 8cd660c..4872b99 100644 --- a/testdevapidocs/org/apache/hadoop/hbase/chaos/actions/Action.html +++ b/testdevapidocs/org/apache/hadoop/hbase/chaos/actions/Action.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}; +var methods = {"i0":10,"i1":10,"i2":10,"i3":10,"i4":10,"i5":10,"i6":10,"i7":10,"i8":10,"i9":10,"i10":10,"i11":10,"i12":10,"i13":10,"i14":10,"i15":10}; var tabs = {65535:["t0","All Methods"],2:["t2","Instance Methods"],8:["t4","Concrete Methods"]}; var altColor = "altColor"; var rowColor = "rowColor"; @@ -113,7 +113,7 @@ var activeTableTab = "activeTableTab"; -public class Action +public class Action extends http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true; title="class or interface in java.lang">Object A (possibly mischievous) action that the ChaosMonkey can perform. @@ -338,26 +338,40 @@ extends http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? killZKNode(org.apache.hadoop.hbase.ServerNameserver) +protected void +modifyAllTableColumns(org.apache.hadoop.hbase.TableNametableName, + http://docs.oracle.com/javase/8/docs/api/java/util/function/BiConsumer.html?is-external=true; title="class or interface in java.util.function">BiConsumerhttp://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String,org.apache.hadoop.hbase.client.ColumnFamilyDescriptorBuildertransform) +Apply a transform to all columns in a given table. + + + +protected void +modifyAllTableColumns(org.apache.hadoop.hbase.TableNametableName, + http://docs.oracle.com/javase/8/docs/api/java/util/function/Consumer.html?is-external=true; title="class or interface in java.util.function">Consumerorg.apache.hadoop.hbase.client.ColumnFamilyDescriptorBuildertransform) +Apply a transform to all columns in a given table. + + + void perform() - + protected void startDataNode(org.apache.hadoop.hbase.ServerNameserver) - + protected void startMaster(org.apache.hadoop.hbase.ServerNameserver) - + protected void startRs(org.apache.hadoop.hbase.ServerNameserver) - + protected void startZKNode(org.apache.hadoop.hbase.ServerNameserver) - + protected void unbalanceRegions(org.apache.hadoop.hbase.ClusterStatusclusterStatus, http://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.ServerNamefromServers, @@ -392,7 +406,7 @@ extends http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? KILL_MASTER_TIMEOUT_KEY -public static finalhttp://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String KILL_MASTER_TIMEOUT_KEY +public static finalhttp://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String KILL_MASTER_TIMEOUT_KEY See Also: Constant Field Values @@ -405,7 +419,7 @@ extends http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? START_MASTER_TIMEOUT_KEY -public static finalhttp://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String START_MASTER_TIMEOUT_KEY +public static finalhttp://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String START_MASTER_TIMEOUT_KEY See Also: Constant Field Values @@ -418,7 +432,7 @@ extends http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? KILL_RS_TIMEOUT_KEY -public static finalhttp://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String KILL_RS_TIMEOUT_KEY +public static finalhttp://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String KILL_RS_TIMEOUT_KEY See Also: Constant Field Values @@ -431,7 +445,7 @@ extends http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? START_RS_TIMEOUT_KEY -public static finalhttp://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String START_RS_TIMEOUT_KEY +public static finalhttp://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String START_RS_TIMEOUT_KEY See Also: Constant Field Values @@ -444,7
[07/51] [partial] hbase-site git commit: Published site at 82d554e3783372cc6b05489452c815b57c06f6cd.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/0383a9c2/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RSRpcServices.html -- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RSRpcServices.html b/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RSRpcServices.html index a945b54..422c076 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RSRpcServices.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RSRpcServices.html @@ -92,3454 +92,3410 @@ 084import org.apache.hadoop.hbase.client.VersionInfoUtil; 085import org.apache.hadoop.hbase.conf.ConfigurationObserver; 086import org.apache.hadoop.hbase.exceptions.FailedSanityCheckException; -087import org.apache.hadoop.hbase.exceptions.MergeRegionException; -088import org.apache.hadoop.hbase.exceptions.OutOfOrderScannerNextException; -089import org.apache.hadoop.hbase.exceptions.ScannerResetException; -090import org.apache.hadoop.hbase.filter.ByteArrayComparable; -091import org.apache.hadoop.hbase.filter.CompareFilter.CompareOp; -092import org.apache.hadoop.hbase.ipc.HBaseRPCErrorHandler; -093import org.apache.hadoop.hbase.ipc.HBaseRpcController; -094import org.apache.hadoop.hbase.ipc.PriorityFunction; -095import org.apache.hadoop.hbase.ipc.QosPriority; -096import org.apache.hadoop.hbase.ipc.RpcCallContext; -097import org.apache.hadoop.hbase.ipc.RpcCallback; -098import org.apache.hadoop.hbase.ipc.RpcServer; -099import org.apache.hadoop.hbase.ipc.RpcServer.BlockingServiceAndInterface; -100import org.apache.hadoop.hbase.ipc.RpcServerFactory; -101import org.apache.hadoop.hbase.ipc.RpcServerInterface; -102import org.apache.hadoop.hbase.ipc.ServerNotRunningYetException; -103import org.apache.hadoop.hbase.ipc.ServerRpcController; -104import org.apache.hadoop.hbase.master.MasterRpcServices; -105import org.apache.hadoop.hbase.quotas.ActivePolicyEnforcement; -106import org.apache.hadoop.hbase.quotas.OperationQuota; -107import org.apache.hadoop.hbase.quotas.QuotaUtil; -108import org.apache.hadoop.hbase.quotas.RegionServerRpcQuotaManager; -109import org.apache.hadoop.hbase.quotas.RegionServerSpaceQuotaManager; -110import org.apache.hadoop.hbase.quotas.SpaceQuotaSnapshot; -111import org.apache.hadoop.hbase.quotas.SpaceViolationPolicyEnforcement; -112import org.apache.hadoop.hbase.regionserver.HRegion.RegionScannerImpl; -113import org.apache.hadoop.hbase.regionserver.Leases.Lease; -114import org.apache.hadoop.hbase.regionserver.Leases.LeaseStillHeldException; -115import org.apache.hadoop.hbase.regionserver.Region.Operation; -116import org.apache.hadoop.hbase.regionserver.ScannerContext.LimitScope; -117import org.apache.hadoop.hbase.regionserver.handler.OpenMetaHandler; -118import org.apache.hadoop.hbase.regionserver.handler.OpenPriorityRegionHandler; -119import org.apache.hadoop.hbase.regionserver.handler.OpenRegionHandler; -120import org.apache.hadoop.hbase.regionserver.wal.WALEdit; -121import org.apache.hadoop.hbase.security.Superusers; -122import org.apache.hadoop.hbase.security.User; -123import org.apache.hadoop.hbase.shaded.com.google.protobuf.ByteString; -124import org.apache.hadoop.hbase.shaded.com.google.protobuf.Message; -125import org.apache.hadoop.hbase.shaded.com.google.protobuf.RpcController; -126import org.apache.hadoop.hbase.shaded.com.google.protobuf.ServiceException; -127import org.apache.hadoop.hbase.shaded.com.google.protobuf.TextFormat; -128import org.apache.hadoop.hbase.shaded.com.google.protobuf.UnsafeByteOperations; -129import org.apache.hadoop.hbase.shaded.protobuf.ProtobufUtil; -130import org.apache.hadoop.hbase.shaded.protobuf.RequestConverter; -131import org.apache.hadoop.hbase.shaded.protobuf.ResponseConverter; -132import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.AdminService; -133import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.ClearCompactionQueuesRequest; -134import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.ClearCompactionQueuesResponse; -135import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CloseRegionRequest; -136import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CloseRegionResponse; -137import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CompactRegionRequest; -138import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CompactRegionResponse; -139import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.ExecuteProceduresRequest; -140import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.ExecuteProceduresResponse; -141import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.FlushRegionRequest; -142import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.FlushRegionResponse; -143import
[10/51] [partial] hbase-site git commit: Published site at 82d554e3783372cc6b05489452c815b57c06f6cd.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/0383a9c2/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RSRpcServices.RegionScannerShippedCallBack.html -- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RSRpcServices.RegionScannerShippedCallBack.html b/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RSRpcServices.RegionScannerShippedCallBack.html index a945b54..422c076 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RSRpcServices.RegionScannerShippedCallBack.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/regionserver/RSRpcServices.RegionScannerShippedCallBack.html @@ -92,3454 +92,3410 @@ 084import org.apache.hadoop.hbase.client.VersionInfoUtil; 085import org.apache.hadoop.hbase.conf.ConfigurationObserver; 086import org.apache.hadoop.hbase.exceptions.FailedSanityCheckException; -087import org.apache.hadoop.hbase.exceptions.MergeRegionException; -088import org.apache.hadoop.hbase.exceptions.OutOfOrderScannerNextException; -089import org.apache.hadoop.hbase.exceptions.ScannerResetException; -090import org.apache.hadoop.hbase.filter.ByteArrayComparable; -091import org.apache.hadoop.hbase.filter.CompareFilter.CompareOp; -092import org.apache.hadoop.hbase.ipc.HBaseRPCErrorHandler; -093import org.apache.hadoop.hbase.ipc.HBaseRpcController; -094import org.apache.hadoop.hbase.ipc.PriorityFunction; -095import org.apache.hadoop.hbase.ipc.QosPriority; -096import org.apache.hadoop.hbase.ipc.RpcCallContext; -097import org.apache.hadoop.hbase.ipc.RpcCallback; -098import org.apache.hadoop.hbase.ipc.RpcServer; -099import org.apache.hadoop.hbase.ipc.RpcServer.BlockingServiceAndInterface; -100import org.apache.hadoop.hbase.ipc.RpcServerFactory; -101import org.apache.hadoop.hbase.ipc.RpcServerInterface; -102import org.apache.hadoop.hbase.ipc.ServerNotRunningYetException; -103import org.apache.hadoop.hbase.ipc.ServerRpcController; -104import org.apache.hadoop.hbase.master.MasterRpcServices; -105import org.apache.hadoop.hbase.quotas.ActivePolicyEnforcement; -106import org.apache.hadoop.hbase.quotas.OperationQuota; -107import org.apache.hadoop.hbase.quotas.QuotaUtil; -108import org.apache.hadoop.hbase.quotas.RegionServerRpcQuotaManager; -109import org.apache.hadoop.hbase.quotas.RegionServerSpaceQuotaManager; -110import org.apache.hadoop.hbase.quotas.SpaceQuotaSnapshot; -111import org.apache.hadoop.hbase.quotas.SpaceViolationPolicyEnforcement; -112import org.apache.hadoop.hbase.regionserver.HRegion.RegionScannerImpl; -113import org.apache.hadoop.hbase.regionserver.Leases.Lease; -114import org.apache.hadoop.hbase.regionserver.Leases.LeaseStillHeldException; -115import org.apache.hadoop.hbase.regionserver.Region.Operation; -116import org.apache.hadoop.hbase.regionserver.ScannerContext.LimitScope; -117import org.apache.hadoop.hbase.regionserver.handler.OpenMetaHandler; -118import org.apache.hadoop.hbase.regionserver.handler.OpenPriorityRegionHandler; -119import org.apache.hadoop.hbase.regionserver.handler.OpenRegionHandler; -120import org.apache.hadoop.hbase.regionserver.wal.WALEdit; -121import org.apache.hadoop.hbase.security.Superusers; -122import org.apache.hadoop.hbase.security.User; -123import org.apache.hadoop.hbase.shaded.com.google.protobuf.ByteString; -124import org.apache.hadoop.hbase.shaded.com.google.protobuf.Message; -125import org.apache.hadoop.hbase.shaded.com.google.protobuf.RpcController; -126import org.apache.hadoop.hbase.shaded.com.google.protobuf.ServiceException; -127import org.apache.hadoop.hbase.shaded.com.google.protobuf.TextFormat; -128import org.apache.hadoop.hbase.shaded.com.google.protobuf.UnsafeByteOperations; -129import org.apache.hadoop.hbase.shaded.protobuf.ProtobufUtil; -130import org.apache.hadoop.hbase.shaded.protobuf.RequestConverter; -131import org.apache.hadoop.hbase.shaded.protobuf.ResponseConverter; -132import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.AdminService; -133import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.ClearCompactionQueuesRequest; -134import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.ClearCompactionQueuesResponse; -135import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CloseRegionRequest; -136import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CloseRegionResponse; -137import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CompactRegionRequest; -138import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CompactRegionResponse; -139import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.ExecuteProceduresRequest; -140import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.ExecuteProceduresResponse; -141import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.FlushRegionRequest; -142import