hbase git commit: HBASE-16466 Snapshots support in VerifyReplication tool
Repository: hbase Updated Branches: refs/heads/master 78f6799f4 -> 2de6b051f HBASE-16466 Snapshots support in VerifyReplication tool Signed-off-by: Andrew PurtellProject: http://git-wip-us.apache.org/repos/asf/hbase/repo Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/2de6b051 Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/2de6b051 Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/2de6b051 Branch: refs/heads/master Commit: 2de6b051f67b6a55eda8d4e247328fda24484adb Parents: 78f6799 Author: Sukumar Maddineni Authored: Wed May 3 13:35:26 2017 -0700 Committer: Andrew Purtell Committed: Wed May 3 14:22:18 2017 -0700 -- .../mapreduce/TableSnapshotInputFormat.java | 5 + .../replication/VerifyReplication.java | 199 +++ .../replication/TestReplicationSmallTests.java | 123 +++- 3 files changed, 282 insertions(+), 45 deletions(-) -- http://git-wip-us.apache.org/repos/asf/hbase/blob/2de6b051/hbase-server/src/main/java/org/apache/hadoop/hbase/mapreduce/TableSnapshotInputFormat.java -- diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/mapreduce/TableSnapshotInputFormat.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/mapreduce/TableSnapshotInputFormat.java index 15d403f..a5f699d 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/mapreduce/TableSnapshotInputFormat.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/mapreduce/TableSnapshotInputFormat.java @@ -120,6 +120,11 @@ public class TableSnapshotInputFormat extends InputFormathttp://git-wip-us.apache.org/repos/asf/hbase/blob/2de6b051/hbase-server/src/main/java/org/apache/hadoop/hbase/mapreduce/replication/VerifyReplication.java -- diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/mapreduce/replication/VerifyReplication.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/mapreduce/replication/VerifyReplication.java index 3f8317b..3d32edd 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/mapreduce/replication/VerifyReplication.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/mapreduce/replication/VerifyReplication.java @@ -25,6 +25,8 @@ import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.conf.Configured; +import org.apache.hadoop.fs.FileSystem; +import org.apache.hadoop.fs.Path; import org.apache.hadoop.hbase.Abortable; import org.apache.hadoop.hbase.HBaseConfiguration; import org.apache.hadoop.hbase.TableName; @@ -36,6 +38,7 @@ import org.apache.hadoop.hbase.client.Result; import org.apache.hadoop.hbase.client.ResultScanner; import org.apache.hadoop.hbase.client.Scan; import org.apache.hadoop.hbase.client.Table; +import org.apache.hadoop.hbase.client.TableSnapshotScanner; import org.apache.hadoop.hbase.filter.Filter; import org.apache.hadoop.hbase.filter.FilterList; import org.apache.hadoop.hbase.filter.PrefixFilter; @@ -43,6 +46,7 @@ import org.apache.hadoop.hbase.io.ImmutableBytesWritable; import org.apache.hadoop.hbase.mapreduce.TableInputFormat; import org.apache.hadoop.hbase.mapreduce.TableMapReduceUtil; import org.apache.hadoop.hbase.mapreduce.TableMapper; +import org.apache.hadoop.hbase.mapreduce.TableSnapshotInputFormat; import org.apache.hadoop.hbase.mapreduce.TableSplit; import org.apache.hadoop.hbase.replication.ReplicationException; import org.apache.hadoop.hbase.replication.ReplicationFactory; @@ -50,14 +54,19 @@ import org.apache.hadoop.hbase.replication.ReplicationPeerConfig; import org.apache.hadoop.hbase.replication.ReplicationPeerZKImpl; import org.apache.hadoop.hbase.replication.ReplicationPeers; import org.apache.hadoop.hbase.util.Bytes; +import org.apache.hadoop.hbase.util.FSUtils; import org.apache.hadoop.hbase.util.Pair; import org.apache.hadoop.hbase.util.Threads; import org.apache.hadoop.hbase.zookeeper.ZooKeeperWatcher; +import org.apache.hadoop.mapreduce.InputSplit; import org.apache.hadoop.mapreduce.Job; +import org.apache.hadoop.mapreduce.MRJobConfig; import org.apache.hadoop.mapreduce.lib.output.NullOutputFormat; import org.apache.hadoop.util.Tool; import org.apache.hadoop.util.ToolRunner; +import com.google.common.annotations.VisibleForTesting; + /** * This map-only job compares the data from a local table with a remote one. * Every cell is compared and must have exactly the same keys (even timestamp) @@ -75,18 +84,31 @@ public class VerifyReplication extends Configured implements Tool { public final static String NAME = "verifyrep"; private final static String
[1/2] hbase git commit: Addendum patch for HBASE-12870. Added check for null pointer.
Repository: hbase Updated Branches: refs/heads/branch-1 9f25836d9 -> e08277ac8 refs/heads/master ff998ef74 -> 78f6799f4 Addendum patch for HBASE-12870. Added check for null pointer. Signed-off-by: Andrew PurtellProject: http://git-wip-us.apache.org/repos/asf/hbase/repo Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/78f6799f Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/78f6799f Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/78f6799f Branch: refs/heads/master Commit: 78f6799f4d53bea368caec77ff32db35109bd96b Parents: ff998ef Author: Chinmay Kulkarni Authored: Wed May 3 13:34:56 2017 -0700 Committer: Andrew Purtell Committed: Wed May 3 14:03:16 2017 -0700 -- .../regionserver/compactions/RatioBasedCompactionPolicy.java| 5 - 1 file changed, 4 insertions(+), 1 deletion(-) -- http://git-wip-us.apache.org/repos/asf/hbase/blob/78f6799f/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/compactions/RatioBasedCompactionPolicy.java -- diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/compactions/RatioBasedCompactionPolicy.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/compactions/RatioBasedCompactionPolicy.java index ddc07cd..2ee051b 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/compactions/RatioBasedCompactionPolicy.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/compactions/RatioBasedCompactionPolicy.java @@ -72,7 +72,10 @@ public class RatioBasedCompactionPolicy extends SortedCompactionPolicy { regionInfo = this.toString(); } // Major compaction time has elapsed. - long cfTTL = this.storeConfigInfo.getStoreFileTtl(); + long cfTTL = HConstants.FOREVER; + if (this.storeConfigInfo != null) { + cfTTL = this.storeConfigInfo.getStoreFileTtl(); + } if (filesToCompact.size() == 1) { // Single file StoreFile sf = filesToCompact.iterator().next();
[2/2] hbase git commit: Addendum patch for HBASE-12870. Added check for null pointer.
Addendum patch for HBASE-12870. Added check for null pointer. Signed-off-by: Andrew PurtellProject: http://git-wip-us.apache.org/repos/asf/hbase/repo Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/e08277ac Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/e08277ac Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/e08277ac Branch: refs/heads/branch-1 Commit: e08277ac8fe466bf63f6fc342256ab7b8d41243a Parents: 9f25836 Author: Chinmay Kulkarni Authored: Wed May 3 13:34:56 2017 -0700 Committer: Andrew Purtell Committed: Wed May 3 14:03:27 2017 -0700 -- .../regionserver/compactions/RatioBasedCompactionPolicy.java| 5 - 1 file changed, 4 insertions(+), 1 deletion(-) -- http://git-wip-us.apache.org/repos/asf/hbase/blob/e08277ac/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/compactions/RatioBasedCompactionPolicy.java -- diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/compactions/RatioBasedCompactionPolicy.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/compactions/RatioBasedCompactionPolicy.java index 9f476d3..2d8772c 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/compactions/RatioBasedCompactionPolicy.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/compactions/RatioBasedCompactionPolicy.java @@ -72,7 +72,10 @@ public class RatioBasedCompactionPolicy extends SortedCompactionPolicy { regionInfo = this.toString(); } // Major compaction time has elapsed. - long cfTTL = this.storeConfigInfo.getStoreFileTtl(); + long cfTTL = HConstants.FOREVER; + if (this.storeConfigInfo != null) { + cfTTL = this.storeConfigInfo.getStoreFileTtl(); + } if (filesToCompact.size() == 1) { // Single file StoreFile sf = filesToCompact.iterator().next();
hbase git commit: HBASE-17978 Ensure superusers can circumvent actions restricted by space quota violations
Repository: hbase Updated Branches: refs/heads/HBASE-16961 ea14f -> 06f71477c HBASE-17978 Ensure superusers can circumvent actions restricted by space quota violations Project: http://git-wip-us.apache.org/repos/asf/hbase/repo Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/06f71477 Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/06f71477 Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/06f71477 Branch: refs/heads/HBASE-16961 Commit: 06f71477c087b7c695786042e353769578dfd74c Parents: ea1 Author: Josh ElserAuthored: Wed May 3 12:10:50 2017 -0400 Committer: Josh Elser Committed: Wed May 3 17:01:56 2017 -0400 -- .../hbase/regionserver/RSRpcServices.java | 4 + .../hbase/quotas/SpaceQuotaHelperForTests.java | 27 +- .../quotas/TestSuperUserQuotaPermissions.java | 300 +++ 3 files changed, 329 insertions(+), 2 deletions(-) -- http://git-wip-us.apache.org/repos/asf/hbase/blob/06f71477/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/RSRpcServices.java -- diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/RSRpcServices.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/RSRpcServices.java index 679bba2..56fccce 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/RSRpcServices.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/RSRpcServices.java @@ -112,6 +112,7 @@ import org.apache.hadoop.hbase.regionserver.handler.OpenMetaHandler; import org.apache.hadoop.hbase.regionserver.handler.OpenPriorityRegionHandler; import org.apache.hadoop.hbase.regionserver.handler.OpenRegionHandler; import org.apache.hadoop.hbase.regionserver.wal.WALEdit; +import org.apache.hadoop.hbase.security.Superusers; import org.apache.hadoop.hbase.security.User; import org.apache.hadoop.hbase.shaded.com.google.protobuf.ByteString; import org.apache.hadoop.hbase.shaded.com.google.protobuf.Message; @@ -1471,7 +1472,10 @@ public class RSRpcServices implements HBaseRPCErrorHandler, checkOpen(); requestCount.increment(); Region region = getRegion(request.getRegion()); + // Quota support is enabled, the requesting user is not system/super user + // and a quota policy is enforced that disables compactions. if (QuotaUtil.isQuotaEnabled(getConfiguration()) && + !Superusers.isSuperUser(RpcServer.getRequestUser()) && this.regionServer.getRegionServerSpaceQuotaManager().areCompactionsDisabled( region.getTableDesc().getTableName())) { throw new DoNotRetryIOException("Compactions on this region are " http://git-wip-us.apache.org/repos/asf/hbase/blob/06f71477/hbase-server/src/test/java/org/apache/hadoop/hbase/quotas/SpaceQuotaHelperForTests.java -- diff --git a/hbase-server/src/test/java/org/apache/hadoop/hbase/quotas/SpaceQuotaHelperForTests.java b/hbase-server/src/test/java/org/apache/hadoop/hbase/quotas/SpaceQuotaHelperForTests.java index b7c51a2..1e2235a 100644 --- a/hbase-server/src/test/java/org/apache/hadoop/hbase/quotas/SpaceQuotaHelperForTests.java +++ b/hbase-server/src/test/java/org/apache/hadoop/hbase/quotas/SpaceQuotaHelperForTests.java @@ -110,6 +110,18 @@ public class SpaceQuotaHelperForTests { } } + QuotaSettings getTableSpaceQuota(Connection conn, TableName tn) throws IOException { +try (QuotaRetriever scanner = QuotaRetriever.open( +conn.getConfiguration(), new QuotaFilter().setTableFilter(tn.getNameAsString( { + for (QuotaSettings setting : scanner) { +if (setting.getTableName().equals(tn) && setting.getQuotaType() == QuotaType.SPACE) { + return setting; +} + } + return null; +} + } + /** * Waits 30seconds for the HBase quota table to exist. */ @@ -130,7 +142,10 @@ public class SpaceQuotaHelperForTests { } void writeData(TableName tn, long sizeInBytes) throws IOException { -final Connection conn = testUtil.getConnection(); +writeData(testUtil.getConnection(), tn, sizeInBytes); + } + + void writeData(Connection conn, TableName tn, long sizeInBytes) throws IOException { final Table table = conn.getTable(tn); try { List updates = new ArrayList<>(); @@ -226,8 +241,16 @@ public class SpaceQuotaHelperForTests { return createTableWithRegions(NamespaceDescriptor.DEFAULT_NAMESPACE_NAME_STR, numRegions); } + TableName createTableWithRegions(Admin admin, int numRegions) throws Exception { +return createTableWithRegions( +testUtil.getAdmin(), NamespaceDescriptor.DEFAULT_NAMESPACE_NAME_STR, numRegions); + } +
hbase git commit: HBASE-17981 Consolidate the space quota shell commands
Repository: hbase Updated Branches: refs/heads/HBASE-16961 0d5028664 -> ea14f HBASE-17981 Consolidate the space quota shell commands Project: http://git-wip-us.apache.org/repos/asf/hbase/repo Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/ea14 Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/ea14 Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/ea14 Branch: refs/heads/HBASE-16961 Commit: ea14f0def18b5f05bcf596c4738480cb7304 Parents: 0d50286 Author: Josh ElserAuthored: Mon May 1 19:44:47 2017 -0400 Committer: Josh Elser Committed: Wed May 3 16:48:17 2017 -0400 -- .../hadoop/hbase/client/QuotaStatusCalls.java | 29 --- .../hadoop/hbase/quotas/QuotaTableUtil.java | 44 -- .../shaded/protobuf/generated/AdminProtos.java | 90 +--- .../src/main/protobuf/Admin.proto | 4 - .../src/main/protobuf/Quota.proto | 12 --- .../hbase/regionserver/RSRpcServices.java | 30 --- .../hadoop/hbase/master/MockRegionServer.java | 9 -- .../hbase/quotas/TestQuotaStatusRPCs.java | 13 +-- hbase-shell/src/main/ruby/hbase/quotas.rb | 18 ++-- hbase-shell/src/main/ruby/hbase_constants.rb| 1 + hbase-shell/src/main/ruby/shell.rb | 1 - .../ruby/shell/commands/list_quota_snapshots.rb | 48 --- .../shell/commands/list_quota_table_sizes.rb| 8 +- .../shell/commands/list_quota_violations.rb | 48 --- .../test/ruby/hbase/quotas_test_no_cluster.rb | 19 - 15 files changed, 101 insertions(+), 273 deletions(-) -- http://git-wip-us.apache.org/repos/asf/hbase/blob/ea14/hbase-client/src/main/java/org/apache/hadoop/hbase/client/QuotaStatusCalls.java -- diff --git a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/QuotaStatusCalls.java b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/QuotaStatusCalls.java index af36d1e..70f6fb6 100644 --- a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/QuotaStatusCalls.java +++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/QuotaStatusCalls.java @@ -26,7 +26,6 @@ import org.apache.hadoop.hbase.shaded.protobuf.ProtobufUtil; import org.apache.hadoop.hbase.shaded.protobuf.RequestConverter; import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.AdminService; import org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.GetQuotaStatesResponse; -import org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.GetSpaceQuotaEnforcementsResponse; import org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.GetSpaceQuotaRegionSizesResponse; import org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.GetSpaceQuotaSnapshotsResponse; @@ -127,32 +126,4 @@ public class QuotaStatusCalls { }; return ProtobufUtil.call(callable); } - - /** - * See {@link #getRegionServerSpaceQuotaEnforcements(ClusterConnection, RpcControllerFactory, int, ServerName)} - */ - public static GetSpaceQuotaEnforcementsResponse getRegionServerSpaceQuotaEnforcements( - ClusterConnection clusterConn, int timeout, ServerName sn) throws IOException { -RpcControllerFactory rpcController = clusterConn.getRpcControllerFactory(); -return getRegionServerSpaceQuotaEnforcements(clusterConn, rpcController, timeout, sn); - } - - /** - * Executes an RPC to the RegionServer identified by the {@code ServerName} to fetch its view on - * enforced space quotas. - */ - public static GetSpaceQuotaEnforcementsResponse getRegionServerSpaceQuotaEnforcements( - ClusterConnection conn, RpcControllerFactory factory, - int timeout, ServerName sn) throws IOException { -final AdminService.BlockingInterface admin = conn.getAdmin(sn); -Callable callable = -new Callable() { - @Override - public GetSpaceQuotaEnforcementsResponse call() throws Exception { -return admin.getSpaceQuotaEnforcements( -factory.newController(), RequestConverter.buildGetSpaceQuotaEnforcementsRequest()); - } -}; -return ProtobufUtil.call(callable); - } } http://git-wip-us.apache.org/repos/asf/hbase/blob/ea14/hbase-client/src/main/java/org/apache/hadoop/hbase/quotas/QuotaTableUtil.java -- diff --git a/hbase-client/src/main/java/org/apache/hadoop/hbase/quotas/QuotaTableUtil.java b/hbase-client/src/main/java/org/apache/hadoop/hbase/quotas/QuotaTableUtil.java index ec480c4..1b670e6 100644 --- a/hbase-client/src/main/java/org/apache/hadoop/hbase/quotas/QuotaTableUtil.java +++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/quotas/QuotaTableUtil.java @@ -42,6 +42,7 @@ import
[49/51] [partial] hbase-site git commit: Published site at 82d554e3783372cc6b05489452c815b57c06f6cd.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/31df4674/checkstyle.rss -- diff --git a/checkstyle.rss b/checkstyle.rss index 28ea0f4..085d37b 100644 --- a/checkstyle.rss +++ b/checkstyle.rss @@ -25,8 +25,8 @@ under the License. en-us 2007 - 2017 The Apache Software Foundation - File: 2155, - Errors: 14365, + File: 2156, + Errors: 14349, Warnings: 0, Infos: 0 @@ -10037,7 +10037,7 @@ under the License. 0 - 32 + 33 @@ -11787,7 +11787,7 @@ under the License. 0 - 59 + 25 @@ -12935,7 +12935,7 @@ under the License. 0 - 14 + 13 @@ -16827,7 +16827,7 @@ under the License. 0 - 56 + 36 @@ -16967,7 +16967,7 @@ under the License. 0 - 25 + 57 @@ -20262,6 +20262,20 @@ under the License. + http://hbase.apache.org/checkstyle.html#org.apache.hadoop.hbase.ipc.NettyRpcServer.java;>org/apache/hadoop/hbase/ipc/NettyRpcServer.java + + + 0 + + + 0 + + + 4 + + + + http://hbase.apache.org/checkstyle.html#org.apache.hadoop.hbase.client.DoNotRetryRegionException.java;>org/apache/hadoop/hbase/client/DoNotRetryRegionException.java @@ -29119,7 +29133,7 @@ under the License. 0 - 79 + 81 http://git-wip-us.apache.org/repos/asf/hbase-site/blob/31df4674/coc.html -- diff --git a/coc.html b/coc.html index 854eb4f..de71c04 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-05-02 + Last Published: 2017-05-03 http://git-wip-us.apache.org/repos/asf/hbase-site/blob/31df4674/cygwin.html -- diff --git a/cygwin.html b/cygwin.html index 22abda9..aaf1c69 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-05-02 + Last Published: 2017-05-03 http://git-wip-us.apache.org/repos/asf/hbase-site/blob/31df4674/dependencies.html -- diff --git a/dependencies.html b/dependencies.html index ced01b2..91ef443 100644 --- a/dependencies.html +++ b/dependencies.html @@ -7,7 +7,7 @@ - + Apache HBase Project Dependencies @@ -524,7 +524,7 @@ https://www.apache.org/;>The Apache Software Foundation. All rights reserved. - Last Published: 2017-05-02 + Last Published: 2017-05-03 http://git-wip-us.apache.org/repos/asf/hbase-site/blob/31df4674/dependency-convergence.html -- diff --git a/dependency-convergence.html b/dependency-convergence.html index 219a8a9..ec61385 100644 --- a/dependency-convergence.html +++ b/dependency-convergence.html @@ -7,7 +7,7 @@ - + Apache HBase Reactor
[05/51] [partial] hbase-site git commit: Published site at 82d554e3783372cc6b05489452c815b57c06f6cd.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/31df4674/devapidocs/src-html/org/apache/hadoop/hbase/client/AsyncHBaseAdmin.TruncateTableProcedureBiConsumer.html -- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/client/AsyncHBaseAdmin.TruncateTableProcedureBiConsumer.html b/devapidocs/src-html/org/apache/hadoop/hbase/client/AsyncHBaseAdmin.TruncateTableProcedureBiConsumer.html index f3f7a46..8750fa2 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/client/AsyncHBaseAdmin.TruncateTableProcedureBiConsumer.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/client/AsyncHBaseAdmin.TruncateTableProcedureBiConsumer.html @@ -56,2015 +56,2125 @@ 048import org.apache.hadoop.hbase.MetaTableAccessor; 049import org.apache.hadoop.hbase.MetaTableAccessor.QueryType; 050import org.apache.hadoop.hbase.NotServingRegionException; -051import org.apache.hadoop.hbase.RegionLocations; -052import org.apache.hadoop.hbase.ServerName; -053import org.apache.hadoop.hbase.NamespaceDescriptor; -054import org.apache.hadoop.hbase.HConstants; -055import org.apache.hadoop.hbase.TableExistsException; -056import org.apache.hadoop.hbase.TableName; -057import org.apache.hadoop.hbase.AsyncMetaTableAccessor; -058import org.apache.hadoop.hbase.TableNotDisabledException; -059import org.apache.hadoop.hbase.TableNotFoundException; -060import org.apache.hadoop.hbase.UnknownRegionException; -061import org.apache.hadoop.hbase.classification.InterfaceAudience; -062import org.apache.hadoop.hbase.classification.InterfaceStability; -063import org.apache.hadoop.hbase.client.AsyncRpcRetryingCallerFactory.AdminRequestCallerBuilder; -064import org.apache.hadoop.hbase.client.AsyncRpcRetryingCallerFactory.MasterRequestCallerBuilder; -065import org.apache.hadoop.hbase.client.Scan.ReadType; -066import org.apache.hadoop.hbase.client.replication.ReplicationSerDeHelper; -067import org.apache.hadoop.hbase.client.replication.TableCFs; -068import org.apache.hadoop.hbase.exceptions.DeserializationException; -069import org.apache.hadoop.hbase.ipc.HBaseRpcController; -070import org.apache.hadoop.hbase.quotas.QuotaFilter; -071import org.apache.hadoop.hbase.quotas.QuotaSettings; -072import org.apache.hadoop.hbase.quotas.QuotaTableUtil; -073import org.apache.hadoop.hbase.replication.ReplicationException; -074import org.apache.hadoop.hbase.replication.ReplicationPeerConfig; -075import org.apache.hadoop.hbase.replication.ReplicationPeerDescription; -076import org.apache.hadoop.hbase.shaded.com.google.protobuf.RpcCallback; -077import org.apache.hadoop.hbase.shaded.protobuf.ProtobufUtil; -078import org.apache.hadoop.hbase.shaded.protobuf.RequestConverter; -079import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.AdminService; -080import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CloseRegionRequest; -081import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CloseRegionResponse; -082import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.SplitRegionRequest; -083import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.SplitRegionResponse; -084import org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos; -085import org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.TableSchema; -086import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.AddColumnRequest; -087import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.AddColumnResponse; -088import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.AssignRegionRequest; -089import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.AssignRegionResponse; -090import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.BalanceRequest; -091import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.BalanceResponse; -092import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.CreateNamespaceRequest; -093import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.CreateNamespaceResponse; -094import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.DeleteNamespaceRequest; -095import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.DeleteNamespaceResponse; -096import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.DeleteSnapshotRequest; -097import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.DeleteSnapshotResponse; -098import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.DisableTableRequest; -099import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.DisableTableResponse; -100import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.EnableTableRequest; -101import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.EnableTableResponse; -102import
[11/51] [partial] hbase-site git commit: Published site at 82d554e3783372cc6b05489452c815b57c06f6cd.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/31df4674/devapidocs/src-html/org/apache/hadoop/hbase/client/AsyncHBaseAdmin.ModifyColumnFamilyProcedureBiConsumer.html -- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/client/AsyncHBaseAdmin.ModifyColumnFamilyProcedureBiConsumer.html b/devapidocs/src-html/org/apache/hadoop/hbase/client/AsyncHBaseAdmin.ModifyColumnFamilyProcedureBiConsumer.html index f3f7a46..8750fa2 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/client/AsyncHBaseAdmin.ModifyColumnFamilyProcedureBiConsumer.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/client/AsyncHBaseAdmin.ModifyColumnFamilyProcedureBiConsumer.html @@ -56,2015 +56,2125 @@ 048import org.apache.hadoop.hbase.MetaTableAccessor; 049import org.apache.hadoop.hbase.MetaTableAccessor.QueryType; 050import org.apache.hadoop.hbase.NotServingRegionException; -051import org.apache.hadoop.hbase.RegionLocations; -052import org.apache.hadoop.hbase.ServerName; -053import org.apache.hadoop.hbase.NamespaceDescriptor; -054import org.apache.hadoop.hbase.HConstants; -055import org.apache.hadoop.hbase.TableExistsException; -056import org.apache.hadoop.hbase.TableName; -057import org.apache.hadoop.hbase.AsyncMetaTableAccessor; -058import org.apache.hadoop.hbase.TableNotDisabledException; -059import org.apache.hadoop.hbase.TableNotFoundException; -060import org.apache.hadoop.hbase.UnknownRegionException; -061import org.apache.hadoop.hbase.classification.InterfaceAudience; -062import org.apache.hadoop.hbase.classification.InterfaceStability; -063import org.apache.hadoop.hbase.client.AsyncRpcRetryingCallerFactory.AdminRequestCallerBuilder; -064import org.apache.hadoop.hbase.client.AsyncRpcRetryingCallerFactory.MasterRequestCallerBuilder; -065import org.apache.hadoop.hbase.client.Scan.ReadType; -066import org.apache.hadoop.hbase.client.replication.ReplicationSerDeHelper; -067import org.apache.hadoop.hbase.client.replication.TableCFs; -068import org.apache.hadoop.hbase.exceptions.DeserializationException; -069import org.apache.hadoop.hbase.ipc.HBaseRpcController; -070import org.apache.hadoop.hbase.quotas.QuotaFilter; -071import org.apache.hadoop.hbase.quotas.QuotaSettings; -072import org.apache.hadoop.hbase.quotas.QuotaTableUtil; -073import org.apache.hadoop.hbase.replication.ReplicationException; -074import org.apache.hadoop.hbase.replication.ReplicationPeerConfig; -075import org.apache.hadoop.hbase.replication.ReplicationPeerDescription; -076import org.apache.hadoop.hbase.shaded.com.google.protobuf.RpcCallback; -077import org.apache.hadoop.hbase.shaded.protobuf.ProtobufUtil; -078import org.apache.hadoop.hbase.shaded.protobuf.RequestConverter; -079import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.AdminService; -080import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CloseRegionRequest; -081import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CloseRegionResponse; -082import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.SplitRegionRequest; -083import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.SplitRegionResponse; -084import org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos; -085import org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.TableSchema; -086import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.AddColumnRequest; -087import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.AddColumnResponse; -088import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.AssignRegionRequest; -089import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.AssignRegionResponse; -090import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.BalanceRequest; -091import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.BalanceResponse; -092import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.CreateNamespaceRequest; -093import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.CreateNamespaceResponse; -094import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.DeleteNamespaceRequest; -095import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.DeleteNamespaceResponse; -096import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.DeleteSnapshotRequest; -097import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.DeleteSnapshotResponse; -098import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.DisableTableRequest; -099import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.DisableTableResponse; -100import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.EnableTableRequest; -101import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.EnableTableResponse; -102import
[44/51] [partial] hbase-site git commit: Published site at 82d554e3783372cc6b05489452c815b57c06f6cd.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/31df4674/devapidocs/org/apache/hadoop/hbase/client/AsyncHBaseAdmin.AddColumnFamilyProcedureBiConsumer.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/client/AsyncHBaseAdmin.AddColumnFamilyProcedureBiConsumer.html b/devapidocs/org/apache/hadoop/hbase/client/AsyncHBaseAdmin.AddColumnFamilyProcedureBiConsumer.html index 8c9b13f..92d61bd 100644 --- a/devapidocs/org/apache/hadoop/hbase/client/AsyncHBaseAdmin.AddColumnFamilyProcedureBiConsumer.html +++ b/devapidocs/org/apache/hadoop/hbase/client/AsyncHBaseAdmin.AddColumnFamilyProcedureBiConsumer.html @@ -127,7 +127,7 @@ var activeTableTab = "activeTableTab"; -private class AsyncHBaseAdmin.AddColumnFamilyProcedureBiConsumer +private class AsyncHBaseAdmin.AddColumnFamilyProcedureBiConsumer extends AsyncHBaseAdmin.TableProcedureBiConsumer @@ -240,7 +240,7 @@ extends AddColumnFamilyProcedureBiConsumer -AddColumnFamilyProcedureBiConsumer(AsyncAdminadmin, +AddColumnFamilyProcedureBiConsumer(AsyncAdminadmin, TableNametableName) @@ -258,7 +258,7 @@ extends getOperationType -http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">StringgetOperationType() +http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">StringgetOperationType() Specified by: getOperationTypein classAsyncHBaseAdmin.TableProcedureBiConsumer http://git-wip-us.apache.org/repos/asf/hbase-site/blob/31df4674/devapidocs/org/apache/hadoop/hbase/client/AsyncHBaseAdmin.AdminRpcCall.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/client/AsyncHBaseAdmin.AdminRpcCall.html b/devapidocs/org/apache/hadoop/hbase/client/AsyncHBaseAdmin.AdminRpcCall.html index 9273bf9..11853c7 100644 --- a/devapidocs/org/apache/hadoop/hbase/client/AsyncHBaseAdmin.AdminRpcCall.html +++ b/devapidocs/org/apache/hadoop/hbase/client/AsyncHBaseAdmin.AdminRpcCall.html @@ -110,7 +110,7 @@ var activeTableTab = "activeTableTab"; http://docs.oracle.com/javase/8/docs/api/java/lang/FunctionalInterface.html?is-external=true; title="class or interface in java.lang">@FunctionalInterface -private static interface AsyncHBaseAdmin.AdminRpcCallRESP,REQ +private static interface AsyncHBaseAdmin.AdminRpcCallRESP,REQ @@ -159,7 +159,7 @@ private static interface call -voidcall(org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.AdminService.Interfacestub, +voidcall(org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.AdminService.Interfacestub, HBaseRpcControllercontroller, REQreq, org.apache.hadoop.hbase.shaded.com.google.protobuf.RpcCallbackRESPdone) http://git-wip-us.apache.org/repos/asf/hbase-site/blob/31df4674/devapidocs/org/apache/hadoop/hbase/client/AsyncHBaseAdmin.Converter.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/client/AsyncHBaseAdmin.Converter.html b/devapidocs/org/apache/hadoop/hbase/client/AsyncHBaseAdmin.Converter.html index 73c6916..36ca3f5 100644 --- a/devapidocs/org/apache/hadoop/hbase/client/AsyncHBaseAdmin.Converter.html +++ b/devapidocs/org/apache/hadoop/hbase/client/AsyncHBaseAdmin.Converter.html @@ -110,7 +110,7 @@ var activeTableTab = "activeTableTab"; http://docs.oracle.com/javase/8/docs/api/java/lang/FunctionalInterface.html?is-external=true; title="class or interface in java.lang">@FunctionalInterface -private static interface AsyncHBaseAdmin.ConverterD,S +private static interface AsyncHBaseAdmin.ConverterD,S @@ -156,7 +156,7 @@ private static interface convert -Dconvert(Ssrc) +Dconvert(Ssrc) throws http://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true; title="class or interface in java.io">IOException Throws: http://git-wip-us.apache.org/repos/asf/hbase-site/blob/31df4674/devapidocs/org/apache/hadoop/hbase/client/AsyncHBaseAdmin.CreateNamespaceProcedureBiConsumer.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/client/AsyncHBaseAdmin.CreateNamespaceProcedureBiConsumer.html b/devapidocs/org/apache/hadoop/hbase/client/AsyncHBaseAdmin.CreateNamespaceProcedureBiConsumer.html index 99d5a6a..4d37334 100644 --- a/devapidocs/org/apache/hadoop/hbase/client/AsyncHBaseAdmin.CreateNamespaceProcedureBiConsumer.html +++ b/devapidocs/org/apache/hadoop/hbase/client/AsyncHBaseAdmin.CreateNamespaceProcedureBiConsumer.html @@ -127,7 +127,7 @@ var activeTableTab = "activeTableTab"; -private class AsyncHBaseAdmin.CreateNamespaceProcedureBiConsumer +private class AsyncHBaseAdmin.CreateNamespaceProcedureBiConsumer extends
[45/51] [partial] hbase-site git commit: Published site at 82d554e3783372cc6b05489452c815b57c06f6cd.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/31df4674/devapidocs/org/apache/hadoop/hbase/client/AsyncAdmin.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/client/AsyncAdmin.html b/devapidocs/org/apache/hadoop/hbase/client/AsyncAdmin.html index 95aa8b8..5692d87 100644 --- a/devapidocs/org/apache/hadoop/hbase/client/AsyncAdmin.html +++ b/devapidocs/org/apache/hadoop/hbase/client/AsyncAdmin.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,"i60":6,"i61":6,"i62":6,"i63":6,"i64":6,"i65":6,"i66":6,"i67":6,"i68":6,"i69":6,"i70":6,"i71":6,"i72":6,"i73":6,"i74":6,"i75":6,"i76":6,"i77":6,"i78":6,"i79":6,"i80":6,"i81":6,"i82":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,"i59":6,"i60":6,"i61":6,"i62":6,"i63":6,"i64":6,"i65":6,"i66":6,"i67":6,"i68":6,"i69":6,"i70":6,"i71":6,"i72":6,"i73":6,"i74":6,"i75":6,"i76":6,"i77":6,"i78":6,"i79":6,"i80":6,"i81":6,"i82":6,"i83":6,"i84":6,"i85":6,"i86":6,"i87":6}; var tabs = {65535:["t0","All Methods"],2:["t2","Instance Methods"],4:["t3","Abstract Methods"]}; var altColor = "altColor"; var rowColor = "rowColor"; @@ -106,7 +106,7 @@ var activeTableTab = "activeTableTab"; @InterfaceAudience.Private -public interface AsyncAdmin +public interface AsyncAdmin The asynchronous administrative API for HBase. This feature is still under development, so marked as IA.Private. Will change to public when @@ -130,97 +130,104 @@ public interface Method and Description +http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/CompletableFuture.html?is-external=true; title="class or interface in java.util.concurrent">CompletableFuturehttp://docs.oracle.com/javase/8/docs/api/java/lang/Boolean.html?is-external=true; title="class or interface in java.lang">Boolean +abortProcedure(longprocId, + booleanmayInterruptIfRunning) +abort a procedure + + + http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/CompletableFuture.html?is-external=true; title="class or interface in java.util.concurrent">CompletableFuturehttp://docs.oracle.com/javase/8/docs/api/java/lang/Void.html?is-external=true; title="class or interface in java.lang">Void addColumnFamily(TableNametableName, HColumnDescriptorcolumnFamily) Add a column family to an existing table. - + http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/CompletableFuture.html?is-external=true; title="class or interface in java.util.concurrent">CompletableFuturehttp://docs.oracle.com/javase/8/docs/api/java/lang/Void.html?is-external=true; title="class or interface in java.lang">Void addReplicationPeer(http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">StringpeerId, ReplicationPeerConfigpeerConfig) Add a new replication peer for replicating data to slave cluster - + http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/CompletableFuture.html?is-external=true; title="class or interface in java.util.concurrent">CompletableFuturehttp://docs.oracle.com/javase/8/docs/api/java/lang/Void.html?is-external=true; title="class or interface in java.lang">Void appendReplicationPeerTableCFs(http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">Stringid, http://docs.oracle.com/javase/8/docs/api/java/util/Map.html?is-external=true; title="class or interface in java.util">MapTableName,? extends http://docs.oracle.com/javase/8/docs/api/java/util/Collection.html?is-external=true; title="class or interface in java.util">Collectionhttp://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">StringtableCfs) Append the replicable table-cf config of the specified peer - + http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/CompletableFuture.html?is-external=true; title="class or interface in
[38/51] [partial] hbase-site git commit: Published site at 82d554e3783372cc6b05489452c815b57c06f6cd.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/31df4674/devapidocs/org/apache/hadoop/hbase/ipc/NettyRpcServer.NettyConnection.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/ipc/NettyRpcServer.NettyConnection.html b/devapidocs/org/apache/hadoop/hbase/ipc/NettyRpcServer.NettyConnection.html new file mode 100644 index 000..c5d900b --- /dev/null +++ b/devapidocs/org/apache/hadoop/hbase/ipc/NettyRpcServer.NettyConnection.html @@ -0,0 +1,507 @@ +http://www.w3.org/TR/html4/loose.dtd;> + + + + + +NettyRpcServer.NettyConnection (Apache HBase 2.0.0-SNAPSHOT API) + + + + + +var methods = {"i0":10,"i1":10,"i2":10,"i3":10,"i4":10,"i5":10,"i6":10,"i7":10,"i8":10}; +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.ipc +Class NettyRpcServer.NettyConnection + + + +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.ipc.RpcServer.Connection + + +org.apache.hadoop.hbase.ipc.NettyRpcServer.NettyConnection + + + + + + + + + +All Implemented Interfaces: +http://docs.oracle.com/javase/8/docs/api/java/io/Closeable.html?is-external=true; title="class or interface in java.io">Closeable, http://docs.oracle.com/javase/8/docs/api/java/lang/AutoCloseable.html?is-external=true; title="class or interface in java.lang">AutoCloseable + + +Enclosing class: +NettyRpcServer + + + +public class NettyRpcServer.NettyConnection +extends RpcServer.Connection + + + + + + + + + + + +Field Summary + +Fields + +Modifier and Type +Field and Description + + +protected io.netty.channel.Channel +channel + + + + + + +Fields inherited from classorg.apache.hadoop.hbase.ipc.RpcServer.Connection +addr, attemptingUser, authenticatedWithFallback, authFailedCall, authFailedResponse, authMethod, AUTHORIZATION_FAILED_CALLID, callCleanup, codec, compressionCodec, CONNECTION_HEADER_RESPONSE_CALLID, connectionHeader, connectionHeaderRead, connectionPreambleRead, cryptoAES, hostAddress, remotePort, retryImmediatelySupported, SASL_CALLID, saslCall, saslContextEstablished, saslServer, service, setConnectionHeaderResponseCall, skipInitialSaslHandshake, ugi, useCryptoAesWrap, user, useSasl, useWrap + + + + + + + + +Constructor Summary + +Constructors + +Constructor and Description + + +NettyConnection(io.netty.channel.Channelchannel) + + + + + + + + + +Method Summary + +All MethodsInstance MethodsConcrete Methods + +Modifier and Type +Method and Description + + +void +close() + + +RpcServer.Call +createCall(intid, + org.apache.hadoop.hbase.shaded.com.google.protobuf.BlockingServiceservice, + org.apache.hadoop.hbase.shaded.com.google.protobuf.Descriptors.MethodDescriptormd, + org.apache.hadoop.hbase.shaded.protobuf.generated.RPCProtos.RequestHeaderheader, + org.apache.hadoop.hbase.shaded.com.google.protobuf.Messageparam, + CellScannercellScanner, + RpcServer.Connectionconnection, + longsize, + org.apache.htrace.TraceInfotinfo, + http://docs.oracle.com/javase/8/docs/api/java/net/InetAddress.html?is-external=true; title="class or interface in java.net">InetAddressremoteAddress, + inttimeout, + RpcServer.CallCleanupreqCleanup) + + +private void +doBadPreambleHandling(http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">Stringmsg) + + +private void +doBadPreambleHandling(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/Exception.html?is-external=true; title="class or interface in java.lang">Exceptione) + + +boolean +isConnectionOpen() + + +(package private) void +process(io.netty.buffer.ByteBufbuf) + + +(package private) void +process(ByteBuffbuf) + + +(package
[30/51] [partial] hbase-site git commit: Published site at 82d554e3783372cc6b05489452c815b57c06f6cd.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/31df4674/devapidocs/org/apache/hadoop/hbase/ipc/class-use/RpcServer.CallCleanup.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/ipc/class-use/RpcServer.CallCleanup.html b/devapidocs/org/apache/hadoop/hbase/ipc/class-use/RpcServer.CallCleanup.html index db06fac..22e9c56 100644 --- a/devapidocs/org/apache/hadoop/hbase/ipc/class-use/RpcServer.CallCleanup.html +++ b/devapidocs/org/apache/hadoop/hbase/ipc/class-use/RpcServer.CallCleanup.html @@ -131,6 +131,60 @@ + +Methods in org.apache.hadoop.hbase.ipc with parameters of type RpcServer.CallCleanup + +Modifier and Type +Method and Description + + + +abstract RpcServer.Call +RpcServer.Connection.createCall(intid, + org.apache.hadoop.hbase.shaded.com.google.protobuf.BlockingServiceservice, + org.apache.hadoop.hbase.shaded.com.google.protobuf.Descriptors.MethodDescriptormd, + org.apache.hadoop.hbase.shaded.protobuf.generated.RPCProtos.RequestHeaderheader, + org.apache.hadoop.hbase.shaded.com.google.protobuf.Messageparam, + CellScannercellScanner, + RpcServer.Connectionconnection, + longsize, + org.apache.htrace.TraceInfotinfo, + http://docs.oracle.com/javase/8/docs/api/java/net/InetAddress.html?is-external=true; title="class or interface in java.net">InetAddressremoteAddress, + inttimeout, + RpcServer.CallCleanupreqCleanup) + + +RpcServer.Call +SimpleRpcServer.Connection.createCall(intid, + org.apache.hadoop.hbase.shaded.com.google.protobuf.BlockingServiceservice, + org.apache.hadoop.hbase.shaded.com.google.protobuf.Descriptors.MethodDescriptormd, + org.apache.hadoop.hbase.shaded.protobuf.generated.RPCProtos.RequestHeaderheader, + org.apache.hadoop.hbase.shaded.com.google.protobuf.Messageparam, + CellScannercellScanner, + RpcServer.Connectionconnection, + longsize, + org.apache.htrace.TraceInfotinfo, + http://docs.oracle.com/javase/8/docs/api/java/net/InetAddress.html?is-external=true; title="class or interface in java.net">InetAddressremoteAddress, + inttimeout, + RpcServer.CallCleanupreqCleanup) + + +RpcServer.Call +NettyRpcServer.NettyConnection.createCall(intid, + org.apache.hadoop.hbase.shaded.com.google.protobuf.BlockingServiceservice, + org.apache.hadoop.hbase.shaded.com.google.protobuf.Descriptors.MethodDescriptormd, + org.apache.hadoop.hbase.shaded.protobuf.generated.RPCProtos.RequestHeaderheader, + org.apache.hadoop.hbase.shaded.com.google.protobuf.Messageparam, + CellScannercellScanner, + RpcServer.Connectionconnection, + longsize, + org.apache.htrace.TraceInfotinfo, + http://docs.oracle.com/javase/8/docs/api/java/net/InetAddress.html?is-external=true; title="class or interface in java.net">InetAddressremoteAddress, + inttimeout, + RpcServer.CallCleanupreqCleanup) + + + Constructors in org.apache.hadoop.hbase.ipc with parameters of type RpcServer.CallCleanup @@ -152,20 +206,34 @@ RpcServer.CallCleanupreqCleanup) -Call(intid, +Call(intid, org.apache.hadoop.hbase.shaded.com.google.protobuf.BlockingServiceservice, org.apache.hadoop.hbase.shaded.com.google.protobuf.Descriptors.MethodDescriptormd, org.apache.hadoop.hbase.shaded.protobuf.generated.RPCProtos.RequestHeaderheader, org.apache.hadoop.hbase.shaded.com.google.protobuf.Messageparam, CellScannercellScanner, -SimpleRpcServer.Connectionconnection, -SimpleRpcServer.Responderresponder, +RpcServer.Connectionconnection, longsize, org.apache.htrace.TraceInfotinfo, http://docs.oracle.com/javase/8/docs/api/java/net/InetAddress.html?is-external=true; title="class or interface in java.net">InetAddressremoteAddress, inttimeout, RpcServer.CallCleanupreqCleanup) + +Call(intid, + org.apache.hadoop.hbase.shaded.com.google.protobuf.BlockingServiceservice, + org.apache.hadoop.hbase.shaded.com.google.protobuf.Descriptors.MethodDescriptormd, + org.apache.hadoop.hbase.shaded.protobuf.generated.RPCProtos.RequestHeaderheader, +org.apache.hadoop.hbase.shaded.com.google.protobuf.Messageparam, +CellScannercellScanner, +RpcServer.Connectionconnection, +longsize, +org.apache.htrace.TraceInfotinfo, +http://docs.oracle.com/javase/8/docs/api/java/net/InetAddress.html?is-external=true; title="class or interface in java.net">InetAddressremoteAddress, +inttimeout, +RpcServer.CallCleanupreqCleanup, +SimpleRpcServer.Responderresponder) + http://git-wip-us.apache.org/repos/asf/hbase-site/blob/31df4674/devapidocs/org/apache/hadoop/hbase/ipc/class-use/RpcServer.Connection.html -- diff --git
[23/51] [partial] hbase-site git commit: Published site at 82d554e3783372cc6b05489452c815b57c06f6cd.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/31df4674/devapidocs/src-html/org/apache/hadoop/hbase/client/AsyncHBaseAdmin.AddColumnFamilyProcedureBiConsumer.html -- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/client/AsyncHBaseAdmin.AddColumnFamilyProcedureBiConsumer.html b/devapidocs/src-html/org/apache/hadoop/hbase/client/AsyncHBaseAdmin.AddColumnFamilyProcedureBiConsumer.html index f3f7a46..8750fa2 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/client/AsyncHBaseAdmin.AddColumnFamilyProcedureBiConsumer.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/client/AsyncHBaseAdmin.AddColumnFamilyProcedureBiConsumer.html @@ -56,2015 +56,2125 @@ 048import org.apache.hadoop.hbase.MetaTableAccessor; 049import org.apache.hadoop.hbase.MetaTableAccessor.QueryType; 050import org.apache.hadoop.hbase.NotServingRegionException; -051import org.apache.hadoop.hbase.RegionLocations; -052import org.apache.hadoop.hbase.ServerName; -053import org.apache.hadoop.hbase.NamespaceDescriptor; -054import org.apache.hadoop.hbase.HConstants; -055import org.apache.hadoop.hbase.TableExistsException; -056import org.apache.hadoop.hbase.TableName; -057import org.apache.hadoop.hbase.AsyncMetaTableAccessor; -058import org.apache.hadoop.hbase.TableNotDisabledException; -059import org.apache.hadoop.hbase.TableNotFoundException; -060import org.apache.hadoop.hbase.UnknownRegionException; -061import org.apache.hadoop.hbase.classification.InterfaceAudience; -062import org.apache.hadoop.hbase.classification.InterfaceStability; -063import org.apache.hadoop.hbase.client.AsyncRpcRetryingCallerFactory.AdminRequestCallerBuilder; -064import org.apache.hadoop.hbase.client.AsyncRpcRetryingCallerFactory.MasterRequestCallerBuilder; -065import org.apache.hadoop.hbase.client.Scan.ReadType; -066import org.apache.hadoop.hbase.client.replication.ReplicationSerDeHelper; -067import org.apache.hadoop.hbase.client.replication.TableCFs; -068import org.apache.hadoop.hbase.exceptions.DeserializationException; -069import org.apache.hadoop.hbase.ipc.HBaseRpcController; -070import org.apache.hadoop.hbase.quotas.QuotaFilter; -071import org.apache.hadoop.hbase.quotas.QuotaSettings; -072import org.apache.hadoop.hbase.quotas.QuotaTableUtil; -073import org.apache.hadoop.hbase.replication.ReplicationException; -074import org.apache.hadoop.hbase.replication.ReplicationPeerConfig; -075import org.apache.hadoop.hbase.replication.ReplicationPeerDescription; -076import org.apache.hadoop.hbase.shaded.com.google.protobuf.RpcCallback; -077import org.apache.hadoop.hbase.shaded.protobuf.ProtobufUtil; -078import org.apache.hadoop.hbase.shaded.protobuf.RequestConverter; -079import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.AdminService; -080import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CloseRegionRequest; -081import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CloseRegionResponse; -082import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.SplitRegionRequest; -083import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.SplitRegionResponse; -084import org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos; -085import org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.TableSchema; -086import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.AddColumnRequest; -087import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.AddColumnResponse; -088import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.AssignRegionRequest; -089import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.AssignRegionResponse; -090import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.BalanceRequest; -091import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.BalanceResponse; -092import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.CreateNamespaceRequest; -093import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.CreateNamespaceResponse; -094import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.DeleteNamespaceRequest; -095import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.DeleteNamespaceResponse; -096import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.DeleteSnapshotRequest; -097import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.DeleteSnapshotResponse; -098import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.DisableTableRequest; -099import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.DisableTableResponse; -100import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.EnableTableRequest; -101import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.EnableTableResponse; -102import
[03/51] [partial] hbase-site git commit: Published site at 82d554e3783372cc6b05489452c815b57c06f6cd.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/31df4674/devapidocs/src-html/org/apache/hadoop/hbase/client/HBaseAdmin.AbortProcedureFuture.html -- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/client/HBaseAdmin.AbortProcedureFuture.html b/devapidocs/src-html/org/apache/hadoop/hbase/client/HBaseAdmin.AbortProcedureFuture.html index 0610ad0..8b22aa1 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/client/HBaseAdmin.AbortProcedureFuture.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/client/HBaseAdmin.AbortProcedureFuture.html @@ -2665,1591 +2665,1570 @@ 2657 @Override 2658 public byte[] execProcedureWithRet(String signature, String instance, MapString, String props) 2659 throws IOException { -2660ProcedureDescription.Builder builder = ProcedureDescription.newBuilder(); -2661 builder.setSignature(signature).setInstance(instance); -2662for (EntryString, String entry : props.entrySet()) { -2663 NameStringPair pair = NameStringPair.newBuilder().setName(entry.getKey()) -2664 .setValue(entry.getValue()).build(); -2665 builder.addConfiguration(pair); -2666} -2667 -2668final ExecProcedureRequest request = ExecProcedureRequest.newBuilder() -2669 .setProcedure(builder.build()).build(); -2670// run the procedure on the master -2671ExecProcedureResponse response = executeCallable(new MasterCallableExecProcedureResponse( -2672getConnection(), getRpcControllerFactory()) { -2673 @Override -2674 protected ExecProcedureResponse rpcCall() throws Exception { -2675return master.execProcedureWithRet(getRpcController(), request); -2676 } -2677}); -2678 -2679return response.hasReturnData() ? response.getReturnData().toByteArray() : null; -2680 } -2681 -2682 @Override -2683 public void execProcedure(String signature, String instance, MapString, String props) -2684 throws IOException { -2685ProcedureDescription.Builder builder = ProcedureDescription.newBuilder(); -2686 builder.setSignature(signature).setInstance(instance); -2687for (EntryString, String entry : props.entrySet()) { -2688 NameStringPair pair = NameStringPair.newBuilder().setName(entry.getKey()) -2689 .setValue(entry.getValue()).build(); -2690 builder.addConfiguration(pair); -2691} -2692 -2693final ExecProcedureRequest request = ExecProcedureRequest.newBuilder() -2694 .setProcedure(builder.build()).build(); -2695// run the procedure on the master -2696ExecProcedureResponse response = executeCallable(new MasterCallableExecProcedureResponse( -2697getConnection(), getRpcControllerFactory()) { -2698 @Override -2699 protected ExecProcedureResponse rpcCall() throws Exception { -2700return master.execProcedure(getRpcController(), request); -2701 } -2702}); -2703 -2704long start = EnvironmentEdgeManager.currentTime(); -2705long max = response.getExpectedTimeout(); -2706long maxPauseTime = max / this.numRetries; -2707int tries = 0; -2708LOG.debug("Waiting a max of " + max + " ms for procedure '" + -2709signature + " : " + instance + "'' to complete. (max " + maxPauseTime + " ms per retry)"); -2710boolean done = false; -2711while (tries == 0 -2712|| ((EnvironmentEdgeManager.currentTime() - start) max !done)) { -2713 try { -2714// sleep a backoff = pauseTime amount -2715long sleep = getPauseTime(tries++); -2716sleep = sleep maxPauseTime ? maxPauseTime : sleep; -2717LOG.debug("(#" + tries + ") Sleeping: " + sleep + -2718 "ms while waiting for procedure completion."); -2719Thread.sleep(sleep); -2720 } catch (InterruptedException e) { -2721throw (InterruptedIOException)new InterruptedIOException("Interrupted").initCause(e); -2722 } -2723 LOG.debug("Getting current status of procedure from master..."); -2724 done = isProcedureFinished(signature, instance, props); -2725} -2726if (!done) { -2727 throw new IOException("Procedure '" + signature + " : " + instance -2728 + "' wasn't completed in expectedTime:" + max + " ms"); -2729} +2660ProcedureDescription desc = ProtobufUtil.buildProcedureDescription(signature, instance, props); +2661final ExecProcedureRequest request = +2662 ExecProcedureRequest.newBuilder().setProcedure(desc).build(); +2663// run the procedure on the master +2664ExecProcedureResponse response = executeCallable( +2665 new MasterCallableExecProcedureResponse(getConnection(), getRpcControllerFactory()) { +2666@Override +2667protected ExecProcedureResponse rpcCall() throws Exception { +2668 return master.execProcedureWithRet(getRpcController(), request); +2669} +2670 }); +2671 +2672return
[20/51] [partial] hbase-site git commit: Published site at 82d554e3783372cc6b05489452c815b57c06f6cd.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/31df4674/devapidocs/src-html/org/apache/hadoop/hbase/client/AsyncHBaseAdmin.CreateNamespaceProcedureBiConsumer.html -- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/client/AsyncHBaseAdmin.CreateNamespaceProcedureBiConsumer.html b/devapidocs/src-html/org/apache/hadoop/hbase/client/AsyncHBaseAdmin.CreateNamespaceProcedureBiConsumer.html index f3f7a46..8750fa2 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/client/AsyncHBaseAdmin.CreateNamespaceProcedureBiConsumer.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/client/AsyncHBaseAdmin.CreateNamespaceProcedureBiConsumer.html @@ -56,2015 +56,2125 @@ 048import org.apache.hadoop.hbase.MetaTableAccessor; 049import org.apache.hadoop.hbase.MetaTableAccessor.QueryType; 050import org.apache.hadoop.hbase.NotServingRegionException; -051import org.apache.hadoop.hbase.RegionLocations; -052import org.apache.hadoop.hbase.ServerName; -053import org.apache.hadoop.hbase.NamespaceDescriptor; -054import org.apache.hadoop.hbase.HConstants; -055import org.apache.hadoop.hbase.TableExistsException; -056import org.apache.hadoop.hbase.TableName; -057import org.apache.hadoop.hbase.AsyncMetaTableAccessor; -058import org.apache.hadoop.hbase.TableNotDisabledException; -059import org.apache.hadoop.hbase.TableNotFoundException; -060import org.apache.hadoop.hbase.UnknownRegionException; -061import org.apache.hadoop.hbase.classification.InterfaceAudience; -062import org.apache.hadoop.hbase.classification.InterfaceStability; -063import org.apache.hadoop.hbase.client.AsyncRpcRetryingCallerFactory.AdminRequestCallerBuilder; -064import org.apache.hadoop.hbase.client.AsyncRpcRetryingCallerFactory.MasterRequestCallerBuilder; -065import org.apache.hadoop.hbase.client.Scan.ReadType; -066import org.apache.hadoop.hbase.client.replication.ReplicationSerDeHelper; -067import org.apache.hadoop.hbase.client.replication.TableCFs; -068import org.apache.hadoop.hbase.exceptions.DeserializationException; -069import org.apache.hadoop.hbase.ipc.HBaseRpcController; -070import org.apache.hadoop.hbase.quotas.QuotaFilter; -071import org.apache.hadoop.hbase.quotas.QuotaSettings; -072import org.apache.hadoop.hbase.quotas.QuotaTableUtil; -073import org.apache.hadoop.hbase.replication.ReplicationException; -074import org.apache.hadoop.hbase.replication.ReplicationPeerConfig; -075import org.apache.hadoop.hbase.replication.ReplicationPeerDescription; -076import org.apache.hadoop.hbase.shaded.com.google.protobuf.RpcCallback; -077import org.apache.hadoop.hbase.shaded.protobuf.ProtobufUtil; -078import org.apache.hadoop.hbase.shaded.protobuf.RequestConverter; -079import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.AdminService; -080import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CloseRegionRequest; -081import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CloseRegionResponse; -082import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.SplitRegionRequest; -083import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.SplitRegionResponse; -084import org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos; -085import org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.TableSchema; -086import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.AddColumnRequest; -087import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.AddColumnResponse; -088import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.AssignRegionRequest; -089import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.AssignRegionResponse; -090import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.BalanceRequest; -091import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.BalanceResponse; -092import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.CreateNamespaceRequest; -093import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.CreateNamespaceResponse; -094import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.DeleteNamespaceRequest; -095import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.DeleteNamespaceResponse; -096import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.DeleteSnapshotRequest; -097import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.DeleteSnapshotResponse; -098import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.DisableTableRequest; -099import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.DisableTableResponse; -100import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.EnableTableRequest; -101import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.EnableTableResponse; -102import
[12/51] [partial] hbase-site git commit: Published site at 82d554e3783372cc6b05489452c815b57c06f6cd.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/31df4674/devapidocs/src-html/org/apache/hadoop/hbase/client/AsyncHBaseAdmin.MergeTableRegionProcedureBiConsumer.html -- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/client/AsyncHBaseAdmin.MergeTableRegionProcedureBiConsumer.html b/devapidocs/src-html/org/apache/hadoop/hbase/client/AsyncHBaseAdmin.MergeTableRegionProcedureBiConsumer.html index f3f7a46..8750fa2 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/client/AsyncHBaseAdmin.MergeTableRegionProcedureBiConsumer.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/client/AsyncHBaseAdmin.MergeTableRegionProcedureBiConsumer.html @@ -56,2015 +56,2125 @@ 048import org.apache.hadoop.hbase.MetaTableAccessor; 049import org.apache.hadoop.hbase.MetaTableAccessor.QueryType; 050import org.apache.hadoop.hbase.NotServingRegionException; -051import org.apache.hadoop.hbase.RegionLocations; -052import org.apache.hadoop.hbase.ServerName; -053import org.apache.hadoop.hbase.NamespaceDescriptor; -054import org.apache.hadoop.hbase.HConstants; -055import org.apache.hadoop.hbase.TableExistsException; -056import org.apache.hadoop.hbase.TableName; -057import org.apache.hadoop.hbase.AsyncMetaTableAccessor; -058import org.apache.hadoop.hbase.TableNotDisabledException; -059import org.apache.hadoop.hbase.TableNotFoundException; -060import org.apache.hadoop.hbase.UnknownRegionException; -061import org.apache.hadoop.hbase.classification.InterfaceAudience; -062import org.apache.hadoop.hbase.classification.InterfaceStability; -063import org.apache.hadoop.hbase.client.AsyncRpcRetryingCallerFactory.AdminRequestCallerBuilder; -064import org.apache.hadoop.hbase.client.AsyncRpcRetryingCallerFactory.MasterRequestCallerBuilder; -065import org.apache.hadoop.hbase.client.Scan.ReadType; -066import org.apache.hadoop.hbase.client.replication.ReplicationSerDeHelper; -067import org.apache.hadoop.hbase.client.replication.TableCFs; -068import org.apache.hadoop.hbase.exceptions.DeserializationException; -069import org.apache.hadoop.hbase.ipc.HBaseRpcController; -070import org.apache.hadoop.hbase.quotas.QuotaFilter; -071import org.apache.hadoop.hbase.quotas.QuotaSettings; -072import org.apache.hadoop.hbase.quotas.QuotaTableUtil; -073import org.apache.hadoop.hbase.replication.ReplicationException; -074import org.apache.hadoop.hbase.replication.ReplicationPeerConfig; -075import org.apache.hadoop.hbase.replication.ReplicationPeerDescription; -076import org.apache.hadoop.hbase.shaded.com.google.protobuf.RpcCallback; -077import org.apache.hadoop.hbase.shaded.protobuf.ProtobufUtil; -078import org.apache.hadoop.hbase.shaded.protobuf.RequestConverter; -079import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.AdminService; -080import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CloseRegionRequest; -081import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CloseRegionResponse; -082import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.SplitRegionRequest; -083import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.SplitRegionResponse; -084import org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos; -085import org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.TableSchema; -086import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.AddColumnRequest; -087import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.AddColumnResponse; -088import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.AssignRegionRequest; -089import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.AssignRegionResponse; -090import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.BalanceRequest; -091import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.BalanceResponse; -092import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.CreateNamespaceRequest; -093import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.CreateNamespaceResponse; -094import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.DeleteNamespaceRequest; -095import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.DeleteNamespaceResponse; -096import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.DeleteSnapshotRequest; -097import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.DeleteSnapshotResponse; -098import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.DisableTableRequest; -099import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.DisableTableResponse; -100import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.EnableTableRequest; -101import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.EnableTableResponse; -102import
[39/51] [partial] hbase-site git commit: Published site at 82d554e3783372cc6b05489452c815b57c06f6cd.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/31df4674/devapidocs/org/apache/hadoop/hbase/ipc/NettyRpcServer.ConnectionHeaderHandler.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/ipc/NettyRpcServer.ConnectionHeaderHandler.html b/devapidocs/org/apache/hadoop/hbase/ipc/NettyRpcServer.ConnectionHeaderHandler.html new file mode 100644 index 000..6a2d862 --- /dev/null +++ b/devapidocs/org/apache/hadoop/hbase/ipc/NettyRpcServer.ConnectionHeaderHandler.html @@ -0,0 +1,399 @@ +http://www.w3.org/TR/html4/loose.dtd;> + + + + + +NettyRpcServer.ConnectionHeaderHandler (Apache HBase 2.0.0-SNAPSHOT API) + + + + + +var methods = {"i0":10}; +var tabs = {65535:["t0","All Methods"],2:["t2","Instance Methods"],8:["t4","Concrete Methods"]}; +var altColor = "altColor"; +var rowColor = "rowColor"; +var tableTab = "tableTab"; +var activeTableTab = "activeTableTab"; + + +JavaScript is disabled on your browser. + + + + + +Skip navigation links + + + + +Overview +Package +Class +Use +Tree +Deprecated +Index +Help + + + + +PrevClass +NextClass + + +Frames +NoFrames + + +AllClasses + + + + + + + +Summary: +Nested| +Field| +Constr| +Method + + +Detail: +Field| +Constr| +Method + + + + + + + + +org.apache.hadoop.hbase.ipc +Class NettyRpcServer.ConnectionHeaderHandler + + + +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 + + +io.netty.channel.ChannelHandlerAdapter + + +io.netty.channel.ChannelInboundHandlerAdapter + + +io.netty.handler.codec.ByteToMessageDecoder + + +org.apache.hadoop.hbase.ipc.NettyRpcServer.ConnectionHeaderHandler + + + + + + + + + + + + + +All Implemented Interfaces: +io.netty.channel.ChannelHandler, io.netty.channel.ChannelInboundHandler + + +Enclosing class: +NettyRpcServer + + + +private class NettyRpcServer.ConnectionHeaderHandler +extends io.netty.handler.codec.ByteToMessageDecoder + + + + + + + + + + + +Nested Class Summary + + + + +Nested classes/interfaces inherited from classio.netty.handler.codec.ByteToMessageDecoder +io.netty.handler.codec.ByteToMessageDecoder.Cumulator + + + + + +Nested classes/interfaces inherited from interfaceio.netty.channel.ChannelHandler +io.netty.channel.ChannelHandler.Sharable + + + + + + + + +Field Summary + +Fields + +Modifier and Type +Field and Description + + +private NettyRpcServer.NettyConnection +connection + + + + + + +Fields inherited from classio.netty.handler.codec.ByteToMessageDecoder +COMPOSITE_CUMULATOR, MERGE_CUMULATOR + + + + + + + + +Constructor Summary + +Constructors + +Constructor and Description + + +ConnectionHeaderHandler() + + + + + + + + + +Method Summary + +All MethodsInstance MethodsConcrete Methods + +Modifier and Type +Method and Description + + +protected void +decode(io.netty.channel.ChannelHandlerContextctx, + io.netty.buffer.ByteBufbyteBuf, + http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true; title="class or interface in java.util">Listhttp://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true; title="class or interface in java.lang">Objectout) + + + + + + +Methods inherited from classio.netty.handler.codec.ByteToMessageDecoder +actualReadableBytes, callDecode, channelInactive, channelRead, channelReadComplete, decodeLast, discardSomeReadBytes, handlerRemoved, handlerRemoved0, internalBuffer, isSingleDecode, setCumulator, setDiscardAfterReads, setSingleDecode, userEventTriggered + + + + + +Methods inherited from classio.netty.channel.ChannelInboundHandlerAdapter +channelActive, channelRegistered, channelUnregistered, channelWritabilityChanged, exceptionCaught + + + + + +Methods inherited from classio.netty.channel.ChannelHandlerAdapter +handlerAdded, isSharable + + + + + +Methods inherited from classjava.lang.http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true; title="class or interface in java.lang">Object +http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true#clone--; title="class or interface in java.lang">clone, http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true#equals-java.lang.Object-; title="class or interface in java.lang">equals, http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true#finalize--; title="class or interface in java.lang">finalize,
[18/51] [partial] hbase-site git commit: Published site at 82d554e3783372cc6b05489452c815b57c06f6cd.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/31df4674/devapidocs/src-html/org/apache/hadoop/hbase/client/AsyncHBaseAdmin.DeleteColumnFamilyProcedureBiConsumer.html -- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/client/AsyncHBaseAdmin.DeleteColumnFamilyProcedureBiConsumer.html b/devapidocs/src-html/org/apache/hadoop/hbase/client/AsyncHBaseAdmin.DeleteColumnFamilyProcedureBiConsumer.html index f3f7a46..8750fa2 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/client/AsyncHBaseAdmin.DeleteColumnFamilyProcedureBiConsumer.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/client/AsyncHBaseAdmin.DeleteColumnFamilyProcedureBiConsumer.html @@ -56,2015 +56,2125 @@ 048import org.apache.hadoop.hbase.MetaTableAccessor; 049import org.apache.hadoop.hbase.MetaTableAccessor.QueryType; 050import org.apache.hadoop.hbase.NotServingRegionException; -051import org.apache.hadoop.hbase.RegionLocations; -052import org.apache.hadoop.hbase.ServerName; -053import org.apache.hadoop.hbase.NamespaceDescriptor; -054import org.apache.hadoop.hbase.HConstants; -055import org.apache.hadoop.hbase.TableExistsException; -056import org.apache.hadoop.hbase.TableName; -057import org.apache.hadoop.hbase.AsyncMetaTableAccessor; -058import org.apache.hadoop.hbase.TableNotDisabledException; -059import org.apache.hadoop.hbase.TableNotFoundException; -060import org.apache.hadoop.hbase.UnknownRegionException; -061import org.apache.hadoop.hbase.classification.InterfaceAudience; -062import org.apache.hadoop.hbase.classification.InterfaceStability; -063import org.apache.hadoop.hbase.client.AsyncRpcRetryingCallerFactory.AdminRequestCallerBuilder; -064import org.apache.hadoop.hbase.client.AsyncRpcRetryingCallerFactory.MasterRequestCallerBuilder; -065import org.apache.hadoop.hbase.client.Scan.ReadType; -066import org.apache.hadoop.hbase.client.replication.ReplicationSerDeHelper; -067import org.apache.hadoop.hbase.client.replication.TableCFs; -068import org.apache.hadoop.hbase.exceptions.DeserializationException; -069import org.apache.hadoop.hbase.ipc.HBaseRpcController; -070import org.apache.hadoop.hbase.quotas.QuotaFilter; -071import org.apache.hadoop.hbase.quotas.QuotaSettings; -072import org.apache.hadoop.hbase.quotas.QuotaTableUtil; -073import org.apache.hadoop.hbase.replication.ReplicationException; -074import org.apache.hadoop.hbase.replication.ReplicationPeerConfig; -075import org.apache.hadoop.hbase.replication.ReplicationPeerDescription; -076import org.apache.hadoop.hbase.shaded.com.google.protobuf.RpcCallback; -077import org.apache.hadoop.hbase.shaded.protobuf.ProtobufUtil; -078import org.apache.hadoop.hbase.shaded.protobuf.RequestConverter; -079import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.AdminService; -080import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CloseRegionRequest; -081import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CloseRegionResponse; -082import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.SplitRegionRequest; -083import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.SplitRegionResponse; -084import org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos; -085import org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.TableSchema; -086import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.AddColumnRequest; -087import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.AddColumnResponse; -088import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.AssignRegionRequest; -089import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.AssignRegionResponse; -090import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.BalanceRequest; -091import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.BalanceResponse; -092import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.CreateNamespaceRequest; -093import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.CreateNamespaceResponse; -094import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.DeleteNamespaceRequest; -095import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.DeleteNamespaceResponse; -096import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.DeleteSnapshotRequest; -097import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.DeleteSnapshotResponse; -098import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.DisableTableRequest; -099import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.DisableTableResponse; -100import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.EnableTableRequest; -101import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.EnableTableResponse; -102import
[34/51] [partial] hbase-site git commit: Published site at 82d554e3783372cc6b05489452c815b57c06f6cd.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/31df4674/devapidocs/org/apache/hadoop/hbase/ipc/RpcServerInterface.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/ipc/RpcServerInterface.html b/devapidocs/org/apache/hadoop/hbase/ipc/RpcServerInterface.html index 709ec03..ec76267 100644 --- a/devapidocs/org/apache/hadoop/hbase/ipc/RpcServerInterface.html +++ b/devapidocs/org/apache/hadoop/hbase/ipc/RpcServerInterface.html @@ -101,7 +101,7 @@ var activeTableTab = "activeTableTab"; All Known Implementing Classes: -RpcServer, SimpleRpcServer +NettyRpcServer, RpcServer, SimpleRpcServer http://git-wip-us.apache.org/repos/asf/hbase-site/blob/31df4674/devapidocs/org/apache/hadoop/hbase/ipc/SimpleRpcServer.Call.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/ipc/SimpleRpcServer.Call.html b/devapidocs/org/apache/hadoop/hbase/ipc/SimpleRpcServer.Call.html index 4d59e23..59c6329 100644 --- a/devapidocs/org/apache/hadoop/hbase/ipc/SimpleRpcServer.Call.html +++ b/devapidocs/org/apache/hadoop/hbase/ipc/SimpleRpcServer.Call.html @@ -123,7 +123,7 @@ var activeTableTab = "activeTableTab"; @InterfaceStability.Evolving -public class SimpleRpcServer.Call +public class SimpleRpcServer.Call extends RpcServer.Call Datastructure that holds all necessary to a method invocation and then afterward, carries the result. @@ -171,19 +171,19 @@ extends Constructor and Description -Call(intid, +Call(intid, org.apache.hadoop.hbase.shaded.com.google.protobuf.BlockingServiceservice, org.apache.hadoop.hbase.shaded.com.google.protobuf.Descriptors.MethodDescriptormd, org.apache.hadoop.hbase.shaded.protobuf.generated.RPCProtos.RequestHeaderheader, org.apache.hadoop.hbase.shaded.com.google.protobuf.Messageparam, CellScannercellScanner, -SimpleRpcServer.Connectionconnection, -SimpleRpcServer.Responderresponder, +RpcServer.Connectionconnection, longsize, org.apache.htrace.TraceInfotinfo, http://docs.oracle.com/javase/8/docs/api/java/net/InetAddress.html?is-external=true; title="class or interface in java.net">InetAddressremoteAddress, inttimeout, -RpcServer.CallCleanupreqCleanup) +RpcServer.CallCleanupreqCleanup, +SimpleRpcServer.Responderresponder) @@ -228,7 +228,7 @@ extends Methods inherited from classorg.apache.hadoop.hbase.ipc.RpcServer.Call -cleanup, getCellScanner, getClientVersionInfo, getDeadline, getHeader, getMethod, getParam, getPriority, getReceiveTime, getRemoteAddress, getRemotePort, getRequestUser, getRequestUserName, getResponseBlockSize, getResponseCellSize, getResponseExceptionSize, getService, getSize, getStartTime, getTimeout, getTraceInfo, incrementResponseBlockSize, incrementResponseCellSize, incrementResponseExceptionSize, isClientCellBlockSupported, isRetryImmediatelySupported, setCallBack, setConnectionHeaderResponse, setReceiveTime, setResponse, setSaslTokenResponse, setStartTime, toShortString, toString +cleanup, createHeaderAndMessageBytes, getCellScanner, getClientVersionInfo, getDeadline, getHeader, getMethod, get Param, getPriority, getReceiveTime, getRemoteAddress, getRemotePort, getRequestUser, getRequestUserName, getResponseBlockSize, getResponseCellSize, getResponseExceptionSize, getService, getSize, getStartTime, getTimeout, getTraceInfo, incrementResponseBlockSize, incrementResponseCellSize, incrementResponseExceptionSize, isClientCellBlockSupported, isRetryImmediatelySupported, setCallBack, setConnectionHeaderResponse, setExceptionResponse, setReceiveTime, setResponse, setSaslTokenResponse, setStartTime, toShortString, toString, wrapWithSasl @@ -257,7 +257,7 @@ extends responder -protectedSimpleRpcServer.Responder responder +protectedSimpleRpcServer.Responder responder @@ -268,25 +268,25 @@ extends Constructor Detail - + Call -Call(intid, +Call(intid, org.apache.hadoop.hbase.shaded.com.google.protobuf.BlockingServiceservice, org.apache.hadoop.hbase.shaded.com.google.protobuf.Descriptors.MethodDescriptormd, org.apache.hadoop.hbase.shaded.protobuf.generated.RPCProtos.RequestHeaderheader, org.apache.hadoop.hbase.shaded.com.google.protobuf.Messageparam, CellScannercellScanner, - SimpleRpcServer.Connectionconnection, - SimpleRpcServer.Responderresponder, + RpcServer.Connectionconnection, longsize, org.apache.htrace.TraceInfotinfo, http://docs.oracle.com/javase/8/docs/api/java/net/InetAddress.html?is-external=true; title="class or interface in java.net">InetAddressremoteAddress, inttimeout, - RpcServer.CallCleanupreqCleanup) + RpcServer.CallCleanupreqCleanup, + SimpleRpcServer.Responderresponder) @@ -303,7 +303,7 @@ extends done -voiddone() +voiddone() Call is done.
[01/51] [partial] hbase-site git commit: Published site at 82d554e3783372cc6b05489452c815b57c06f6cd.
Repository: hbase-site Updated Branches: refs/heads/asf-site f8a136728 -> 31df46740 http://git-wip-us.apache.org/repos/asf/hbase-site/blob/31df4674/devapidocs/src-html/org/apache/hadoop/hbase/client/HBaseAdmin.CreateTableFuture.html -- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/client/HBaseAdmin.CreateTableFuture.html b/devapidocs/src-html/org/apache/hadoop/hbase/client/HBaseAdmin.CreateTableFuture.html index 0610ad0..8b22aa1 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/client/HBaseAdmin.CreateTableFuture.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/client/HBaseAdmin.CreateTableFuture.html @@ -2665,1591 +2665,1570 @@ 2657 @Override 2658 public byte[] execProcedureWithRet(String signature, String instance, MapString, String props) 2659 throws IOException { -2660ProcedureDescription.Builder builder = ProcedureDescription.newBuilder(); -2661 builder.setSignature(signature).setInstance(instance); -2662for (EntryString, String entry : props.entrySet()) { -2663 NameStringPair pair = NameStringPair.newBuilder().setName(entry.getKey()) -2664 .setValue(entry.getValue()).build(); -2665 builder.addConfiguration(pair); -2666} -2667 -2668final ExecProcedureRequest request = ExecProcedureRequest.newBuilder() -2669 .setProcedure(builder.build()).build(); -2670// run the procedure on the master -2671ExecProcedureResponse response = executeCallable(new MasterCallableExecProcedureResponse( -2672getConnection(), getRpcControllerFactory()) { -2673 @Override -2674 protected ExecProcedureResponse rpcCall() throws Exception { -2675return master.execProcedureWithRet(getRpcController(), request); -2676 } -2677}); -2678 -2679return response.hasReturnData() ? response.getReturnData().toByteArray() : null; -2680 } -2681 -2682 @Override -2683 public void execProcedure(String signature, String instance, MapString, String props) -2684 throws IOException { -2685ProcedureDescription.Builder builder = ProcedureDescription.newBuilder(); -2686 builder.setSignature(signature).setInstance(instance); -2687for (EntryString, String entry : props.entrySet()) { -2688 NameStringPair pair = NameStringPair.newBuilder().setName(entry.getKey()) -2689 .setValue(entry.getValue()).build(); -2690 builder.addConfiguration(pair); -2691} -2692 -2693final ExecProcedureRequest request = ExecProcedureRequest.newBuilder() -2694 .setProcedure(builder.build()).build(); -2695// run the procedure on the master -2696ExecProcedureResponse response = executeCallable(new MasterCallableExecProcedureResponse( -2697getConnection(), getRpcControllerFactory()) { -2698 @Override -2699 protected ExecProcedureResponse rpcCall() throws Exception { -2700return master.execProcedure(getRpcController(), request); -2701 } -2702}); -2703 -2704long start = EnvironmentEdgeManager.currentTime(); -2705long max = response.getExpectedTimeout(); -2706long maxPauseTime = max / this.numRetries; -2707int tries = 0; -2708LOG.debug("Waiting a max of " + max + " ms for procedure '" + -2709signature + " : " + instance + "'' to complete. (max " + maxPauseTime + " ms per retry)"); -2710boolean done = false; -2711while (tries == 0 -2712|| ((EnvironmentEdgeManager.currentTime() - start) max !done)) { -2713 try { -2714// sleep a backoff = pauseTime amount -2715long sleep = getPauseTime(tries++); -2716sleep = sleep maxPauseTime ? maxPauseTime : sleep; -2717LOG.debug("(#" + tries + ") Sleeping: " + sleep + -2718 "ms while waiting for procedure completion."); -2719Thread.sleep(sleep); -2720 } catch (InterruptedException e) { -2721throw (InterruptedIOException)new InterruptedIOException("Interrupted").initCause(e); -2722 } -2723 LOG.debug("Getting current status of procedure from master..."); -2724 done = isProcedureFinished(signature, instance, props); -2725} -2726if (!done) { -2727 throw new IOException("Procedure '" + signature + " : " + instance -2728 + "' wasn't completed in expectedTime:" + max + " ms"); -2729} +2660ProcedureDescription desc = ProtobufUtil.buildProcedureDescription(signature, instance, props); +2661final ExecProcedureRequest request = +2662 ExecProcedureRequest.newBuilder().setProcedure(desc).build(); +2663// run the procedure on the master +2664ExecProcedureResponse response = executeCallable( +2665 new MasterCallableExecProcedureResponse(getConnection(), getRpcControllerFactory()) { +2666@Override +2667protected ExecProcedureResponse rpcCall() throws Exception { +2668 return master.execProcedureWithRet(getRpcController(),
[27/51] [partial] hbase-site git commit: Published site at 82d554e3783372cc6b05489452c815b57c06f6cd.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/31df4674/devapidocs/org/apache/hadoop/hbase/regionserver/compactions/RatioBasedCompactionPolicy.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/regionserver/compactions/RatioBasedCompactionPolicy.html b/devapidocs/org/apache/hadoop/hbase/regionserver/compactions/RatioBasedCompactionPolicy.html index 5102330..6d81e76 100644 --- a/devapidocs/org/apache/hadoop/hbase/regionserver/compactions/RatioBasedCompactionPolicy.html +++ b/devapidocs/org/apache/hadoop/hbase/regionserver/compactions/RatioBasedCompactionPolicy.html @@ -124,7 +124,7 @@ var activeTableTab = "activeTableTab"; @InterfaceAudience.Private -public class RatioBasedCompactionPolicy +public class RatioBasedCompactionPolicy extends SortedCompactionPolicy The default algorithm for selecting files for compaction. Combines the compaction configuration and the provisional file selection that @@ -267,7 +267,7 @@ extends LOG -private static finalorg.apache.commons.logging.Log LOG +private static finalorg.apache.commons.logging.Log LOG @@ -284,7 +284,7 @@ extends RatioBasedCompactionPolicy -publicRatioBasedCompactionPolicy(org.apache.hadoop.conf.Configurationconf, +publicRatioBasedCompactionPolicy(org.apache.hadoop.conf.Configurationconf, StoreConfigInformationstoreConfigInfo) @@ -302,7 +302,7 @@ extends shouldPerformMajorCompaction -publicbooleanshouldPerformMajorCompaction(http://docs.oracle.com/javase/8/docs/api/java/util/Collection.html?is-external=true; title="class or interface in java.util">CollectionStoreFilefilesToCompact) +publicbooleanshouldPerformMajorCompaction(http://docs.oracle.com/javase/8/docs/api/java/util/Collection.html?is-external=true; title="class or interface in java.util">CollectionStoreFilefilesToCompact) 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: @@ -322,7 +322,7 @@ extends createCompactionRequest -protectedCompactionRequestcreateCompactionRequest(http://docs.oracle.com/javase/8/docs/api/java/util/ArrayList.html?is-external=true; title="class or interface in java.util">ArrayListStoreFilecandidateSelection, +protectedCompactionRequestcreateCompactionRequest(http://docs.oracle.com/javase/8/docs/api/java/util/ArrayList.html?is-external=true; title="class or interface in java.util">ArrayListStoreFilecandidateSelection, booleantryingMajor, booleanmayUseOffPeak, booleanmayBeStuck) @@ -341,7 +341,7 @@ extends applyCompactionPolicy -protectedhttp://docs.oracle.com/javase/8/docs/api/java/util/ArrayList.html?is-external=true; title="class or interface in java.util">ArrayListStoreFileapplyCompactionPolicy(http://docs.oracle.com/javase/8/docs/api/java/util/ArrayList.html?is-external=true; title="class or interface in java.util">ArrayListStoreFilecandidates, +protectedhttp://docs.oracle.com/javase/8/docs/api/java/util/ArrayList.html?is-external=true; title="class or interface in java.util">ArrayListStoreFileapplyCompactionPolicy(http://docs.oracle.com/javase/8/docs/api/java/util/ArrayList.html?is-external=true; title="class or interface in java.util">ArrayListStoreFilecandidates, booleanmayUseOffPeak, booleanmayBeStuck) throws http://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true; title="class or interface in java.io">IOException @@ -387,7 +387,7 @@ extends needsCompaction -publicbooleanneedsCompaction(http://docs.oracle.com/javase/8/docs/api/java/util/Collection.html?is-external=true; title="class or interface in java.util">CollectionStoreFilestoreFiles, +publicbooleanneedsCompaction(http://docs.oracle.com/javase/8/docs/api/java/util/Collection.html?is-external=true; title="class or interface in java.util">CollectionStoreFilestoreFiles, http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true; title="class or interface in java.util">ListStoreFilefilesCompacting) A heuristic method to decide whether to schedule a compaction request @@ -407,7 +407,7 @@ extends setMinThreshold -publicvoidsetMinThreshold(intminThreshold) +publicvoidsetMinThreshold(intminThreshold) Overwrite min threshold for compaction http://git-wip-us.apache.org/repos/asf/hbase-site/blob/31df4674/devapidocs/org/apache/hadoop/hbase/regionserver/package-tree.html -- diff --git
hbase-site git commit: INFRA-10751 Empty commit
Repository: hbase-site Updated Branches: refs/heads/asf-site 31df46740 -> 2fd6b4cca 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/2fd6b4cc Tree: http://git-wip-us.apache.org/repos/asf/hbase-site/tree/2fd6b4cc Diff: http://git-wip-us.apache.org/repos/asf/hbase-site/diff/2fd6b4cc Branch: refs/heads/asf-site Commit: 2fd6b4cca84987431b0c6e820a38997b58706945 Parents: 31df467 Author: jenkinsAuthored: Wed May 3 14:58:58 2017 + Committer: jenkins Committed: Wed May 3 14:58:58 2017 + -- --
[50/51] [partial] hbase-site git commit: Published site at 82d554e3783372cc6b05489452c815b57c06f6cd.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/31df4674/checkstyle-aggregate.html -- diff --git a/checkstyle-aggregate.html b/checkstyle-aggregate.html index 7c7a524..de1dfeb 100644 --- a/checkstyle-aggregate.html +++ b/checkstyle-aggregate.html @@ -7,7 +7,7 @@ - + Apache HBase Checkstyle Results @@ -286,10 +286,10 @@ Warnings Errors -2155 +2156 0 0 -14365 +14349 Files @@ -787,7 +787,7 @@ org/apache/hadoop/hbase/client/AsyncHBaseAdmin.java 0 0 -32 +33 org/apache/hadoop/hbase/client/AsyncMetaRegionLocator.java 0 @@ -927,7 +927,7 @@ org/apache/hadoop/hbase/client/HBaseAdmin.java 0 0 -79 +81 org/apache/hadoop/hbase/client/HRegionLocator.java 0 @@ -2454,4576 +2454,4581 @@ 0 1 +org/apache/hadoop/hbase/ipc/NettyRpcServer.java +0 +0 +4 + org/apache/hadoop/hbase/ipc/PriorityFunction.java 0 0 8 - + org/apache/hadoop/hbase/ipc/RWQueueRpcExecutor.java 0 0 4 - + org/apache/hadoop/hbase/ipc/RemoteWithExtrasException.java 0 0 1 - + org/apache/hadoop/hbase/ipc/RpcCall.java 0 0 2 - + org/apache/hadoop/hbase/ipc/RpcCallContext.java 0 0 3 - + org/apache/hadoop/hbase/ipc/RpcClient.java 0 0 1 - + org/apache/hadoop/hbase/ipc/RpcClientFactory.java 0 0 1 - + org/apache/hadoop/hbase/ipc/RpcConnection.java 0 0 2 - + org/apache/hadoop/hbase/ipc/RpcExecutor.java 0 0 8 - + org/apache/hadoop/hbase/ipc/RpcScheduler.java 0 0 2 - + org/apache/hadoop/hbase/ipc/RpcSchedulerContext.java 0 0 1 - + org/apache/hadoop/hbase/ipc/RpcServer.java 0 0 -25 - +57 + org/apache/hadoop/hbase/ipc/RpcServerFactory.java 0 0 4 - + org/apache/hadoop/hbase/ipc/RpcServerInterface.java 0 0 4 - + org/apache/hadoop/hbase/ipc/SimpleRpcScheduler.java 0 0 8 - + org/apache/hadoop/hbase/ipc/SimpleRpcServer.java 0 0 -59 - +25 + org/apache/hadoop/hbase/mapred/Driver.java 0 0 4 - + org/apache/hadoop/hbase/mapred/GroupingTableMap.java 0 0 11 - + org/apache/hadoop/hbase/mapred/HRegionPartitioner.java 0 0 4 - + org/apache/hadoop/hbase/mapred/IdentityTableMap.java 0 0 8 - + org/apache/hadoop/hbase/mapred/IdentityTableReduce.java 0 0 7 - + org/apache/hadoop/hbase/mapred/MultiTableSnapshotInputFormat.java 0 0 5 - + org/apache/hadoop/hbase/mapred/RowCounter.java 0 0 7 - + org/apache/hadoop/hbase/mapred/TableInputFormat.java 0 0 1 - + org/apache/hadoop/hbase/mapred/TableInputFormatBase.java 0 0 6 - + org/apache/hadoop/hbase/mapred/TableMap.java 0 0 1 - + org/apache/hadoop/hbase/mapred/TableMapReduceUtil.java 0 0 11 - + org/apache/hadoop/hbase/mapred/TableOutputFormat.java 0 0 2 - + org/apache/hadoop/hbase/mapred/TableRecordReader.java 0 0 5 - + org/apache/hadoop/hbase/mapred/TableRecordReaderImpl.java 0 0 7 - + org/apache/hadoop/hbase/mapred/TableReduce.java 0 0 1 - + org/apache/hadoop/hbase/mapred/TableSnapshotInputFormat.java 0 0 4 - + org/apache/hadoop/hbase/mapred/TableSplit.java 0 0 17 - + org/apache/hadoop/hbase/mapreduce/CellCounter.java 0 0 10 - + org/apache/hadoop/hbase/mapreduce/CellCreator.java 0 0 6 - + org/apache/hadoop/hbase/mapreduce/CopyTable.java 0 0 12 - + org/apache/hadoop/hbase/mapreduce/DefaultVisibilityExpressionResolver.java 0 0 2 - + org/apache/hadoop/hbase/mapreduce/Driver.java 0 0 3 - + org/apache/hadoop/hbase/mapreduce/Export.java 0 0 7 - + org/apache/hadoop/hbase/mapreduce/GroupingTableMapper.java 0 0 3 - + org/apache/hadoop/hbase/mapreduce/HFileInputFormat.java 0 0 1 - + org/apache/hadoop/hbase/mapreduce/HFileOutputFormat2.java 0 0 5 - + org/apache/hadoop/hbase/mapreduce/HRegionPartitioner.java 0 0 4 - + org/apache/hadoop/hbase/mapreduce/HashTable.java 0 0 2 - + org/apache/hadoop/hbase/mapreduce/IdentityTableMapper.java 0 0 1 - + org/apache/hadoop/hbase/mapreduce/IdentityTableReducer.java 0 0 1 - + org/apache/hadoop/hbase/mapreduce/Import.java 0 0 9 - + org/apache/hadoop/hbase/mapreduce/ImportTsv.java 0 0 19 - + org/apache/hadoop/hbase/mapreduce/IndexBuilder.java 0 0 1 - + org/apache/hadoop/hbase/mapreduce/JarFinder.java 0 0 1 - + org/apache/hadoop/hbase/mapreduce/JobUtil.java 0 0 4 - + org/apache/hadoop/hbase/mapreduce/KeyValueSortReducer.java 0 0 4 - + org/apache/hadoop/hbase/mapreduce/LoadIncrementalHFiles.java 0 0 6 - + org/apache/hadoop/hbase/mapreduce/MultiHFileOutputFormat.java 0 0 7 - + org/apache/hadoop/hbase/mapreduce/MultiTableInputFormat.java 0 0 1 - + org/apache/hadoop/hbase/mapreduce/MultiTableInputFormatBase.java 0 0 5 - + org/apache/hadoop/hbase/mapreduce/MultiTableOutputFormat.java 0 0 3 - + org/apache/hadoop/hbase/mapreduce/MultiTableSnapshotInputFormat.java 0 0 1 - + org/apache/hadoop/hbase/mapreduce/MultiTableSnapshotInputFormatImpl.java 0 0 12 - + org/apache/hadoop/hbase/mapreduce/MultithreadedTableMapper.java 0 0 7 - +
[47/51] [partial] hbase-site git commit: Published site at 82d554e3783372cc6b05489452c815b57c06f6cd.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/31df4674/devapidocs/org/apache/hadoop/hbase/backup/package-tree.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/backup/package-tree.html b/devapidocs/org/apache/hadoop/hbase/backup/package-tree.html index 1f603c7..00d50bc 100644 --- a/devapidocs/org/apache/hadoop/hbase/backup/package-tree.html +++ b/devapidocs/org/apache/hadoop/hbase/backup/package-tree.html @@ -165,10 +165,10 @@ 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.backup.BackupRestoreConstants.BackupCommand -org.apache.hadoop.hbase.backup.BackupInfo.BackupState org.apache.hadoop.hbase.backup.BackupType org.apache.hadoop.hbase.backup.BackupInfo.BackupPhase +org.apache.hadoop.hbase.backup.BackupRestoreConstants.BackupCommand +org.apache.hadoop.hbase.backup.BackupInfo.BackupState http://git-wip-us.apache.org/repos/asf/hbase-site/blob/31df4674/devapidocs/org/apache/hadoop/hbase/class-use/Cell.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/class-use/Cell.html b/devapidocs/org/apache/hadoop/hbase/class-use/Cell.html index 01eb0d1..3d5902e 100644 --- a/devapidocs/org/apache/hadoop/hbase/class-use/Cell.html +++ b/devapidocs/org/apache/hadoop/hbase/class-use/Cell.html @@ -5669,26 +5669,19 @@ service. byte[]k2) -protected ScanQueryMatcher.MatchCode -StoreScanner.optimize(ScanQueryMatcher.MatchCodeqcode, -Cellcell) -See if we should actually SEEK or rather just SKIP to the next Cell (see HBASE-13109). - - - private void StoreScanner.parallelSeek(http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true; title="class or interface in java.util">List? extends KeyValueScannerscanners, Cellkv) Seek storefiles in parallel to optimize IO latency as much as possible - + boolean StoreFileReader.passesGeneralRowColBloomFilter(Cellcell) A method for checking Bloom filters. - + private boolean HRegion.RegionScannerImpl.populateResult(http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true; title="class or interface in java.util">ListCellresults, KeyValueHeapheap, @@ -5698,14 +5691,14 @@ service. reached, or remainingResultSize (if not -1) is reaced - + Cell RegionCoprocessorHost.postMutationBeforeWAL(RegionObserver.MutationTypeopType, Mutationmutation, CelloldCell, CellnewCell) - + boolean RegionCoprocessorHost.postScannerFilterRow(InternalScanners, CellcurRowCell) @@ -5713,23 +5706,23 @@ service. filter. - + private void StripeMultiFileWriter.BoundaryMultiWriter.prepareWriterFor(Cellcell) - + boolean RegionCoprocessorHost.prePrepareTimeStampForDeleteVersion(Mutationmutation, Cellkv, byte[]byteNow, Getget) - + Cell CellFlatMap.put(Cellk, Cellv) - + private Cell HMobStore.readCell(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.Pathlocations, http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">StringfileName, @@ -5740,14 +5733,14 @@ service. Reads the cell from a mob file. - + private Cell HRegion.reckonAppend(Celldelta, CellcurrentValue, longnow, Appendmutation) - + private Cell HRegion.reckonIncrement(Celldelta, longdeltaAmount, @@ -5758,7 +5751,7 @@ service. Calculate new Increment Cell. - + boolean StoreFileScanner.requestSeek(Cellkv, booleanforward, @@ -5766,7 +5759,7 @@ service. Pretend we have done a seek but don't do it yet, if possible. - + boolean KeyValueScanner.requestSeek(Cellkv, booleanforward, @@ -5776,13 +5769,13 @@ service. row/column combination specified by the kv parameter. - + boolean SegmentScanner.requestSeek(Cellc, booleanforward, booleanuseBloom) - + boolean KeyValueHeap.requestSeek(Cellkey, booleanforward, @@ -5792,70 +5785,70 @@ service. row/column combination specified by the kv parameter. - + boolean NonLazyKeyValueScanner.requestSeek(Cellkv, booleanforward, booleanuseBloom) - + boolean
[15/51] [partial] hbase-site git commit: Published site at 82d554e3783372cc6b05489452c815b57c06f6cd.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/31df4674/devapidocs/src-html/org/apache/hadoop/hbase/client/AsyncHBaseAdmin.DisableTableProcedureBiConsumer.html -- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/client/AsyncHBaseAdmin.DisableTableProcedureBiConsumer.html b/devapidocs/src-html/org/apache/hadoop/hbase/client/AsyncHBaseAdmin.DisableTableProcedureBiConsumer.html index f3f7a46..8750fa2 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/client/AsyncHBaseAdmin.DisableTableProcedureBiConsumer.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/client/AsyncHBaseAdmin.DisableTableProcedureBiConsumer.html @@ -56,2015 +56,2125 @@ 048import org.apache.hadoop.hbase.MetaTableAccessor; 049import org.apache.hadoop.hbase.MetaTableAccessor.QueryType; 050import org.apache.hadoop.hbase.NotServingRegionException; -051import org.apache.hadoop.hbase.RegionLocations; -052import org.apache.hadoop.hbase.ServerName; -053import org.apache.hadoop.hbase.NamespaceDescriptor; -054import org.apache.hadoop.hbase.HConstants; -055import org.apache.hadoop.hbase.TableExistsException; -056import org.apache.hadoop.hbase.TableName; -057import org.apache.hadoop.hbase.AsyncMetaTableAccessor; -058import org.apache.hadoop.hbase.TableNotDisabledException; -059import org.apache.hadoop.hbase.TableNotFoundException; -060import org.apache.hadoop.hbase.UnknownRegionException; -061import org.apache.hadoop.hbase.classification.InterfaceAudience; -062import org.apache.hadoop.hbase.classification.InterfaceStability; -063import org.apache.hadoop.hbase.client.AsyncRpcRetryingCallerFactory.AdminRequestCallerBuilder; -064import org.apache.hadoop.hbase.client.AsyncRpcRetryingCallerFactory.MasterRequestCallerBuilder; -065import org.apache.hadoop.hbase.client.Scan.ReadType; -066import org.apache.hadoop.hbase.client.replication.ReplicationSerDeHelper; -067import org.apache.hadoop.hbase.client.replication.TableCFs; -068import org.apache.hadoop.hbase.exceptions.DeserializationException; -069import org.apache.hadoop.hbase.ipc.HBaseRpcController; -070import org.apache.hadoop.hbase.quotas.QuotaFilter; -071import org.apache.hadoop.hbase.quotas.QuotaSettings; -072import org.apache.hadoop.hbase.quotas.QuotaTableUtil; -073import org.apache.hadoop.hbase.replication.ReplicationException; -074import org.apache.hadoop.hbase.replication.ReplicationPeerConfig; -075import org.apache.hadoop.hbase.replication.ReplicationPeerDescription; -076import org.apache.hadoop.hbase.shaded.com.google.protobuf.RpcCallback; -077import org.apache.hadoop.hbase.shaded.protobuf.ProtobufUtil; -078import org.apache.hadoop.hbase.shaded.protobuf.RequestConverter; -079import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.AdminService; -080import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CloseRegionRequest; -081import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CloseRegionResponse; -082import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.SplitRegionRequest; -083import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.SplitRegionResponse; -084import org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos; -085import org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.TableSchema; -086import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.AddColumnRequest; -087import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.AddColumnResponse; -088import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.AssignRegionRequest; -089import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.AssignRegionResponse; -090import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.BalanceRequest; -091import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.BalanceResponse; -092import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.CreateNamespaceRequest; -093import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.CreateNamespaceResponse; -094import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.DeleteNamespaceRequest; -095import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.DeleteNamespaceResponse; -096import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.DeleteSnapshotRequest; -097import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.DeleteSnapshotResponse; -098import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.DisableTableRequest; -099import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.DisableTableResponse; -100import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.EnableTableRequest; -101import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.EnableTableResponse; -102import
[42/51] [partial] hbase-site git commit: Published site at 82d554e3783372cc6b05489452c815b57c06f6cd.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/31df4674/devapidocs/org/apache/hadoop/hbase/client/HBaseAdmin.NamespaceFuture.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/client/HBaseAdmin.NamespaceFuture.html b/devapidocs/org/apache/hadoop/hbase/client/HBaseAdmin.NamespaceFuture.html index f326ed2..4c22c7e 100644 --- a/devapidocs/org/apache/hadoop/hbase/client/HBaseAdmin.NamespaceFuture.html +++ b/devapidocs/org/apache/hadoop/hbase/client/HBaseAdmin.NamespaceFuture.html @@ -124,7 +124,7 @@ var activeTableTab = "activeTableTab"; @InterfaceAudience.Private @InterfaceStability.Evolving -protected abstract static class HBaseAdmin.NamespaceFuture +protected abstract static class HBaseAdmin.NamespaceFuture extends HBaseAdmin.ProcedureFuturehttp://docs.oracle.com/javase/8/docs/api/java/lang/Void.html?is-external=true; title="class or interface in java.lang">Void @@ -244,7 +244,7 @@ extends namespaceName -private finalhttp://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String namespaceName +private finalhttp://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String namespaceName @@ -261,7 +261,7 @@ extends NamespaceFuture -publicNamespaceFuture(HBaseAdminadmin, +publicNamespaceFuture(HBaseAdminadmin, http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">StringnamespaceName, http://docs.oracle.com/javase/8/docs/api/java/lang/Long.html?is-external=true; title="class or interface in java.lang">LongprocId) @@ -280,7 +280,7 @@ extends getNamespaceName -protectedhttp://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">StringgetNamespaceName() +protectedhttp://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">StringgetNamespaceName() Returns: the namespace name @@ -293,7 +293,7 @@ extends getOperationType -public abstracthttp://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">StringgetOperationType() +public abstracthttp://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">StringgetOperationType() Returns: the operation type like CREATE_NAMESPACE, DELETE_NAMESPACE, etc. @@ -306,7 +306,7 @@ extends toString -publichttp://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">StringtoString() +publichttp://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">StringtoString() Overrides: http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true#toString--; title="class or interface in java.lang">toStringin classhttp://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true; title="class or interface in java.lang">Object http://git-wip-us.apache.org/repos/asf/hbase-site/blob/31df4674/devapidocs/org/apache/hadoop/hbase/client/HBaseAdmin.ProcedureFuture.WaitForStateCallable.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/client/HBaseAdmin.ProcedureFuture.WaitForStateCallable.html b/devapidocs/org/apache/hadoop/hbase/client/HBaseAdmin.ProcedureFuture.WaitForStateCallable.html index 6ffb264..c1c9297 100644 --- a/devapidocs/org/apache/hadoop/hbase/client/HBaseAdmin.ProcedureFuture.WaitForStateCallable.html +++ b/devapidocs/org/apache/hadoop/hbase/client/HBaseAdmin.ProcedureFuture.WaitForStateCallable.html @@ -109,7 +109,7 @@ var activeTableTab = "activeTableTab"; -protected static interface HBaseAdmin.ProcedureFuture.WaitForStateCallable +protected static interface HBaseAdmin.ProcedureFuture.WaitForStateCallable @@ -161,7 +161,7 @@ var activeTableTab = "activeTableTab"; checkState -booleancheckState(inttries) +booleancheckState(inttries) throws http://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true; title="class or interface in java.io">IOException Throws: @@ -175,7 +175,7 @@ var activeTableTab = "activeTableTab"; throwInterruptedException -voidthrowInterruptedException() +voidthrowInterruptedException() throws http://docs.oracle.com/javase/8/docs/api/java/io/InterruptedIOException.html?is-external=true; title="class or interface in java.io">InterruptedIOException Throws: @@ -189,7 +189,7 @@ var activeTableTab = "activeTableTab"; throwTimeoutException -voidthrowTimeoutException(longelapsed) +voidthrowTimeoutException(longelapsed)
[16/51] [partial] hbase-site git commit: Published site at 82d554e3783372cc6b05489452c815b57c06f6cd.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/31df4674/devapidocs/src-html/org/apache/hadoop/hbase/client/AsyncHBaseAdmin.DeleteTableProcedureBiConsumer.html -- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/client/AsyncHBaseAdmin.DeleteTableProcedureBiConsumer.html b/devapidocs/src-html/org/apache/hadoop/hbase/client/AsyncHBaseAdmin.DeleteTableProcedureBiConsumer.html index f3f7a46..8750fa2 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/client/AsyncHBaseAdmin.DeleteTableProcedureBiConsumer.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/client/AsyncHBaseAdmin.DeleteTableProcedureBiConsumer.html @@ -56,2015 +56,2125 @@ 048import org.apache.hadoop.hbase.MetaTableAccessor; 049import org.apache.hadoop.hbase.MetaTableAccessor.QueryType; 050import org.apache.hadoop.hbase.NotServingRegionException; -051import org.apache.hadoop.hbase.RegionLocations; -052import org.apache.hadoop.hbase.ServerName; -053import org.apache.hadoop.hbase.NamespaceDescriptor; -054import org.apache.hadoop.hbase.HConstants; -055import org.apache.hadoop.hbase.TableExistsException; -056import org.apache.hadoop.hbase.TableName; -057import org.apache.hadoop.hbase.AsyncMetaTableAccessor; -058import org.apache.hadoop.hbase.TableNotDisabledException; -059import org.apache.hadoop.hbase.TableNotFoundException; -060import org.apache.hadoop.hbase.UnknownRegionException; -061import org.apache.hadoop.hbase.classification.InterfaceAudience; -062import org.apache.hadoop.hbase.classification.InterfaceStability; -063import org.apache.hadoop.hbase.client.AsyncRpcRetryingCallerFactory.AdminRequestCallerBuilder; -064import org.apache.hadoop.hbase.client.AsyncRpcRetryingCallerFactory.MasterRequestCallerBuilder; -065import org.apache.hadoop.hbase.client.Scan.ReadType; -066import org.apache.hadoop.hbase.client.replication.ReplicationSerDeHelper; -067import org.apache.hadoop.hbase.client.replication.TableCFs; -068import org.apache.hadoop.hbase.exceptions.DeserializationException; -069import org.apache.hadoop.hbase.ipc.HBaseRpcController; -070import org.apache.hadoop.hbase.quotas.QuotaFilter; -071import org.apache.hadoop.hbase.quotas.QuotaSettings; -072import org.apache.hadoop.hbase.quotas.QuotaTableUtil; -073import org.apache.hadoop.hbase.replication.ReplicationException; -074import org.apache.hadoop.hbase.replication.ReplicationPeerConfig; -075import org.apache.hadoop.hbase.replication.ReplicationPeerDescription; -076import org.apache.hadoop.hbase.shaded.com.google.protobuf.RpcCallback; -077import org.apache.hadoop.hbase.shaded.protobuf.ProtobufUtil; -078import org.apache.hadoop.hbase.shaded.protobuf.RequestConverter; -079import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.AdminService; -080import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CloseRegionRequest; -081import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CloseRegionResponse; -082import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.SplitRegionRequest; -083import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.SplitRegionResponse; -084import org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos; -085import org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.TableSchema; -086import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.AddColumnRequest; -087import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.AddColumnResponse; -088import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.AssignRegionRequest; -089import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.AssignRegionResponse; -090import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.BalanceRequest; -091import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.BalanceResponse; -092import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.CreateNamespaceRequest; -093import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.CreateNamespaceResponse; -094import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.DeleteNamespaceRequest; -095import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.DeleteNamespaceResponse; -096import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.DeleteSnapshotRequest; -097import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.DeleteSnapshotResponse; -098import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.DisableTableRequest; -099import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.DisableTableResponse; -100import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.EnableTableRequest; -101import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.EnableTableResponse; -102import
[21/51] [partial] hbase-site git commit: Published site at 82d554e3783372cc6b05489452c815b57c06f6cd.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/31df4674/devapidocs/src-html/org/apache/hadoop/hbase/client/AsyncHBaseAdmin.Converter.html -- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/client/AsyncHBaseAdmin.Converter.html b/devapidocs/src-html/org/apache/hadoop/hbase/client/AsyncHBaseAdmin.Converter.html index f3f7a46..8750fa2 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/client/AsyncHBaseAdmin.Converter.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/client/AsyncHBaseAdmin.Converter.html @@ -56,2015 +56,2125 @@ 048import org.apache.hadoop.hbase.MetaTableAccessor; 049import org.apache.hadoop.hbase.MetaTableAccessor.QueryType; 050import org.apache.hadoop.hbase.NotServingRegionException; -051import org.apache.hadoop.hbase.RegionLocations; -052import org.apache.hadoop.hbase.ServerName; -053import org.apache.hadoop.hbase.NamespaceDescriptor; -054import org.apache.hadoop.hbase.HConstants; -055import org.apache.hadoop.hbase.TableExistsException; -056import org.apache.hadoop.hbase.TableName; -057import org.apache.hadoop.hbase.AsyncMetaTableAccessor; -058import org.apache.hadoop.hbase.TableNotDisabledException; -059import org.apache.hadoop.hbase.TableNotFoundException; -060import org.apache.hadoop.hbase.UnknownRegionException; -061import org.apache.hadoop.hbase.classification.InterfaceAudience; -062import org.apache.hadoop.hbase.classification.InterfaceStability; -063import org.apache.hadoop.hbase.client.AsyncRpcRetryingCallerFactory.AdminRequestCallerBuilder; -064import org.apache.hadoop.hbase.client.AsyncRpcRetryingCallerFactory.MasterRequestCallerBuilder; -065import org.apache.hadoop.hbase.client.Scan.ReadType; -066import org.apache.hadoop.hbase.client.replication.ReplicationSerDeHelper; -067import org.apache.hadoop.hbase.client.replication.TableCFs; -068import org.apache.hadoop.hbase.exceptions.DeserializationException; -069import org.apache.hadoop.hbase.ipc.HBaseRpcController; -070import org.apache.hadoop.hbase.quotas.QuotaFilter; -071import org.apache.hadoop.hbase.quotas.QuotaSettings; -072import org.apache.hadoop.hbase.quotas.QuotaTableUtil; -073import org.apache.hadoop.hbase.replication.ReplicationException; -074import org.apache.hadoop.hbase.replication.ReplicationPeerConfig; -075import org.apache.hadoop.hbase.replication.ReplicationPeerDescription; -076import org.apache.hadoop.hbase.shaded.com.google.protobuf.RpcCallback; -077import org.apache.hadoop.hbase.shaded.protobuf.ProtobufUtil; -078import org.apache.hadoop.hbase.shaded.protobuf.RequestConverter; -079import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.AdminService; -080import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CloseRegionRequest; -081import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CloseRegionResponse; -082import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.SplitRegionRequest; -083import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.SplitRegionResponse; -084import org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos; -085import org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.TableSchema; -086import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.AddColumnRequest; -087import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.AddColumnResponse; -088import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.AssignRegionRequest; -089import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.AssignRegionResponse; -090import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.BalanceRequest; -091import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.BalanceResponse; -092import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.CreateNamespaceRequest; -093import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.CreateNamespaceResponse; -094import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.DeleteNamespaceRequest; -095import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.DeleteNamespaceResponse; -096import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.DeleteSnapshotRequest; -097import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.DeleteSnapshotResponse; -098import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.DisableTableRequest; -099import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.DisableTableResponse; -100import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.EnableTableRequest; -101import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.EnableTableResponse; -102import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.DeleteColumnRequest; -103import
[24/51] [partial] hbase-site git commit: Published site at 82d554e3783372cc6b05489452c815b57c06f6cd.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/31df4674/devapidocs/src-html/org/apache/hadoop/hbase/client/AsyncAdmin.html -- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/client/AsyncAdmin.html b/devapidocs/src-html/org/apache/hadoop/hbase/client/AsyncAdmin.html index dba11f3..84aca73 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/client/AsyncAdmin.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/client/AsyncAdmin.html @@ -33,723 +33,778 @@ 025 026import org.apache.hadoop.hbase.HColumnDescriptor; 027import org.apache.hadoop.hbase.HRegionInfo; -028import org.apache.hadoop.hbase.ServerName; -029import org.apache.hadoop.hbase.NamespaceDescriptor; -030import org.apache.hadoop.hbase.TableName; -031import org.apache.hadoop.hbase.classification.InterfaceAudience; -032import org.apache.hadoop.hbase.quotas.QuotaFilter; -033import org.apache.hadoop.hbase.quotas.QuotaSettings; -034import org.apache.hadoop.hbase.client.replication.TableCFs; -035import org.apache.hadoop.hbase.replication.ReplicationPeerConfig; -036import org.apache.hadoop.hbase.replication.ReplicationPeerDescription; -037import org.apache.hadoop.hbase.util.Pair; -038 -039/** -040 * The asynchronous administrative API for HBase. -041 * p -042 * This feature is still under development, so marked as IA.Private. Will change to public when -043 * done. Use it with caution. -044 */ -045@InterfaceAudience.Private -046public interface AsyncAdmin { -047 -048 /** -049 * @return Async Connection used by this object. -050 */ -051 AsyncConnectionImpl getConnection(); -052 -053 /** -054 * @param tableName Table to check. -055 * @return True if table exists already. The return value will be wrapped by a -056 * {@link CompletableFuture}. -057 */ -058 CompletableFutureBoolean tableExists(final TableName tableName); -059 -060 /** -061 * List all the userspace tables. -062 * @return - returns an array of TableDescriptors wrapped by a {@link CompletableFuture}. -063 * @see #listTables(Pattern, boolean) -064 */ -065 CompletableFutureTableDescriptor[] listTables(); -066 -067 /** -068 * List all the tables matching the given pattern. -069 * @param regex The regular expression to match against -070 * @param includeSysTables False to match only against userspace tables -071 * @return - returns an array of TableDescriptors wrapped by a {@link CompletableFuture}. -072 * @see #listTables(Pattern, boolean) -073 */ -074 CompletableFutureTableDescriptor[] listTables(String regex, boolean includeSysTables); -075 -076 /** -077 * List all the tables matching the given pattern. -078 * @param pattern The compiled regular expression to match against -079 * @param includeSysTables False to match only against userspace tables -080 * @return - returns an array of TableDescriptors wrapped by a {@link CompletableFuture}. -081 */ -082 CompletableFutureTableDescriptor[] listTables(Pattern pattern, boolean includeSysTables); -083 -084 /** -085 * List all of the names of userspace tables. -086 * @return TableName[] an array of table names wrapped by a {@link CompletableFuture}. -087 * @see #listTableNames(Pattern, boolean) -088 */ -089 CompletableFutureTableName[] listTableNames(); -090 -091 /** -092 * List all of the names of userspace tables. -093 * @param regex The regular expression to match against -094 * @param includeSysTables False to match only against userspace tables -095 * @return TableName[] an array of table names wrapped by a {@link CompletableFuture}. -096 * @see #listTableNames(Pattern, boolean) -097 */ -098 CompletableFutureTableName[] listTableNames(final String regex, final boolean includeSysTables); -099 -100 /** -101 * List all of the names of userspace tables. -102 * @param pattern The regular expression to match against -103 * @param includeSysTables False to match only against userspace tables -104 * @return TableName[] an array of table names wrapped by a {@link CompletableFuture}. -105 */ -106 CompletableFutureTableName[] listTableNames(final Pattern pattern, -107 final boolean includeSysTables); -108 -109 /** -110 * Method for getting the tableDescriptor -111 * @param tableName as a {@link TableName} -112 * @return the read-only tableDescriptor wrapped by a {@link CompletableFuture}. -113 */ -114 CompletableFutureTableDescriptor getTableDescriptor(final TableName tableName); -115 -116 /** -117 * Creates a new table. -118 * @param desc table descriptor for table -119 */ -120 CompletableFutureVoid createTable(TableDescriptor desc); -121 -122 /** -123 * Creates a new table with the specified number of regions. The start key specified will become -124 * the end key of the first region of the table, and the end key specified will become the start -125 * key of the last region of the table
[33/51] [partial] hbase-site git commit: Published site at 82d554e3783372cc6b05489452c815b57c06f6cd.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/31df4674/devapidocs/org/apache/hadoop/hbase/ipc/SimpleRpcServer.Connection.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/ipc/SimpleRpcServer.Connection.html b/devapidocs/org/apache/hadoop/hbase/ipc/SimpleRpcServer.Connection.html index 7e861b2..c49bca3 100644 --- a/devapidocs/org/apache/hadoop/hbase/ipc/SimpleRpcServer.Connection.html +++ b/devapidocs/org/apache/hadoop/hbase/ipc/SimpleRpcServer.Connection.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}; +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,12 +113,16 @@ var activeTableTab = "activeTableTab"; +All Implemented Interfaces: +http://docs.oracle.com/javase/8/docs/api/java/io/Closeable.html?is-external=true; title="class or interface in java.io">Closeable, http://docs.oracle.com/javase/8/docs/api/java/lang/AutoCloseable.html?is-external=true; title="class or interface in java.lang">AutoCloseable + + Enclosing class: SimpleRpcServer -public class SimpleRpcServer.Connection +public class SimpleRpcServer.Connection extends RpcServer.Connection Reads calls from a connection and queues them for handling. @@ -140,64 +144,44 @@ extends Field and Description -private SimpleRpcServer.Call -authFailedCall - - protected http://docs.oracle.com/javase/8/docs/api/java/nio/channels/SocketChannel.html?is-external=true; title="class or interface in java.nio.channels">SocketChannel channel - + private ByteBuff data - + private http://docs.oracle.com/javase/8/docs/api/java/nio/ByteBuffer.html?is-external=true; title="class or interface in java.nio">ByteBuffer dataLengthBuffer - + private long lastContact - + protected http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/ConcurrentLinkedDeque.html?is-external=true; title="class or interface in java.util.concurrent">ConcurrentLinkedDequeSimpleRpcServer.Call responseQueue - + private http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/locks/Lock.html?is-external=true; title="class or interface in java.util.concurrent.locks">Lock responseWriteLock - + private http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/atomic/LongAdder.html?is-external=true; title="class or interface in java.util.concurrent.atomic">LongAdder rpcCount - -private SimpleRpcServer.Call -saslCall - -private SimpleRpcServer.Call -setConnectionHeaderResponseCall - - protected http://docs.oracle.com/javase/8/docs/api/java/net/Socket.html?is-external=true; title="class or interface in java.net">Socket socket - -private http://docs.oracle.com/javase/8/docs/api/java/nio/ByteBuffer.html?is-external=true; title="class or interface in java.nio">ByteBuffer -unwrappedData - - -private http://docs.oracle.com/javase/8/docs/api/java/nio/ByteBuffer.html?is-external=true; title="class or interface in java.nio">ByteBuffer -unwrappedDataLengthBuffer - Fields inherited from classorg.apache.hadoop.hbase.ipc.RpcServer.Connection -addr, attemptingUser, authenticatedWithFallback, authFailedResponse, authMethod, AUTHORIZATION_FAILED_CALLID, callCleanup, codec, compressionCodec, CONNECTION_HEADER_RESPONSE_CALLID, connectionHeader, connectionHeaderRead, connectionPreambleRead, cryptoAES, hostAddress, remotePort, retry ImmediatelySupported, SASL_CALLID, saslContextEstablished, saslServer, service, skipInitialSaslHandshake, ugi, useCryptoAesWrap, user, us eSasl, useWrap +addr, attemptingUser, authenticatedWithFallback, authFailedCall, authFailedResponse, authMethod, AUTHORIZATION_FAILED_CALLID, callCleanup, codec, compressionCodec, CONNECTION_HEADER_RESPONSE_CALLID, connectionHeader, connectionHeaderRead, connectionPreambleRead, cryptoAES, hostAddress, remotePort, retryImmediatelySupported, SASL_CALLID, saslCall, saslContextEstablished, saslServer, service, setConnectionHeaderResponseCall, skipInitialSaslHandshake, ugi, useCryptoAesWrap, user, useSasl, useWrap @@ -232,115 +216,83 @@ extends Method and Description -private boolean -authorizeConnection() - - protected int channelDataRead(http://docs.oracle.com/javase/8/docs/api/java/nio/channels/ReadableByteChannel.html?is-external=true; title="class or interface in java.nio.channels">ReadableByteChannelchannel, ByteBuffbuf) - -protected void + +void close() + +RpcServer.Call +createCall(intid, +
[07/51] [partial] hbase-site git commit: Published site at 82d554e3783372cc6b05489452c815b57c06f6cd.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/31df4674/devapidocs/src-html/org/apache/hadoop/hbase/client/AsyncHBaseAdmin.TableOperator.html -- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/client/AsyncHBaseAdmin.TableOperator.html b/devapidocs/src-html/org/apache/hadoop/hbase/client/AsyncHBaseAdmin.TableOperator.html index f3f7a46..8750fa2 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/client/AsyncHBaseAdmin.TableOperator.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/client/AsyncHBaseAdmin.TableOperator.html @@ -56,2015 +56,2125 @@ 048import org.apache.hadoop.hbase.MetaTableAccessor; 049import org.apache.hadoop.hbase.MetaTableAccessor.QueryType; 050import org.apache.hadoop.hbase.NotServingRegionException; -051import org.apache.hadoop.hbase.RegionLocations; -052import org.apache.hadoop.hbase.ServerName; -053import org.apache.hadoop.hbase.NamespaceDescriptor; -054import org.apache.hadoop.hbase.HConstants; -055import org.apache.hadoop.hbase.TableExistsException; -056import org.apache.hadoop.hbase.TableName; -057import org.apache.hadoop.hbase.AsyncMetaTableAccessor; -058import org.apache.hadoop.hbase.TableNotDisabledException; -059import org.apache.hadoop.hbase.TableNotFoundException; -060import org.apache.hadoop.hbase.UnknownRegionException; -061import org.apache.hadoop.hbase.classification.InterfaceAudience; -062import org.apache.hadoop.hbase.classification.InterfaceStability; -063import org.apache.hadoop.hbase.client.AsyncRpcRetryingCallerFactory.AdminRequestCallerBuilder; -064import org.apache.hadoop.hbase.client.AsyncRpcRetryingCallerFactory.MasterRequestCallerBuilder; -065import org.apache.hadoop.hbase.client.Scan.ReadType; -066import org.apache.hadoop.hbase.client.replication.ReplicationSerDeHelper; -067import org.apache.hadoop.hbase.client.replication.TableCFs; -068import org.apache.hadoop.hbase.exceptions.DeserializationException; -069import org.apache.hadoop.hbase.ipc.HBaseRpcController; -070import org.apache.hadoop.hbase.quotas.QuotaFilter; -071import org.apache.hadoop.hbase.quotas.QuotaSettings; -072import org.apache.hadoop.hbase.quotas.QuotaTableUtil; -073import org.apache.hadoop.hbase.replication.ReplicationException; -074import org.apache.hadoop.hbase.replication.ReplicationPeerConfig; -075import org.apache.hadoop.hbase.replication.ReplicationPeerDescription; -076import org.apache.hadoop.hbase.shaded.com.google.protobuf.RpcCallback; -077import org.apache.hadoop.hbase.shaded.protobuf.ProtobufUtil; -078import org.apache.hadoop.hbase.shaded.protobuf.RequestConverter; -079import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.AdminService; -080import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CloseRegionRequest; -081import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CloseRegionResponse; -082import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.SplitRegionRequest; -083import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.SplitRegionResponse; -084import org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos; -085import org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.TableSchema; -086import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.AddColumnRequest; -087import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.AddColumnResponse; -088import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.AssignRegionRequest; -089import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.AssignRegionResponse; -090import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.BalanceRequest; -091import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.BalanceResponse; -092import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.CreateNamespaceRequest; -093import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.CreateNamespaceResponse; -094import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.DeleteNamespaceRequest; -095import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.DeleteNamespaceResponse; -096import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.DeleteSnapshotRequest; -097import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.DeleteSnapshotResponse; -098import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.DisableTableRequest; -099import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.DisableTableResponse; -100import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.EnableTableRequest; -101import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.EnableTableResponse; -102import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.DeleteColumnRequest; -103import
[28/51] [partial] hbase-site git commit: Published site at 82d554e3783372cc6b05489452c815b57c06f6cd.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/31df4674/devapidocs/org/apache/hadoop/hbase/regionserver/StoreScanner.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/regionserver/StoreScanner.html b/devapidocs/org/apache/hadoop/hbase/regionserver/StoreScanner.html index 581b976..498fef5 100644 --- a/devapidocs/org/apache/hadoop/hbase/regionserver/StoreScanner.html +++ b/devapidocs/org/apache/hadoop/hbase/regionserver/StoreScanner.html @@ -18,7 +18,7 @@ catch(err) { } //--> -var methods = {"i0":10,"i1":10,"i2":10,"i3":10,"i4":10,"i5":10,"i6":9,"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}; +var methods = {"i0":10,"i1":10,"i2":10,"i3":10,"i4":10,"i5":10,"i6":9,"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}; 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.Private -public class StoreScanner +public class StoreScanner extends NonReversedNonLazyKeyValueScanner implements KeyValueScanner, InternalScanner, ChangedReadersObserver Scanner scans both the memstore and the Store. Coalesce KeyValue stream @@ -528,53 +528,54 @@ implements -protected ScanQueryMatcher.MatchCode -optimize(ScanQueryMatcher.MatchCodeqcode, -Cellcell) -See if we should actually SEEK or rather just SKIP to the next Cell (see HBASE-13109). - - - private void parallelSeek(http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true; title="class or interface in java.util">List? extends KeyValueScannerscanners, Cellkv) Seek storefiles in parallel to optimize IO latency as much as possible - + Cell peek() Look at the next Cell in this scanner, but do not iterate scanner. - + boolean reseek(Cellkv) Reseek the scanner at or after the specified KeyValue. - + protected void resetKVHeap(http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true; title="class or interface in java.util">List? extends KeyValueScannerscanners, CellComparatorcomparator) - + protected void resetScannerStack(CelllastTopKey) - + boolean seek(Cellkey) Seek the scanner at or after the specified KeyValue. - + protected boolean seekAsDirection(Cellkv) Do a reseek in a normal StoreScanner(scan forward) + +private void +seekOrSkipToNextColumn(Cellcell) + +private void +seekOrSkipToNextRow(Cellcell) + + protected void seekScanners(http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true; title="class or interface in java.util">List? extends KeyValueScannerscanners, CellseekKey, @@ -583,24 +584,36 @@ implements Seek the specified scanners with the given key - + protected boolean seekToNextRow(Cellc) - + protected http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true; title="class or interface in java.util">ListKeyValueScanner selectScannersFrom(http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true; title="class or interface in java.util">List? extends KeyValueScannerallScanners) Filters the given list of scanners using Bloom filter, time range, and TTL. - + void shipped() Called after a batch of rows scanned and set to be returned to client. - + +protected boolean +trySkipToNextColumn(Cellcell) +See trySkipToNextRow(Cell) + + + +protected boolean +trySkipToNextRow(Cellcell) +See if we should actually SEEK or rather just SKIP to the next Cell (see HBASE-13109). + + + void updateReaders(http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true; title="class or interface in java.util">ListStoreFilesfs) Notify observers. @@ -655,7 +668,7 @@ implements LOG -private static finalorg.apache.commons.logging.Log LOG +private static finalorg.apache.commons.logging.Log LOG @@ -664,7 +677,7 @@ implements store -protected finalStore store +protected finalStore store @@ -673,7 +686,7 @@ implements matcher -protectedScanQueryMatcher matcher +protectedScanQueryMatcher matcher @@ -682,7 +695,7 @@ implements heap -protectedKeyValueHeap heap +protectedKeyValueHeap heap @@ -691,7 +704,7 @@ implements cacheBlocks -protectedboolean cacheBlocks +protectedboolean cacheBlocks @@ -700,7 +713,7 @@ implements countPerRow -protectedlong countPerRow +protectedlong countPerRow @@ -709,7 +722,7 @@ implements storeLimit -protectedint storeLimit +protectedint storeLimit @@ -718,7
[06/51] [partial] hbase-site git commit: Published site at 82d554e3783372cc6b05489452c815b57c06f6cd.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/31df4674/devapidocs/src-html/org/apache/hadoop/hbase/client/AsyncHBaseAdmin.TableProcedureBiConsumer.html -- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/client/AsyncHBaseAdmin.TableProcedureBiConsumer.html b/devapidocs/src-html/org/apache/hadoop/hbase/client/AsyncHBaseAdmin.TableProcedureBiConsumer.html index f3f7a46..8750fa2 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/client/AsyncHBaseAdmin.TableProcedureBiConsumer.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/client/AsyncHBaseAdmin.TableProcedureBiConsumer.html @@ -56,2015 +56,2125 @@ 048import org.apache.hadoop.hbase.MetaTableAccessor; 049import org.apache.hadoop.hbase.MetaTableAccessor.QueryType; 050import org.apache.hadoop.hbase.NotServingRegionException; -051import org.apache.hadoop.hbase.RegionLocations; -052import org.apache.hadoop.hbase.ServerName; -053import org.apache.hadoop.hbase.NamespaceDescriptor; -054import org.apache.hadoop.hbase.HConstants; -055import org.apache.hadoop.hbase.TableExistsException; -056import org.apache.hadoop.hbase.TableName; -057import org.apache.hadoop.hbase.AsyncMetaTableAccessor; -058import org.apache.hadoop.hbase.TableNotDisabledException; -059import org.apache.hadoop.hbase.TableNotFoundException; -060import org.apache.hadoop.hbase.UnknownRegionException; -061import org.apache.hadoop.hbase.classification.InterfaceAudience; -062import org.apache.hadoop.hbase.classification.InterfaceStability; -063import org.apache.hadoop.hbase.client.AsyncRpcRetryingCallerFactory.AdminRequestCallerBuilder; -064import org.apache.hadoop.hbase.client.AsyncRpcRetryingCallerFactory.MasterRequestCallerBuilder; -065import org.apache.hadoop.hbase.client.Scan.ReadType; -066import org.apache.hadoop.hbase.client.replication.ReplicationSerDeHelper; -067import org.apache.hadoop.hbase.client.replication.TableCFs; -068import org.apache.hadoop.hbase.exceptions.DeserializationException; -069import org.apache.hadoop.hbase.ipc.HBaseRpcController; -070import org.apache.hadoop.hbase.quotas.QuotaFilter; -071import org.apache.hadoop.hbase.quotas.QuotaSettings; -072import org.apache.hadoop.hbase.quotas.QuotaTableUtil; -073import org.apache.hadoop.hbase.replication.ReplicationException; -074import org.apache.hadoop.hbase.replication.ReplicationPeerConfig; -075import org.apache.hadoop.hbase.replication.ReplicationPeerDescription; -076import org.apache.hadoop.hbase.shaded.com.google.protobuf.RpcCallback; -077import org.apache.hadoop.hbase.shaded.protobuf.ProtobufUtil; -078import org.apache.hadoop.hbase.shaded.protobuf.RequestConverter; -079import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.AdminService; -080import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CloseRegionRequest; -081import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CloseRegionResponse; -082import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.SplitRegionRequest; -083import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.SplitRegionResponse; -084import org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos; -085import org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.TableSchema; -086import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.AddColumnRequest; -087import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.AddColumnResponse; -088import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.AssignRegionRequest; -089import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.AssignRegionResponse; -090import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.BalanceRequest; -091import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.BalanceResponse; -092import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.CreateNamespaceRequest; -093import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.CreateNamespaceResponse; -094import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.DeleteNamespaceRequest; -095import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.DeleteNamespaceResponse; -096import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.DeleteSnapshotRequest; -097import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.DeleteSnapshotResponse; -098import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.DisableTableRequest; -099import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.DisableTableResponse; -100import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.EnableTableRequest; -101import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.EnableTableResponse; -102import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.DeleteColumnRequest; -103import
[04/51] [partial] hbase-site git commit: Published site at 82d554e3783372cc6b05489452c815b57c06f6cd.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/31df4674/devapidocs/src-html/org/apache/hadoop/hbase/client/AsyncHBaseAdmin.html -- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/client/AsyncHBaseAdmin.html b/devapidocs/src-html/org/apache/hadoop/hbase/client/AsyncHBaseAdmin.html index f3f7a46..8750fa2 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/client/AsyncHBaseAdmin.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/client/AsyncHBaseAdmin.html @@ -56,2015 +56,2125 @@ 048import org.apache.hadoop.hbase.MetaTableAccessor; 049import org.apache.hadoop.hbase.MetaTableAccessor.QueryType; 050import org.apache.hadoop.hbase.NotServingRegionException; -051import org.apache.hadoop.hbase.RegionLocations; -052import org.apache.hadoop.hbase.ServerName; -053import org.apache.hadoop.hbase.NamespaceDescriptor; -054import org.apache.hadoop.hbase.HConstants; -055import org.apache.hadoop.hbase.TableExistsException; -056import org.apache.hadoop.hbase.TableName; -057import org.apache.hadoop.hbase.AsyncMetaTableAccessor; -058import org.apache.hadoop.hbase.TableNotDisabledException; -059import org.apache.hadoop.hbase.TableNotFoundException; -060import org.apache.hadoop.hbase.UnknownRegionException; -061import org.apache.hadoop.hbase.classification.InterfaceAudience; -062import org.apache.hadoop.hbase.classification.InterfaceStability; -063import org.apache.hadoop.hbase.client.AsyncRpcRetryingCallerFactory.AdminRequestCallerBuilder; -064import org.apache.hadoop.hbase.client.AsyncRpcRetryingCallerFactory.MasterRequestCallerBuilder; -065import org.apache.hadoop.hbase.client.Scan.ReadType; -066import org.apache.hadoop.hbase.client.replication.ReplicationSerDeHelper; -067import org.apache.hadoop.hbase.client.replication.TableCFs; -068import org.apache.hadoop.hbase.exceptions.DeserializationException; -069import org.apache.hadoop.hbase.ipc.HBaseRpcController; -070import org.apache.hadoop.hbase.quotas.QuotaFilter; -071import org.apache.hadoop.hbase.quotas.QuotaSettings; -072import org.apache.hadoop.hbase.quotas.QuotaTableUtil; -073import org.apache.hadoop.hbase.replication.ReplicationException; -074import org.apache.hadoop.hbase.replication.ReplicationPeerConfig; -075import org.apache.hadoop.hbase.replication.ReplicationPeerDescription; -076import org.apache.hadoop.hbase.shaded.com.google.protobuf.RpcCallback; -077import org.apache.hadoop.hbase.shaded.protobuf.ProtobufUtil; -078import org.apache.hadoop.hbase.shaded.protobuf.RequestConverter; -079import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.AdminService; -080import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CloseRegionRequest; -081import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CloseRegionResponse; -082import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.SplitRegionRequest; -083import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.SplitRegionResponse; -084import org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos; -085import org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.TableSchema; -086import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.AddColumnRequest; -087import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.AddColumnResponse; -088import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.AssignRegionRequest; -089import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.AssignRegionResponse; -090import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.BalanceRequest; -091import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.BalanceResponse; -092import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.CreateNamespaceRequest; -093import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.CreateNamespaceResponse; -094import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.DeleteNamespaceRequest; -095import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.DeleteNamespaceResponse; -096import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.DeleteSnapshotRequest; -097import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.DeleteSnapshotResponse; -098import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.DisableTableRequest; -099import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.DisableTableResponse; -100import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.EnableTableRequest; -101import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.EnableTableResponse; -102import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.DeleteColumnRequest; -103import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.DeleteColumnResponse; -104import
[40/51] [partial] hbase-site git commit: Published site at 82d554e3783372cc6b05489452c815b57c06f6cd.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/31df4674/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 1864a1e..e190354 100644 --- a/devapidocs/org/apache/hadoop/hbase/client/package-tree.html +++ b/devapidocs/org/apache/hadoop/hbase/client/package-tree.html @@ -521,25 +521,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.HBaseAdmin.ReplicationState -org.apache.hadoop.hbase.client.CompactType -org.apache.hadoop.hbase.client.AbstractResponse.ResponseType -org.apache.hadoop.hbase.client.CompactionState -org.apache.hadoop.hbase.client.MasterSwitchType -org.apache.hadoop.hbase.client.MobCompactPartitionPolicy -org.apache.hadoop.hbase.client.RequestController.ReturnCode -org.apache.hadoop.hbase.client.ScannerCallable.MoreResults -org.apache.hadoop.hbase.client.AsyncScanSingleRegionRpcRetryingCaller.ScanControllerState -org.apache.hadoop.hbase.client.Consistency org.apache.hadoop.hbase.client.AsyncRequestFutureImpl.Retry -org.apache.hadoop.hbase.client.Durability org.apache.hadoop.hbase.client.RegionLocateType -org.apache.hadoop.hbase.client.AsyncScanSingleRegionRpcRetryingCaller.ScanResumerState +org.apache.hadoop.hbase.client.MasterSwitchType +org.apache.hadoop.hbase.client.CompactType +org.apache.hadoop.hbase.client.Durability org.apache.hadoop.hbase.client.AsyncProcessTask.SubmittedRows +org.apache.hadoop.hbase.client.RequestController.ReturnCode +org.apache.hadoop.hbase.client.Consistency +org.apache.hadoop.hbase.client.AbstractResponse.ResponseType +org.apache.hadoop.hbase.client.MobCompactPartitionPolicy org.apache.hadoop.hbase.client.SnapshotType -org.apache.hadoop.hbase.client.Scan.ReadType +org.apache.hadoop.hbase.client.HBaseAdmin.ReplicationState +org.apache.hadoop.hbase.client.AsyncScanSingleRegionRpcRetryingCaller.ScanControllerState org.apache.hadoop.hbase.client.IsolationLevel +org.apache.hadoop.hbase.client.CompactionState org.apache.hadoop.hbase.client.TableState.State +org.apache.hadoop.hbase.client.Scan.ReadType +org.apache.hadoop.hbase.client.ScannerCallable.MoreResults +org.apache.hadoop.hbase.client.AsyncScanSingleRegionRpcRetryingCaller.ScanResumerState http://git-wip-us.apache.org/repos/asf/hbase-site/blob/31df4674/devapidocs/org/apache/hadoop/hbase/conf/ConfigurationObserver.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/conf/ConfigurationObserver.html b/devapidocs/org/apache/hadoop/hbase/conf/ConfigurationObserver.html index ad5e759..d23e36f 100644 --- a/devapidocs/org/apache/hadoop/hbase/conf/ConfigurationObserver.html +++ b/devapidocs/org/apache/hadoop/hbase/conf/ConfigurationObserver.html @@ -105,7 +105,7 @@ var activeTableTab = "activeTableTab"; All Known Implementing Classes: -BaseLoadBalancer, CompactSplitThread, FavoredNodeLoadBalancer, FavoredStochasticBalancer, HFileCleaner, HMaster, HMasterCommandLine.LocalHMaster, HMobStore, HRegion, HRegionServer, HStore, MasterProcedureEnv, MasterRpcServices, RpcServer, RSGroupBasedLoadBalancer, RSRpcServices, SimpleLoadBalancer, SimpleRpcScheduler, SimpleRpcServer, StochasticLoadBalancer +BaseLoadBalancer, CompactSplitThread, FavoredNodeLoadBalancer, FavoredStochasticBalancer, HFileCleaner, HMaster, HMasterCommandLine.LocalHMaster, HMobStore, HRegion, HRegionServer, HStore, MasterProcedureEnv, MasterRpcServices, NettyRpcServer, RpcServer, RSGroupBasedLoadBalancer, RSRpcServices, SimpleLoadBalancer, SimpleRpcScheduler, SimpleRpcServer, StochasticLoadBalancer http://git-wip-us.apache.org/repos/asf/hbase-site/blob/31df4674/devapidocs/org/apache/hadoop/hbase/conf/class-use/ConfigurationObserver.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/conf/class-use/ConfigurationObserver.html b/devapidocs/org/apache/hadoop/hbase/conf/class-use/ConfigurationObserver.html index 0dfbf18..6c05c79 100644 --- a/devapidocs/org/apache/hadoop/hbase/conf/class-use/ConfigurationObserver.html +++ b/devapidocs/org/apache/hadoop/hbase/conf/class-use/ConfigurationObserver.html @@ -214,17 +214,23 @@ class +NettyRpcServer +An RPC server with Netty4 implementation. + + + +class RpcServer An RPC server that hosts protobuf described Services. - + class SimpleRpcScheduler The default scheduler. - + class
[19/51] [partial] hbase-site git commit: Published site at 82d554e3783372cc6b05489452c815b57c06f6cd.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/31df4674/devapidocs/src-html/org/apache/hadoop/hbase/client/AsyncHBaseAdmin.CreateTableProcedureBiConsumer.html -- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/client/AsyncHBaseAdmin.CreateTableProcedureBiConsumer.html b/devapidocs/src-html/org/apache/hadoop/hbase/client/AsyncHBaseAdmin.CreateTableProcedureBiConsumer.html index f3f7a46..8750fa2 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/client/AsyncHBaseAdmin.CreateTableProcedureBiConsumer.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/client/AsyncHBaseAdmin.CreateTableProcedureBiConsumer.html @@ -56,2015 +56,2125 @@ 048import org.apache.hadoop.hbase.MetaTableAccessor; 049import org.apache.hadoop.hbase.MetaTableAccessor.QueryType; 050import org.apache.hadoop.hbase.NotServingRegionException; -051import org.apache.hadoop.hbase.RegionLocations; -052import org.apache.hadoop.hbase.ServerName; -053import org.apache.hadoop.hbase.NamespaceDescriptor; -054import org.apache.hadoop.hbase.HConstants; -055import org.apache.hadoop.hbase.TableExistsException; -056import org.apache.hadoop.hbase.TableName; -057import org.apache.hadoop.hbase.AsyncMetaTableAccessor; -058import org.apache.hadoop.hbase.TableNotDisabledException; -059import org.apache.hadoop.hbase.TableNotFoundException; -060import org.apache.hadoop.hbase.UnknownRegionException; -061import org.apache.hadoop.hbase.classification.InterfaceAudience; -062import org.apache.hadoop.hbase.classification.InterfaceStability; -063import org.apache.hadoop.hbase.client.AsyncRpcRetryingCallerFactory.AdminRequestCallerBuilder; -064import org.apache.hadoop.hbase.client.AsyncRpcRetryingCallerFactory.MasterRequestCallerBuilder; -065import org.apache.hadoop.hbase.client.Scan.ReadType; -066import org.apache.hadoop.hbase.client.replication.ReplicationSerDeHelper; -067import org.apache.hadoop.hbase.client.replication.TableCFs; -068import org.apache.hadoop.hbase.exceptions.DeserializationException; -069import org.apache.hadoop.hbase.ipc.HBaseRpcController; -070import org.apache.hadoop.hbase.quotas.QuotaFilter; -071import org.apache.hadoop.hbase.quotas.QuotaSettings; -072import org.apache.hadoop.hbase.quotas.QuotaTableUtil; -073import org.apache.hadoop.hbase.replication.ReplicationException; -074import org.apache.hadoop.hbase.replication.ReplicationPeerConfig; -075import org.apache.hadoop.hbase.replication.ReplicationPeerDescription; -076import org.apache.hadoop.hbase.shaded.com.google.protobuf.RpcCallback; -077import org.apache.hadoop.hbase.shaded.protobuf.ProtobufUtil; -078import org.apache.hadoop.hbase.shaded.protobuf.RequestConverter; -079import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.AdminService; -080import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CloseRegionRequest; -081import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CloseRegionResponse; -082import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.SplitRegionRequest; -083import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.SplitRegionResponse; -084import org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos; -085import org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.TableSchema; -086import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.AddColumnRequest; -087import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.AddColumnResponse; -088import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.AssignRegionRequest; -089import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.AssignRegionResponse; -090import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.BalanceRequest; -091import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.BalanceResponse; -092import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.CreateNamespaceRequest; -093import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.CreateNamespaceResponse; -094import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.DeleteNamespaceRequest; -095import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.DeleteNamespaceResponse; -096import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.DeleteSnapshotRequest; -097import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.DeleteSnapshotResponse; -098import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.DisableTableRequest; -099import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.DisableTableResponse; -100import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.EnableTableRequest; -101import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.EnableTableResponse; -102import
[02/51] [partial] hbase-site git commit: Published site at 82d554e3783372cc6b05489452c815b57c06f6cd.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/31df4674/devapidocs/src-html/org/apache/hadoop/hbase/client/HBaseAdmin.AddColumnFamilyFuture.html -- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/client/HBaseAdmin.AddColumnFamilyFuture.html b/devapidocs/src-html/org/apache/hadoop/hbase/client/HBaseAdmin.AddColumnFamilyFuture.html index 0610ad0..8b22aa1 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/client/HBaseAdmin.AddColumnFamilyFuture.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/client/HBaseAdmin.AddColumnFamilyFuture.html @@ -2665,1591 +2665,1570 @@ 2657 @Override 2658 public byte[] execProcedureWithRet(String signature, String instance, MapString, String props) 2659 throws IOException { -2660ProcedureDescription.Builder builder = ProcedureDescription.newBuilder(); -2661 builder.setSignature(signature).setInstance(instance); -2662for (EntryString, String entry : props.entrySet()) { -2663 NameStringPair pair = NameStringPair.newBuilder().setName(entry.getKey()) -2664 .setValue(entry.getValue()).build(); -2665 builder.addConfiguration(pair); -2666} -2667 -2668final ExecProcedureRequest request = ExecProcedureRequest.newBuilder() -2669 .setProcedure(builder.build()).build(); -2670// run the procedure on the master -2671ExecProcedureResponse response = executeCallable(new MasterCallableExecProcedureResponse( -2672getConnection(), getRpcControllerFactory()) { -2673 @Override -2674 protected ExecProcedureResponse rpcCall() throws Exception { -2675return master.execProcedureWithRet(getRpcController(), request); -2676 } -2677}); -2678 -2679return response.hasReturnData() ? response.getReturnData().toByteArray() : null; -2680 } -2681 -2682 @Override -2683 public void execProcedure(String signature, String instance, MapString, String props) -2684 throws IOException { -2685ProcedureDescription.Builder builder = ProcedureDescription.newBuilder(); -2686 builder.setSignature(signature).setInstance(instance); -2687for (EntryString, String entry : props.entrySet()) { -2688 NameStringPair pair = NameStringPair.newBuilder().setName(entry.getKey()) -2689 .setValue(entry.getValue()).build(); -2690 builder.addConfiguration(pair); -2691} -2692 -2693final ExecProcedureRequest request = ExecProcedureRequest.newBuilder() -2694 .setProcedure(builder.build()).build(); -2695// run the procedure on the master -2696ExecProcedureResponse response = executeCallable(new MasterCallableExecProcedureResponse( -2697getConnection(), getRpcControllerFactory()) { -2698 @Override -2699 protected ExecProcedureResponse rpcCall() throws Exception { -2700return master.execProcedure(getRpcController(), request); -2701 } -2702}); -2703 -2704long start = EnvironmentEdgeManager.currentTime(); -2705long max = response.getExpectedTimeout(); -2706long maxPauseTime = max / this.numRetries; -2707int tries = 0; -2708LOG.debug("Waiting a max of " + max + " ms for procedure '" + -2709signature + " : " + instance + "'' to complete. (max " + maxPauseTime + " ms per retry)"); -2710boolean done = false; -2711while (tries == 0 -2712|| ((EnvironmentEdgeManager.currentTime() - start) max !done)) { -2713 try { -2714// sleep a backoff = pauseTime amount -2715long sleep = getPauseTime(tries++); -2716sleep = sleep maxPauseTime ? maxPauseTime : sleep; -2717LOG.debug("(#" + tries + ") Sleeping: " + sleep + -2718 "ms while waiting for procedure completion."); -2719Thread.sleep(sleep); -2720 } catch (InterruptedException e) { -2721throw (InterruptedIOException)new InterruptedIOException("Interrupted").initCause(e); -2722 } -2723 LOG.debug("Getting current status of procedure from master..."); -2724 done = isProcedureFinished(signature, instance, props); -2725} -2726if (!done) { -2727 throw new IOException("Procedure '" + signature + " : " + instance -2728 + "' wasn't completed in expectedTime:" + max + " ms"); -2729} +2660ProcedureDescription desc = ProtobufUtil.buildProcedureDescription(signature, instance, props); +2661final ExecProcedureRequest request = +2662 ExecProcedureRequest.newBuilder().setProcedure(desc).build(); +2663// run the procedure on the master +2664ExecProcedureResponse response = executeCallable( +2665 new MasterCallableExecProcedureResponse(getConnection(), getRpcControllerFactory()) { +2666@Override +2667protected ExecProcedureResponse rpcCall() throws Exception { +2668 return master.execProcedureWithRet(getRpcController(), request); +2669} +2670 }); +2671 +2672return
[43/51] [partial] hbase-site git commit: Published site at 82d554e3783372cc6b05489452c815b57c06f6cd.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/31df4674/devapidocs/org/apache/hadoop/hbase/client/AsyncHBaseAdmin.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/client/AsyncHBaseAdmin.html b/devapidocs/org/apache/hadoop/hbase/client/AsyncHBaseAdmin.html index 484a3ea..a305c65 100644 --- a/devapidocs/org/apache/hadoop/hbase/client/AsyncHBaseAdmin.html +++ b/devapidocs/org/apache/hadoop/hbase/client/AsyncHBaseAdmin.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}; +var methods = {"i0":10,"i1":10,"i2":10,"i3":10,"i4":10,"i5":10,"i6":10,"i7":10,"i8":10,"i9":10,"i10":10,"i11":10,"i12":10,"i13":10,"i14":10,"i15":10,"i16":10,"i17":10,"i18":10,"i19":10,"i20":10,"i21":10,"i22":10,"i23":10,"i24":10,"i25":10,"i26":10,"i27":10,"i28":10,"i29":10,"i30":10,"i31":10,"i32":10,"i33":10,"i34":10,"i35":10,"i36":10,"i37":10,"i38":10,"i39":10,"i40":10,"i41":10,"i42":10,"i43":10,"i44":10,"i45":10,"i46":10,"i47":10,"i48":10,"i49":10,"i50":10,"i51":10,"i52":10,"i53":10,"i54":10,"i55":10,"i56":10,"i57":10,"i58":10,"i59":10,"i60":10,"i61":10,"i62":10,"i63":10,"i64":10,"i65":10,"i66":10,"i67":10,"i68":10,"i69":10,"i70":10,"i71":10,"i72":10,"i73":10,"i74":10,"i75":10,"i76":10,"i77":10,"i78":10,"i79":10,"i80":10,"i81":10,"i82":10,"i83":10,"i84":10,"i85":10,"i86":10,"i87":10,"i88":10,"i89":10,"i90":10,"i91":10,"i92":10,"i93":10,"i94":10,"i95":10,"i96":10,"i97":10,"i98":10,"i99":10,"i100":10,"i101":10,"i102":10,"i103":10,"i104":10,"i105":10,"i106":10,"i107":10}; var tabs = {65535:["t0","All Methods"],2:["t2","Instance Methods"],8:["t4","Concrete Methods"]}; var altColor = "altColor"; var rowColor = "rowColor"; @@ -115,7 +115,7 @@ var activeTableTab = "activeTableTab"; @InterfaceAudience.Private @InterfaceStability.Evolving -public class AsyncHBaseAdmin +public class AsyncHBaseAdmin 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 AsyncAdmin The implementation of AsyncAdmin. @@ -297,20 +297,27 @@ implements Method and Description +http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/CompletableFuture.html?is-external=true; title="class or interface in java.util.concurrent">CompletableFuturehttp://docs.oracle.com/javase/8/docs/api/java/lang/Boolean.html?is-external=true; title="class or interface in java.lang">Boolean +abortProcedure(longprocId, + booleanmayInterruptIfRunning) +abort a procedure + + + http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/CompletableFuture.html?is-external=true; title="class or interface in java.util.concurrent">CompletableFuturehttp://docs.oracle.com/javase/8/docs/api/java/lang/Void.html?is-external=true; title="class or interface in java.lang">Void addColumnFamily(TableNametableName, HColumnDescriptorcolumnFamily) Add a column family to an existing table. - + http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/CompletableFuture.html?is-external=true; title="class or interface in java.util.concurrent">CompletableFuturehttp://docs.oracle.com/javase/8/docs/api/java/lang/Void.html?is-external=true; title="class or interface in java.lang">Void addReplicationPeer(http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">StringpeerId, ReplicationPeerConfigpeerConfig) Add a new replication peer for replicating data to slave cluster - + private PREQ,PRESP,RESPhttp://docs.oracle.com/javase/8/docs/api/java/util/concurrent/CompletableFuture.html?is-external=true; title="class or interface in java.util.concurrent">CompletableFutureRESP adminCall(HBaseRpcControllercontroller, org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.AdminService.Interfacestub, @@ -318,36 +325,36 @@ implements AsyncHBaseAdmin.AdminRpcCallPRESP,PREQrpcCall, AsyncHBaseAdmin.ConverterRESP,PRESPrespConverter) - +
[48/51] [partial] hbase-site git commit: Published site at 82d554e3783372cc6b05489452c815b57c06f6cd.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/31df4674/devapidocs/index-all.html -- diff --git a/devapidocs/index-all.html b/devapidocs/index-all.html index a629294..32022a5 100644 --- a/devapidocs/index-all.html +++ b/devapidocs/index-all.html @@ -236,6 +236,12 @@ abort a procedure +abortProcedure(long, boolean) - Method in interface org.apache.hadoop.hbase.client.AsyncAdmin + +abort a procedure + +abortProcedure(long, boolean) - Method in class org.apache.hadoop.hbase.client.AsyncHBaseAdmin + abortProcedure(long, boolean) - Method in class org.apache.hadoop.hbase.client.HBaseAdmin abortProcedure(RpcController, MasterProtos.AbortProcedureRequest) - Method in class org.apache.hadoop.hbase.client.ShortCircuitMasterConnection @@ -2730,6 +2736,8 @@ allCells - Variable in class org.apache.hadoop.hbase.mapreduce.CopyTable +allChannels - Variable in class org.apache.hadoop.hbase.ipc.NettyRpcServer + allCompactedFilesCached - Variable in class org.apache.hadoop.hbase.regionserver.StripeStoreFileManager.State allFiles - Variable in class org.apache.hadoop.hbase.master.MasterMobCompactionThread.CompactionRunner @@ -4249,7 +4257,7 @@ AuthenticationTokenSelector() - Constructor for class org.apache.hadoop.hbase.security.token.AuthenticationTokenSelector -authFailedCall - Variable in class org.apache.hadoop.hbase.ipc.SimpleRpcServer.Connection +authFailedCall - Variable in class org.apache.hadoop.hbase.ipc.RpcServer.Connection authFailedFailedOpCount - Variable in class org.apache.hadoop.hbase.zookeeper.MetricsZooKeeperSourceImpl @@ -4353,7 +4361,7 @@ authorize(User, TableName, byte[], Permission.Action) - Method in class org.apache.hadoop.hbase.security.access.TableAuthManager -authorizeConnection() - Method in class org.apache.hadoop.hbase.ipc.SimpleRpcServer.Connection +authorizeConnection() - Method in class org.apache.hadoop.hbase.ipc.RpcServer.Connection authorizeGroup(String, Permission.Action) - Method in class org.apache.hadoop.hbase.security.access.TableAuthManager @@ -5707,6 +5715,8 @@ Deprecated. +bindAddress - Variable in class org.apache.hadoop.hbase.ipc.NettyRpcServer + bindAddress - Variable in class org.apache.hadoop.hbase.ipc.RpcServer bindToPort(String, int) - Static method in class org.apache.hadoop.hbase.thrift2.ThriftServer @@ -8221,6 +8231,14 @@ call - Variable in class org.apache.hadoop.hbase.ipc.CallRunner +call(BlockingService, Descriptors.MethodDescriptor, Message, CellScanner, long, MonitoredRPCHandler) - Method in class org.apache.hadoop.hbase.ipc.NettyRpcServer + +call(BlockingService, Descriptors.MethodDescriptor, Message, CellScanner, long, MonitoredRPCHandler, long, int) - Method in class org.apache.hadoop.hbase.ipc.NettyRpcServer + +Call(int, BlockingService, Descriptors.MethodDescriptor, RPCProtos.RequestHeader, Message, CellScanner, RpcServer.Connection, long, TraceInfo, InetAddress, int, RpcServer.CallCleanup) - Constructor for class org.apache.hadoop.hbase.ipc.NettyRpcServer.Call + +call - Variable in class org.apache.hadoop.hbase.ipc.NettyRpcServer.CallWriteListener + call(RpcCall, MonitoredRPCHandler) - Method in class org.apache.hadoop.hbase.ipc.RpcServer This is a server side method, which is invoked over RPC. @@ -8245,7 +8263,7 @@ call(BlockingService, Descriptors.MethodDescriptor, Message, CellScanner, long, MonitoredRPCHandler, long, int) - Method in class org.apache.hadoop.hbase.ipc.SimpleRpcServer -Call(int, BlockingService, Descriptors.MethodDescriptor, RPCProtos.RequestHeader, Message, CellScanner, SimpleRpcServer.Connection, SimpleRpcServer.Responder, long, TraceInfo, InetAddress, int, RpcServer.CallCleanup) - Constructor for class org.apache.hadoop.hbase.ipc.SimpleRpcServer.Call +Call(int, BlockingService, Descriptors.MethodDescriptor, RPCProtos.RequestHeader, Message, CellScanner, RpcServer.Connection, long, TraceInfo, InetAddress, int, RpcServer.CallCleanup, SimpleRpcServer.Responder) - Constructor for class org.apache.hadoop.hbase.ipc.SimpleRpcServer.Call call() - Method in class org.apache.hadoop.hbase.master.AssignCallable @@ -8562,6 +8580,8 @@ callWithRetries(RetryingCallableT, int) - Method in class org.apache.hadoop.hbase.client.RpcRetryingCallerImpl +CallWriteListener(NettyRpcServer.Call) - Constructor for class org.apache.hadoop.hbase.ipc.NettyRpcServer.CallWriteListener + calSleepTimeMs() - Method in class org.apache.hadoop.hbase.io.hadoopbackport.ThrottledInputStream calSleepTimeMs(long, long, long) - Static method in class org.apache.hadoop.hbase.io.hadoopbackport.ThrottledInputStream @@ -9442,10 +9462,14 @@ channel - Variable in class org.apache.hadoop.hbase.ipc.NettyRpcConnection +channel - Variable in class org.apache.hadoop.hbase.ipc.NettyRpcServer.NettyConnection + channel - Variable in class
[29/51] [partial] hbase-site git commit: Published site at 82d554e3783372cc6b05489452c815b57c06f6cd.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/31df4674/devapidocs/org/apache/hadoop/hbase/regionserver/MobStoreScanner.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/regionserver/MobStoreScanner.html b/devapidocs/org/apache/hadoop/hbase/regionserver/MobStoreScanner.html index 3fe7938..fb99b5a 100644 --- a/devapidocs/org/apache/hadoop/hbase/regionserver/MobStoreScanner.html +++ b/devapidocs/org/apache/hadoop/hbase/regionserver/MobStoreScanner.html @@ -245,7 +245,7 @@ extends StoreScanner -addCurrentScanners, checkFlushed, checkReseek, checkScanOrder, close, enableLazySeekGlobally, getAllScannersForTesting, getEstimatedNumberOfKvsScanned, getNextIndexedKey, getScannerOrder, getScannersNoCompaction, next, next, optimize, peek, reseek, resetKVHeap, resetScannerStack, seek, seekAsDirection, seekScanners, seekToNextRow, selectScannersFrom, shipped, updateReaders +addCurrentScanners, checkFlushed, checkReseek, checkScanOrder, close, enableLazySeekGlobally, getAllScannersForTesting, getEstimatedNumberOfKvsScanned, getNextIndexedKey, getScannerOrder, getScannersNoCompaction, next, next, peek, reseek, resetKVHeap, resetScannerStack, seek, seekAsDirection, seekScanners, seekToNextRow, selectScannersFrom, shipped, trySkipToNextColumn, trySkipToNextRow, updateReaders http://git-wip-us.apache.org/repos/asf/hbase-site/blob/31df4674/devapidocs/org/apache/hadoop/hbase/regionserver/Region.FlushResult.Result.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/regionserver/Region.FlushResult.Result.html b/devapidocs/org/apache/hadoop/hbase/regionserver/Region.FlushResult.Result.html index fa0dca0..42be667 100644 --- a/devapidocs/org/apache/hadoop/hbase/regionserver/Region.FlushResult.Result.html +++ b/devapidocs/org/apache/hadoop/hbase/regionserver/Region.FlushResult.Result.html @@ -260,7 +260,7 @@ the order they are declared. values -public staticRegion.FlushResult.Result[]values() +public staticRegion.FlushResult.Result[]values() Returns an array containing the constants of this enum type, in the order they are declared. This method may be used to iterate over the constants as follows: @@ -280,7 +280,7 @@ for (Region.FlushResult.Result c : Region.FlushResult.Result.values()) valueOf -public staticRegion.FlushResult.ResultvalueOf(http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">Stringname) +public staticRegion.FlushResult.ResultvalueOf(http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">Stringname) Returns the enum constant of this type with the specified name. The string must match exactly an identifier used to declare an enum constant in this type. (Extraneous whitespace characters are http://git-wip-us.apache.org/repos/asf/hbase-site/blob/31df4674/devapidocs/org/apache/hadoop/hbase/regionserver/ReversedMobStoreScanner.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/regionserver/ReversedMobStoreScanner.html b/devapidocs/org/apache/hadoop/hbase/regionserver/ReversedMobStoreScanner.html index 86622e0..6da46d3 100644 --- a/devapidocs/org/apache/hadoop/hbase/regionserver/ReversedMobStoreScanner.html +++ b/devapidocs/org/apache/hadoop/hbase/regionserver/ReversedMobStoreScanner.html @@ -257,7 +257,7 @@ extends StoreScanner -addCurrentScanners, checkFlushed, checkReseek, close, enableLazySeekGlobally, getAllScannersForTesting, getEstimatedNumberOfKvsScanned, getNextIndexedKey, getScannerOrder, getScannersNoCompaction, next, next, optimize, peek, resetScannerStack, selectScannersFrom, shipped, updateReaders +addCurrentScanners, checkFlushed, checkReseek, close, enableLazySeekGlobally, getAllScannersForTesting, getEstimatedNumberOfKvsScanned, getNextIndexedKey, getScannerOrder, getScannersNoCompaction, next, next, peek, resetScannerStack, selectScannersFrom, shipped, trySkipToNextColumn, trySkipToNextRow, updateReaders http://git-wip-us.apache.org/repos/asf/hbase-site/blob/31df4674/devapidocs/org/apache/hadoop/hbase/regionserver/ReversedStoreScanner.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/regionserver/ReversedStoreScanner.html b/devapidocs/org/apache/hadoop/hbase/regionserver/ReversedStoreScanner.html index 90c74d0..7fa0629 100644 --- a/devapidocs/org/apache/hadoop/hbase/regionserver/ReversedStoreScanner.html +++ b/devapidocs/org/apache/hadoop/hbase/regionserver/ReversedStoreScanner.html @@ -292,7 +292,7 @@ implements StoreScanner -addCurrentScanners, checkFlushed, checkReseek, close, enableLazySeekGlobally, getAllScannersForTesting,
[36/51] [partial] hbase-site git commit: Published site at 82d554e3783372cc6b05489452c815b57c06f6cd.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/31df4674/devapidocs/org/apache/hadoop/hbase/ipc/RpcServer.Connection.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/ipc/RpcServer.Connection.html b/devapidocs/org/apache/hadoop/hbase/ipc/RpcServer.Connection.html index 9cd6a86..2319d90 100644 --- a/devapidocs/org/apache/hadoop/hbase/ipc/RpcServer.Connection.html +++ b/devapidocs/org/apache/hadoop/hbase/ipc/RpcServer.Connection.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":6,"i9":10,"i10":10,"i11":10}; +var methods = {"i0":10,"i1":6,"i2":10,"i3":10,"i4":10,"i5":10,"i6":10,"i7":10,"i8":10,"i9":10,"i10":10,"i11":10,"i12":10,"i13":6,"i14":10,"i15":10,"i16":10,"i17":10,"i18":10,"i19":10,"i20":10,"i21":10,"i22":10}; var tabs = {65535:["t0","All Methods"],2:["t2","Instance Methods"],4:["t3","Abstract Methods"],8:["t4","Concrete Methods"]}; var altColor = "altColor"; var rowColor = "rowColor"; @@ -108,8 +108,12 @@ var activeTableTab = "activeTableTab"; +All Implemented Interfaces: +http://docs.oracle.com/javase/8/docs/api/java/io/Closeable.html?is-external=true; title="class or interface in java.io">Closeable, http://docs.oracle.com/javase/8/docs/api/java/lang/AutoCloseable.html?is-external=true; title="class or interface in java.lang">AutoCloseable + + Direct Known Subclasses: -SimpleRpcServer.Connection +NettyRpcServer.NettyConnection, SimpleRpcServer.Connection Enclosing class: @@ -117,8 +121,9 @@ var activeTableTab = "activeTableTab"; -public abstract class RpcServer.Connection -extends http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true; title="class or interface in java.lang">Object +public abstract class RpcServer.Connection +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 http://docs.oracle.com/javase/8/docs/api/java/io/Closeable.html?is-external=true; title="class or interface in java.io">Closeable Reads calls from a connection and queues them for handling. @@ -151,69 +156,77 @@ extends http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? authenticatedWithFallback +protected RpcServer.Call +authFailedCall + + protected http://docs.oracle.com/javase/8/docs/api/java/io/ByteArrayOutputStream.html?is-external=true; title="class or interface in java.io">ByteArrayOutputStream authFailedResponse - + protected AuthMethod authMethod - + protected static int AUTHORIZATION_FAILED_CALLID - + protected RpcServer.CallCleanup callCleanup - + protected Codec codec Codec the client asked use. - + protected org.apache.hadoop.io.compress.CompressionCodec compressionCodec Compression codec the client asked us use. - + protected static int CONNECTION_HEADER_RESPONSE_CALLID - + protected org.apache.hadoop.hbase.shaded.protobuf.generated.RPCProtos.ConnectionHeader connectionHeader - + protected boolean connectionHeaderRead - + protected boolean connectionPreambleRead - + protected CryptoAES cryptoAES - + protected http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String hostAddress - + protected int remotePort - + protected boolean retryImmediatelySupported - + protected static int SASL_CALLID + +protected RpcServer.Call +saslCall + protected boolean saslContextEstablished @@ -227,26 +240,38 @@ extends http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? service +protected RpcServer.Call +setConnectionHeaderResponseCall + + protected boolean skipInitialSaslHandshake - + protected org.apache.hadoop.security.UserGroupInformation ugi + +private http://docs.oracle.com/javase/8/docs/api/java/nio/ByteBuffer.html?is-external=true; title="class or interface in java.nio">ByteBuffer +unwrappedData + +private http://docs.oracle.com/javase/8/docs/api/java/nio/ByteBuffer.html?is-external=true; title="class or interface in java.nio">ByteBuffer +unwrappedDataLengthBuffer + + protected boolean useCryptoAesWrap - + protected User user - + protected boolean useSasl - + protected boolean useWrap @@ -283,56 +308,118 @@ extends http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? Method and Description +protected boolean +authorizeConnection() + + +abstract RpcServer.Call +createCall(intid, + org.apache.hadoop.hbase.shaded.com.google.protobuf.BlockingServiceservice, + org.apache.hadoop.hbase.shaded.com.google.protobuf.Descriptors.MethodDescriptormd, + org.apache.hadoop.hbase.shaded.protobuf.generated.RPCProtos.RequestHeaderheader, + org.apache.hadoop.hbase.shaded.com.google.protobuf.Messageparam, + CellScannercellScanner, +
[10/51] [partial] hbase-site git commit: Published site at 82d554e3783372cc6b05489452c815b57c06f6cd.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/31df4674/devapidocs/src-html/org/apache/hadoop/hbase/client/AsyncHBaseAdmin.ModifyNamespaceProcedureBiConsumer.html -- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/client/AsyncHBaseAdmin.ModifyNamespaceProcedureBiConsumer.html b/devapidocs/src-html/org/apache/hadoop/hbase/client/AsyncHBaseAdmin.ModifyNamespaceProcedureBiConsumer.html index f3f7a46..8750fa2 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/client/AsyncHBaseAdmin.ModifyNamespaceProcedureBiConsumer.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/client/AsyncHBaseAdmin.ModifyNamespaceProcedureBiConsumer.html @@ -56,2015 +56,2125 @@ 048import org.apache.hadoop.hbase.MetaTableAccessor; 049import org.apache.hadoop.hbase.MetaTableAccessor.QueryType; 050import org.apache.hadoop.hbase.NotServingRegionException; -051import org.apache.hadoop.hbase.RegionLocations; -052import org.apache.hadoop.hbase.ServerName; -053import org.apache.hadoop.hbase.NamespaceDescriptor; -054import org.apache.hadoop.hbase.HConstants; -055import org.apache.hadoop.hbase.TableExistsException; -056import org.apache.hadoop.hbase.TableName; -057import org.apache.hadoop.hbase.AsyncMetaTableAccessor; -058import org.apache.hadoop.hbase.TableNotDisabledException; -059import org.apache.hadoop.hbase.TableNotFoundException; -060import org.apache.hadoop.hbase.UnknownRegionException; -061import org.apache.hadoop.hbase.classification.InterfaceAudience; -062import org.apache.hadoop.hbase.classification.InterfaceStability; -063import org.apache.hadoop.hbase.client.AsyncRpcRetryingCallerFactory.AdminRequestCallerBuilder; -064import org.apache.hadoop.hbase.client.AsyncRpcRetryingCallerFactory.MasterRequestCallerBuilder; -065import org.apache.hadoop.hbase.client.Scan.ReadType; -066import org.apache.hadoop.hbase.client.replication.ReplicationSerDeHelper; -067import org.apache.hadoop.hbase.client.replication.TableCFs; -068import org.apache.hadoop.hbase.exceptions.DeserializationException; -069import org.apache.hadoop.hbase.ipc.HBaseRpcController; -070import org.apache.hadoop.hbase.quotas.QuotaFilter; -071import org.apache.hadoop.hbase.quotas.QuotaSettings; -072import org.apache.hadoop.hbase.quotas.QuotaTableUtil; -073import org.apache.hadoop.hbase.replication.ReplicationException; -074import org.apache.hadoop.hbase.replication.ReplicationPeerConfig; -075import org.apache.hadoop.hbase.replication.ReplicationPeerDescription; -076import org.apache.hadoop.hbase.shaded.com.google.protobuf.RpcCallback; -077import org.apache.hadoop.hbase.shaded.protobuf.ProtobufUtil; -078import org.apache.hadoop.hbase.shaded.protobuf.RequestConverter; -079import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.AdminService; -080import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CloseRegionRequest; -081import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CloseRegionResponse; -082import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.SplitRegionRequest; -083import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.SplitRegionResponse; -084import org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos; -085import org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.TableSchema; -086import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.AddColumnRequest; -087import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.AddColumnResponse; -088import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.AssignRegionRequest; -089import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.AssignRegionResponse; -090import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.BalanceRequest; -091import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.BalanceResponse; -092import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.CreateNamespaceRequest; -093import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.CreateNamespaceResponse; -094import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.DeleteNamespaceRequest; -095import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.DeleteNamespaceResponse; -096import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.DeleteSnapshotRequest; -097import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.DeleteSnapshotResponse; -098import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.DisableTableRequest; -099import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.DisableTableResponse; -100import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.EnableTableRequest; -101import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.EnableTableResponse; -102import
[22/51] [partial] hbase-site git commit: Published site at 82d554e3783372cc6b05489452c815b57c06f6cd.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/31df4674/devapidocs/src-html/org/apache/hadoop/hbase/client/AsyncHBaseAdmin.AdminRpcCall.html -- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/client/AsyncHBaseAdmin.AdminRpcCall.html b/devapidocs/src-html/org/apache/hadoop/hbase/client/AsyncHBaseAdmin.AdminRpcCall.html index f3f7a46..8750fa2 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/client/AsyncHBaseAdmin.AdminRpcCall.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/client/AsyncHBaseAdmin.AdminRpcCall.html @@ -56,2015 +56,2125 @@ 048import org.apache.hadoop.hbase.MetaTableAccessor; 049import org.apache.hadoop.hbase.MetaTableAccessor.QueryType; 050import org.apache.hadoop.hbase.NotServingRegionException; -051import org.apache.hadoop.hbase.RegionLocations; -052import org.apache.hadoop.hbase.ServerName; -053import org.apache.hadoop.hbase.NamespaceDescriptor; -054import org.apache.hadoop.hbase.HConstants; -055import org.apache.hadoop.hbase.TableExistsException; -056import org.apache.hadoop.hbase.TableName; -057import org.apache.hadoop.hbase.AsyncMetaTableAccessor; -058import org.apache.hadoop.hbase.TableNotDisabledException; -059import org.apache.hadoop.hbase.TableNotFoundException; -060import org.apache.hadoop.hbase.UnknownRegionException; -061import org.apache.hadoop.hbase.classification.InterfaceAudience; -062import org.apache.hadoop.hbase.classification.InterfaceStability; -063import org.apache.hadoop.hbase.client.AsyncRpcRetryingCallerFactory.AdminRequestCallerBuilder; -064import org.apache.hadoop.hbase.client.AsyncRpcRetryingCallerFactory.MasterRequestCallerBuilder; -065import org.apache.hadoop.hbase.client.Scan.ReadType; -066import org.apache.hadoop.hbase.client.replication.ReplicationSerDeHelper; -067import org.apache.hadoop.hbase.client.replication.TableCFs; -068import org.apache.hadoop.hbase.exceptions.DeserializationException; -069import org.apache.hadoop.hbase.ipc.HBaseRpcController; -070import org.apache.hadoop.hbase.quotas.QuotaFilter; -071import org.apache.hadoop.hbase.quotas.QuotaSettings; -072import org.apache.hadoop.hbase.quotas.QuotaTableUtil; -073import org.apache.hadoop.hbase.replication.ReplicationException; -074import org.apache.hadoop.hbase.replication.ReplicationPeerConfig; -075import org.apache.hadoop.hbase.replication.ReplicationPeerDescription; -076import org.apache.hadoop.hbase.shaded.com.google.protobuf.RpcCallback; -077import org.apache.hadoop.hbase.shaded.protobuf.ProtobufUtil; -078import org.apache.hadoop.hbase.shaded.protobuf.RequestConverter; -079import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.AdminService; -080import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CloseRegionRequest; -081import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CloseRegionResponse; -082import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.SplitRegionRequest; -083import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.SplitRegionResponse; -084import org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos; -085import org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.TableSchema; -086import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.AddColumnRequest; -087import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.AddColumnResponse; -088import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.AssignRegionRequest; -089import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.AssignRegionResponse; -090import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.BalanceRequest; -091import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.BalanceResponse; -092import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.CreateNamespaceRequest; -093import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.CreateNamespaceResponse; -094import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.DeleteNamespaceRequest; -095import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.DeleteNamespaceResponse; -096import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.DeleteSnapshotRequest; -097import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.DeleteSnapshotResponse; -098import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.DisableTableRequest; -099import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.DisableTableResponse; -100import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.EnableTableRequest; -101import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.EnableTableResponse; -102import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.DeleteColumnRequest; -103import
[13/51] [partial] hbase-site git commit: Published site at 82d554e3783372cc6b05489452c815b57c06f6cd.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/31df4674/devapidocs/src-html/org/apache/hadoop/hbase/client/AsyncHBaseAdmin.MasterRpcCall.html -- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/client/AsyncHBaseAdmin.MasterRpcCall.html b/devapidocs/src-html/org/apache/hadoop/hbase/client/AsyncHBaseAdmin.MasterRpcCall.html index f3f7a46..8750fa2 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/client/AsyncHBaseAdmin.MasterRpcCall.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/client/AsyncHBaseAdmin.MasterRpcCall.html @@ -56,2015 +56,2125 @@ 048import org.apache.hadoop.hbase.MetaTableAccessor; 049import org.apache.hadoop.hbase.MetaTableAccessor.QueryType; 050import org.apache.hadoop.hbase.NotServingRegionException; -051import org.apache.hadoop.hbase.RegionLocations; -052import org.apache.hadoop.hbase.ServerName; -053import org.apache.hadoop.hbase.NamespaceDescriptor; -054import org.apache.hadoop.hbase.HConstants; -055import org.apache.hadoop.hbase.TableExistsException; -056import org.apache.hadoop.hbase.TableName; -057import org.apache.hadoop.hbase.AsyncMetaTableAccessor; -058import org.apache.hadoop.hbase.TableNotDisabledException; -059import org.apache.hadoop.hbase.TableNotFoundException; -060import org.apache.hadoop.hbase.UnknownRegionException; -061import org.apache.hadoop.hbase.classification.InterfaceAudience; -062import org.apache.hadoop.hbase.classification.InterfaceStability; -063import org.apache.hadoop.hbase.client.AsyncRpcRetryingCallerFactory.AdminRequestCallerBuilder; -064import org.apache.hadoop.hbase.client.AsyncRpcRetryingCallerFactory.MasterRequestCallerBuilder; -065import org.apache.hadoop.hbase.client.Scan.ReadType; -066import org.apache.hadoop.hbase.client.replication.ReplicationSerDeHelper; -067import org.apache.hadoop.hbase.client.replication.TableCFs; -068import org.apache.hadoop.hbase.exceptions.DeserializationException; -069import org.apache.hadoop.hbase.ipc.HBaseRpcController; -070import org.apache.hadoop.hbase.quotas.QuotaFilter; -071import org.apache.hadoop.hbase.quotas.QuotaSettings; -072import org.apache.hadoop.hbase.quotas.QuotaTableUtil; -073import org.apache.hadoop.hbase.replication.ReplicationException; -074import org.apache.hadoop.hbase.replication.ReplicationPeerConfig; -075import org.apache.hadoop.hbase.replication.ReplicationPeerDescription; -076import org.apache.hadoop.hbase.shaded.com.google.protobuf.RpcCallback; -077import org.apache.hadoop.hbase.shaded.protobuf.ProtobufUtil; -078import org.apache.hadoop.hbase.shaded.protobuf.RequestConverter; -079import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.AdminService; -080import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CloseRegionRequest; -081import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CloseRegionResponse; -082import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.SplitRegionRequest; -083import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.SplitRegionResponse; -084import org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos; -085import org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.TableSchema; -086import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.AddColumnRequest; -087import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.AddColumnResponse; -088import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.AssignRegionRequest; -089import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.AssignRegionResponse; -090import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.BalanceRequest; -091import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.BalanceResponse; -092import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.CreateNamespaceRequest; -093import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.CreateNamespaceResponse; -094import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.DeleteNamespaceRequest; -095import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.DeleteNamespaceResponse; -096import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.DeleteSnapshotRequest; -097import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.DeleteSnapshotResponse; -098import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.DisableTableRequest; -099import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.DisableTableResponse; -100import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.EnableTableRequest; -101import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.EnableTableResponse; -102import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.DeleteColumnRequest; -103import
[17/51] [partial] hbase-site git commit: Published site at 82d554e3783372cc6b05489452c815b57c06f6cd.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/31df4674/devapidocs/src-html/org/apache/hadoop/hbase/client/AsyncHBaseAdmin.DeleteNamespaceProcedureBiConsumer.html -- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/client/AsyncHBaseAdmin.DeleteNamespaceProcedureBiConsumer.html b/devapidocs/src-html/org/apache/hadoop/hbase/client/AsyncHBaseAdmin.DeleteNamespaceProcedureBiConsumer.html index f3f7a46..8750fa2 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/client/AsyncHBaseAdmin.DeleteNamespaceProcedureBiConsumer.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/client/AsyncHBaseAdmin.DeleteNamespaceProcedureBiConsumer.html @@ -56,2015 +56,2125 @@ 048import org.apache.hadoop.hbase.MetaTableAccessor; 049import org.apache.hadoop.hbase.MetaTableAccessor.QueryType; 050import org.apache.hadoop.hbase.NotServingRegionException; -051import org.apache.hadoop.hbase.RegionLocations; -052import org.apache.hadoop.hbase.ServerName; -053import org.apache.hadoop.hbase.NamespaceDescriptor; -054import org.apache.hadoop.hbase.HConstants; -055import org.apache.hadoop.hbase.TableExistsException; -056import org.apache.hadoop.hbase.TableName; -057import org.apache.hadoop.hbase.AsyncMetaTableAccessor; -058import org.apache.hadoop.hbase.TableNotDisabledException; -059import org.apache.hadoop.hbase.TableNotFoundException; -060import org.apache.hadoop.hbase.UnknownRegionException; -061import org.apache.hadoop.hbase.classification.InterfaceAudience; -062import org.apache.hadoop.hbase.classification.InterfaceStability; -063import org.apache.hadoop.hbase.client.AsyncRpcRetryingCallerFactory.AdminRequestCallerBuilder; -064import org.apache.hadoop.hbase.client.AsyncRpcRetryingCallerFactory.MasterRequestCallerBuilder; -065import org.apache.hadoop.hbase.client.Scan.ReadType; -066import org.apache.hadoop.hbase.client.replication.ReplicationSerDeHelper; -067import org.apache.hadoop.hbase.client.replication.TableCFs; -068import org.apache.hadoop.hbase.exceptions.DeserializationException; -069import org.apache.hadoop.hbase.ipc.HBaseRpcController; -070import org.apache.hadoop.hbase.quotas.QuotaFilter; -071import org.apache.hadoop.hbase.quotas.QuotaSettings; -072import org.apache.hadoop.hbase.quotas.QuotaTableUtil; -073import org.apache.hadoop.hbase.replication.ReplicationException; -074import org.apache.hadoop.hbase.replication.ReplicationPeerConfig; -075import org.apache.hadoop.hbase.replication.ReplicationPeerDescription; -076import org.apache.hadoop.hbase.shaded.com.google.protobuf.RpcCallback; -077import org.apache.hadoop.hbase.shaded.protobuf.ProtobufUtil; -078import org.apache.hadoop.hbase.shaded.protobuf.RequestConverter; -079import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.AdminService; -080import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CloseRegionRequest; -081import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CloseRegionResponse; -082import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.SplitRegionRequest; -083import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.SplitRegionResponse; -084import org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos; -085import org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.TableSchema; -086import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.AddColumnRequest; -087import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.AddColumnResponse; -088import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.AssignRegionRequest; -089import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.AssignRegionResponse; -090import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.BalanceRequest; -091import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.BalanceResponse; -092import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.CreateNamespaceRequest; -093import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.CreateNamespaceResponse; -094import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.DeleteNamespaceRequest; -095import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.DeleteNamespaceResponse; -096import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.DeleteSnapshotRequest; -097import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.DeleteSnapshotResponse; -098import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.DisableTableRequest; -099import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.DisableTableResponse; -100import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.EnableTableRequest; -101import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.EnableTableResponse; -102import
[35/51] [partial] hbase-site git commit: Published site at 82d554e3783372cc6b05489452c815b57c06f6cd.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/31df4674/devapidocs/org/apache/hadoop/hbase/ipc/RpcServer.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/ipc/RpcServer.html b/devapidocs/org/apache/hadoop/hbase/ipc/RpcServer.html index 7e29d55..737b9b3 100644 --- a/devapidocs/org/apache/hadoop/hbase/ipc/RpcServer.html +++ b/devapidocs/org/apache/hadoop/hbase/ipc/RpcServer.html @@ -18,7 +18,7 @@ catch(err) { } //--> -var methods = {"i0":10,"i1":9,"i2":10,"i3":10,"i4":10,"i5":10,"i6":9,"i7":10,"i8":10,"i9":9,"i10":6,"i11":9,"i12":9,"i13":9,"i14":9,"i15":10,"i16":10,"i17":9,"i18":9,"i19":9,"i20":9,"i21":10,"i22":9,"i23":10,"i24":10,"i25":10,"i26":10,"i27":10,"i28":10,"i29":10}; +var methods = {"i0":10,"i1":9,"i2":10,"i3":10,"i4":9,"i5":10,"i6":10,"i7":10,"i8":9,"i9":10,"i10":10,"i11":9,"i12":6,"i13":9,"i14":9,"i15":9,"i16":9,"i17":10,"i18":10,"i19":9,"i20":9,"i21":9,"i22":9,"i23":10,"i24":9,"i25":10,"i26":10,"i27":10,"i28":10,"i29":10,"i30":10,"i31":10,"i32":10}; var tabs = {65535:["t0","All Methods"],1:["t1","Static Methods"],2:["t2","Instance Methods"],4:["t3","Abstract Methods"],8:["t4","Concrete Methods"]}; var altColor = "altColor"; var rowColor = "rowColor"; @@ -113,13 +113,13 @@ var activeTableTab = "activeTableTab"; Direct Known Subclasses: -SimpleRpcServer +NettyRpcServer, SimpleRpcServer @InterfaceAudience.LimitedPrivate(value={"Coprocesssor","Phoenix"}) @InterfaceStability.Evolving -public abstract class RpcServer +public abstract class RpcServer 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 RpcServerInterface, ConfigurationObserver An RPC server that hosts protobuf described Services. @@ -335,74 +335,81 @@ implements +protected static int +NIO_BUFFER_LIMIT +When the read or write buffer size is larger than this limit, i/o will be + done in chunks of this size. + + + protected static RequestTooBigException REQUEST_TOO_BIG_EXCEPTION - + protected ByteBufferPool reservoir - + private RSRpcServices rsRpcServices Used to get details for scan with a scanner_id TODO try to figure out a better way and remove reference from regionserver package later. - + (package private) boolean running This flag is used to indicate to sub threads when they should go down. - + protected RpcScheduler scheduler - + protected org.apache.hadoop.security.token.SecretManagerorg.apache.hadoop.security.token.TokenIdentifier secretManager - + protected Server server - + protected http://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true; title="class or interface in java.util">ListRpcServer.BlockingServiceAndInterface services - + (package private) boolean started This flag is set to true after all threads are up and 'running' and the server is then opened for business by the call to RpcServerInterface.start(). - + protected boolean tcpKeepAlive - + protected boolean tcpNoDelay - + protected UserProvider userProvider - + protected static http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String WARN_RESPONSE_SIZE - + protected static http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String WARN_RESPONSE_TIME - + protected int warnResponseSize - + protected int warnResponseTime @@ -475,104 +482,120 @@ implements +private static int +channelIO(http://docs.oracle.com/javase/8/docs/api/java/nio/channels/ReadableByteChannel.html?is-external=true; title="class or interface in java.nio.channels">ReadableByteChannelreadCh, + http://docs.oracle.com/javase/8/docs/api/java/nio/channels/WritableByteChannel.html?is-external=true; title="class or interface in java.nio.channels">WritableByteChannelwriteCh, + http://docs.oracle.com/javase/8/docs/api/java/nio/ByteBuffer.html?is-external=true; title="class or interface in java.nio">ByteBufferbuf) +Helper for channelRead(java.nio.channels.ReadableByteChannel, java.nio.ByteBuffer) + and #channelWrite(GatheringByteChannel, BufferChain). + + + +protected int +channelRead(http://docs.oracle.com/javase/8/docs/api/java/nio/channels/ReadableByteChannel.html?is-external=true; title="class or interface in java.nio.channels">ReadableByteChannelchannel, + http://docs.oracle.com/javase/8/docs/api/java/nio/ByteBuffer.html?is-external=true; title="class or interface in java.nio">ByteBufferbuffer) +This is a wrapper around http://docs.oracle.com/javase/8/docs/api/java/nio/channels/ReadableByteChannel.html?is-external=true#read-java.nio.ByteBuffer-; title="class or interface in java.nio.channels">ReadableByteChannel.read(java.nio.ByteBuffer). + + + protected AuthenticationTokenSecretManager createSecretManager() -
[37/51] [partial] hbase-site git commit: Published site at 82d554e3783372cc6b05489452c815b57c06f6cd.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/31df4674/devapidocs/org/apache/hadoop/hbase/ipc/RpcServer.BlockingServiceAndInterface.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/ipc/RpcServer.BlockingServiceAndInterface.html b/devapidocs/org/apache/hadoop/hbase/ipc/RpcServer.BlockingServiceAndInterface.html index 2117446..741a5c4 100644 --- a/devapidocs/org/apache/hadoop/hbase/ipc/RpcServer.BlockingServiceAndInterface.html +++ b/devapidocs/org/apache/hadoop/hbase/ipc/RpcServer.BlockingServiceAndInterface.html @@ -113,7 +113,7 @@ var activeTableTab = "activeTableTab"; -public static class RpcServer.BlockingServiceAndInterface +public static class RpcServer.BlockingServiceAndInterface extends http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true; title="class or interface in java.lang">Object Datastructure for passing a BlockingService and its associated class of protobuf service interface. For example, a server that fielded what is defined @@ -214,7 +214,7 @@ extends http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? service -private finalorg.apache.hadoop.hbase.shaded.com.google.protobuf.BlockingService service +private finalorg.apache.hadoop.hbase.shaded.com.google.protobuf.BlockingService service @@ -223,7 +223,7 @@ extends http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? serviceInterface -private finalhttp://docs.oracle.com/javase/8/docs/api/java/lang/Class.html?is-external=true; title="class or interface in java.lang">Class? serviceInterface +private finalhttp://docs.oracle.com/javase/8/docs/api/java/lang/Class.html?is-external=true; title="class or interface in java.lang">Class? serviceInterface @@ -240,7 +240,7 @@ extends http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? BlockingServiceAndInterface -publicBlockingServiceAndInterface(org.apache.hadoop.hbase.shaded.com.google.protobuf.BlockingServiceservice, +publicBlockingServiceAndInterface(org.apache.hadoop.hbase.shaded.com.google.protobuf.BlockingServiceservice, http://docs.oracle.com/javase/8/docs/api/java/lang/Class.html?is-external=true; title="class or interface in java.lang">Class?serviceInterface) @@ -258,7 +258,7 @@ extends http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? getServiceInterface -publichttp://docs.oracle.com/javase/8/docs/api/java/lang/Class.html?is-external=true; title="class or interface in java.lang">Class?getServiceInterface() +publichttp://docs.oracle.com/javase/8/docs/api/java/lang/Class.html?is-external=true; title="class or interface in java.lang">Class?getServiceInterface() @@ -267,7 +267,7 @@ extends http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? getBlockingService -publicorg.apache.hadoop.hbase.shaded.com.google.protobuf.BlockingServicegetBlockingService() +publicorg.apache.hadoop.hbase.shaded.com.google.protobuf.BlockingServicegetBlockingService() http://git-wip-us.apache.org/repos/asf/hbase-site/blob/31df4674/devapidocs/org/apache/hadoop/hbase/ipc/RpcServer.ByteBuffByteInput.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/ipc/RpcServer.ByteBuffByteInput.html b/devapidocs/org/apache/hadoop/hbase/ipc/RpcServer.ByteBuffByteInput.html index 481651f..1692c30 100644 --- a/devapidocs/org/apache/hadoop/hbase/ipc/RpcServer.ByteBuffByteInput.html +++ b/devapidocs/org/apache/hadoop/hbase/ipc/RpcServer.ByteBuffByteInput.html @@ -118,7 +118,7 @@ var activeTableTab = "activeTableTab"; -protected static class RpcServer.ByteBuffByteInput +protected static class RpcServer.ByteBuffByteInput extends org.apache.hadoop.hbase.shaded.com.google.protobuf.ByteInput @@ -249,7 +249,7 @@ extends org.apache.hadoop.hbase.shaded.com.google.protobuf.ByteInput buf -privateByteBuff buf +privateByteBuff buf @@ -258,7 +258,7 @@ extends org.apache.hadoop.hbase.shaded.com.google.protobuf.ByteInput offset -privateint offset +privateint offset @@ -267,7 +267,7 @@ extends org.apache.hadoop.hbase.shaded.com.google.protobuf.ByteInput length -privateint length +privateint length @@ -284,7 +284,7 @@ extends org.apache.hadoop.hbase.shaded.com.google.protobuf.ByteInput ByteBuffByteInput -ByteBuffByteInput(ByteBuffbuf, +ByteBuffByteInput(ByteBuffbuf, intoffset, intlength) @@ -303,7 +303,7 @@ extends org.apache.hadoop.hbase.shaded.com.google.protobuf.ByteInput read -publicbyteread(intoffset) +publicbyteread(intoffset) Description copied from class:org.apache.hadoop.hbase.shaded.com.google.protobuf.ByteInput Reads a single byte from the given offset. @@ -322,7 +322,7 @@ extends org.apache.hadoop.hbase.shaded.com.google.protobuf.ByteInput getAbsoluteOffset
[26/51] [partial] hbase-site git commit: Published site at 82d554e3783372cc6b05489452c815b57c06f6cd.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/31df4674/devapidocs/org/apache/hadoop/hbase/regionserver/wal/package-tree.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/regionserver/wal/package-tree.html b/devapidocs/org/apache/hadoop/hbase/regionserver/wal/package-tree.html index 320500a..326107e 100644 --- a/devapidocs/org/apache/hadoop/hbase/regionserver/wal/package-tree.html +++ b/devapidocs/org/apache/hadoop/hbase/regionserver/wal/package-tree.html @@ -248,8 +248,8 @@ java.lang.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.wal.ProtobufLogReader.WALHdrResult org.apache.hadoop.hbase.regionserver.wal.RingBufferTruck.Type +org.apache.hadoop.hbase.regionserver.wal.ProtobufLogReader.WALHdrResult http://git-wip-us.apache.org/repos/asf/hbase-site/blob/31df4674/devapidocs/org/apache/hadoop/hbase/security/access/package-tree.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/security/access/package-tree.html b/devapidocs/org/apache/hadoop/hbase/security/access/package-tree.html index 8387ff7..042bbd4 100644 --- a/devapidocs/org/apache/hadoop/hbase/security/access/package-tree.html +++ b/devapidocs/org/apache/hadoop/hbase/security/access/package-tree.html @@ -135,8 +135,8 @@ java.lang.http://docs.oracle.com/javase/8/docs/api/java/lang/Enum.html?is-external=true; title="class or interface in java.lang">EnumE (implements java.lang.http://docs.oracle.com/javase/8/docs/api/java/lang/Comparable.html?is-external=true; title="class or interface in java.lang">ComparableT, java.io.http://docs.oracle.com/javase/8/docs/api/java/io/Serializable.html?is-external=true; title="class or interface in java.io">Serializable) -org.apache.hadoop.hbase.security.access.AccessController.OpType org.apache.hadoop.hbase.security.access.Permission.Action +org.apache.hadoop.hbase.security.access.AccessController.OpType org.apache.hadoop.hbase.security.access.AccessControlFilter.Strategy http://git-wip-us.apache.org/repos/asf/hbase-site/blob/31df4674/devapidocs/org/apache/hadoop/hbase/security/class-use/SaslStatus.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/security/class-use/SaslStatus.html b/devapidocs/org/apache/hadoop/hbase/security/class-use/SaslStatus.html index 93eb960..37e5532 100644 --- a/devapidocs/org/apache/hadoop/hbase/security/class-use/SaslStatus.html +++ b/devapidocs/org/apache/hadoop/hbase/security/class-use/SaslStatus.html @@ -109,8 +109,8 @@ -private void -SimpleRpcServer.Connection.doRawSaslReply(SaslStatusstatus, +protected void +RpcServer.Connection.doRawSaslReply(SaslStatusstatus, org.apache.hadoop.io.Writablerv, http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">StringerrorClass, http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">Stringerror) http://git-wip-us.apache.org/repos/asf/hbase-site/blob/31df4674/devapidocs/org/apache/hadoop/hbase/security/package-tree.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/security/package-tree.html b/devapidocs/org/apache/hadoop/hbase/security/package-tree.html index 73b9c9d..e40986a 100644 --- a/devapidocs/org/apache/hadoop/hbase/security/package-tree.html +++ b/devapidocs/org/apache/hadoop/hbase/security/package-tree.html @@ -191,9 +191,9 @@ java.lang.http://docs.oracle.com/javase/8/docs/api/java/lang/Enum.html?is-external=true; title="class or interface in java.lang">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.security.SaslStatus -org.apache.hadoop.hbase.security.AuthMethod org.apache.hadoop.hbase.security.SaslUtil.QualityOfProtection +org.apache.hadoop.hbase.security.AuthMethod +org.apache.hadoop.hbase.security.SaslStatus http://git-wip-us.apache.org/repos/asf/hbase-site/blob/31df4674/devapidocs/org/apache/hadoop/hbase/thrift/package-tree.html -- diff --git
[32/51] [partial] hbase-site git commit: Published site at 82d554e3783372cc6b05489452c815b57c06f6cd.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/31df4674/devapidocs/org/apache/hadoop/hbase/ipc/SimpleRpcServer.Listener.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/ipc/SimpleRpcServer.Listener.html b/devapidocs/org/apache/hadoop/hbase/ipc/SimpleRpcServer.Listener.html index 5996aef..85f0adc 100644 --- a/devapidocs/org/apache/hadoop/hbase/ipc/SimpleRpcServer.Listener.html +++ b/devapidocs/org/apache/hadoop/hbase/ipc/SimpleRpcServer.Listener.html @@ -122,7 +122,7 @@ var activeTableTab = "activeTableTab"; -private class SimpleRpcServer.Listener +private class SimpleRpcServer.Listener extends http://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html?is-external=true; title="class or interface in java.lang">Thread Listens on the socket. Creates jobs for the handler threads @@ -296,7 +296,7 @@ extends http://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html? acceptChannel -privatehttp://docs.oracle.com/javase/8/docs/api/java/nio/channels/ServerSocketChannel.html?is-external=true; title="class or interface in java.nio.channels">ServerSocketChannel acceptChannel +privatehttp://docs.oracle.com/javase/8/docs/api/java/nio/channels/ServerSocketChannel.html?is-external=true; title="class or interface in java.nio.channels">ServerSocketChannel acceptChannel @@ -305,7 +305,7 @@ extends http://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html? selector -privatehttp://docs.oracle.com/javase/8/docs/api/java/nio/channels/Selector.html?is-external=true; title="class or interface in java.nio.channels">Selector selector +privatehttp://docs.oracle.com/javase/8/docs/api/java/nio/channels/Selector.html?is-external=true; title="class or interface in java.nio.channels">Selector selector @@ -314,7 +314,7 @@ extends http://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html? readers -privateSimpleRpcServer.Listener.Reader[] readers +privateSimpleRpcServer.Listener.Reader[] readers @@ -323,7 +323,7 @@ extends http://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html? currentReader -privateint currentReader +privateint currentReader @@ -332,7 +332,7 @@ extends http://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html? readerPendingConnectionQueueLength -private finalint readerPendingConnectionQueueLength +private finalint readerPendingConnectionQueueLength @@ -341,7 +341,7 @@ extends http://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html? readPool -privatehttp://docs.oracle.com/javase/8/docs/api/java/util/concurrent/ExecutorService.html?is-external=true; title="class or interface in java.util.concurrent">ExecutorService readPool +privatehttp://docs.oracle.com/javase/8/docs/api/java/util/concurrent/ExecutorService.html?is-external=true; title="class or interface in java.util.concurrent">ExecutorService readPool @@ -358,7 +358,7 @@ extends http://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html? Listener -publicListener(http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">Stringname) +publicListener(http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">Stringname) throws http://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true; title="class or interface in java.io">IOException Throws: @@ -380,7 +380,7 @@ extends http://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html? run -publicvoidrun() +publicvoidrun() Specified by: http://docs.oracle.com/javase/8/docs/api/java/lang/Runnable.html?is-external=true#run--; title="class or interface in java.lang">runin interfacehttp://docs.oracle.com/javase/8/docs/api/java/lang/Runnable.html?is-external=true; title="class or interface in java.lang">Runnable @@ -395,7 +395,7 @@ extends http://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html? closeCurrentConnection -privatevoidcloseCurrentConnection(http://docs.oracle.com/javase/8/docs/api/java/nio/channels/SelectionKey.html?is-external=true; title="class or interface in java.nio.channels">SelectionKeykey, +privatevoidcloseCurrentConnection(http://docs.oracle.com/javase/8/docs/api/java/nio/channels/SelectionKey.html?is-external=true; title="class or interface in java.nio.channels">SelectionKeykey, http://docs.oracle.com/javase/8/docs/api/java/lang/Throwable.html?is-external=true; title="class or interface in java.lang">Throwablee) @@ -405,7 +405,7 @@ extends http://docs.oracle.com/javase/8/docs/api/java/lang/Thread.html? getAddress -http://docs.oracle.com/javase/8/docs/api/java/net/InetSocketAddress.html?is-external=true; title="class or interface in java.net">InetSocketAddressgetAddress() +http://docs.oracle.com/javase/8/docs/api/java/net/InetSocketAddress.html?is-external=true;
[08/51] [partial] hbase-site git commit: Published site at 82d554e3783372cc6b05489452c815b57c06f6cd.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/31df4674/devapidocs/src-html/org/apache/hadoop/hbase/client/AsyncHBaseAdmin.ProcedureBiConsumer.html -- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/client/AsyncHBaseAdmin.ProcedureBiConsumer.html b/devapidocs/src-html/org/apache/hadoop/hbase/client/AsyncHBaseAdmin.ProcedureBiConsumer.html index f3f7a46..8750fa2 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/client/AsyncHBaseAdmin.ProcedureBiConsumer.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/client/AsyncHBaseAdmin.ProcedureBiConsumer.html @@ -56,2015 +56,2125 @@ 048import org.apache.hadoop.hbase.MetaTableAccessor; 049import org.apache.hadoop.hbase.MetaTableAccessor.QueryType; 050import org.apache.hadoop.hbase.NotServingRegionException; -051import org.apache.hadoop.hbase.RegionLocations; -052import org.apache.hadoop.hbase.ServerName; -053import org.apache.hadoop.hbase.NamespaceDescriptor; -054import org.apache.hadoop.hbase.HConstants; -055import org.apache.hadoop.hbase.TableExistsException; -056import org.apache.hadoop.hbase.TableName; -057import org.apache.hadoop.hbase.AsyncMetaTableAccessor; -058import org.apache.hadoop.hbase.TableNotDisabledException; -059import org.apache.hadoop.hbase.TableNotFoundException; -060import org.apache.hadoop.hbase.UnknownRegionException; -061import org.apache.hadoop.hbase.classification.InterfaceAudience; -062import org.apache.hadoop.hbase.classification.InterfaceStability; -063import org.apache.hadoop.hbase.client.AsyncRpcRetryingCallerFactory.AdminRequestCallerBuilder; -064import org.apache.hadoop.hbase.client.AsyncRpcRetryingCallerFactory.MasterRequestCallerBuilder; -065import org.apache.hadoop.hbase.client.Scan.ReadType; -066import org.apache.hadoop.hbase.client.replication.ReplicationSerDeHelper; -067import org.apache.hadoop.hbase.client.replication.TableCFs; -068import org.apache.hadoop.hbase.exceptions.DeserializationException; -069import org.apache.hadoop.hbase.ipc.HBaseRpcController; -070import org.apache.hadoop.hbase.quotas.QuotaFilter; -071import org.apache.hadoop.hbase.quotas.QuotaSettings; -072import org.apache.hadoop.hbase.quotas.QuotaTableUtil; -073import org.apache.hadoop.hbase.replication.ReplicationException; -074import org.apache.hadoop.hbase.replication.ReplicationPeerConfig; -075import org.apache.hadoop.hbase.replication.ReplicationPeerDescription; -076import org.apache.hadoop.hbase.shaded.com.google.protobuf.RpcCallback; -077import org.apache.hadoop.hbase.shaded.protobuf.ProtobufUtil; -078import org.apache.hadoop.hbase.shaded.protobuf.RequestConverter; -079import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.AdminService; -080import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CloseRegionRequest; -081import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CloseRegionResponse; -082import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.SplitRegionRequest; -083import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.SplitRegionResponse; -084import org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos; -085import org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.TableSchema; -086import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.AddColumnRequest; -087import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.AddColumnResponse; -088import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.AssignRegionRequest; -089import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.AssignRegionResponse; -090import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.BalanceRequest; -091import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.BalanceResponse; -092import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.CreateNamespaceRequest; -093import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.CreateNamespaceResponse; -094import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.DeleteNamespaceRequest; -095import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.DeleteNamespaceResponse; -096import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.DeleteSnapshotRequest; -097import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.DeleteSnapshotResponse; -098import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.DisableTableRequest; -099import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.DisableTableResponse; -100import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.EnableTableRequest; -101import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.EnableTableResponse; -102import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.DeleteColumnRequest; -103import
[14/51] [partial] hbase-site git commit: Published site at 82d554e3783372cc6b05489452c815b57c06f6cd.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/31df4674/devapidocs/src-html/org/apache/hadoop/hbase/client/AsyncHBaseAdmin.EnableTableProcedureBiConsumer.html -- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/client/AsyncHBaseAdmin.EnableTableProcedureBiConsumer.html b/devapidocs/src-html/org/apache/hadoop/hbase/client/AsyncHBaseAdmin.EnableTableProcedureBiConsumer.html index f3f7a46..8750fa2 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/client/AsyncHBaseAdmin.EnableTableProcedureBiConsumer.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/client/AsyncHBaseAdmin.EnableTableProcedureBiConsumer.html @@ -56,2015 +56,2125 @@ 048import org.apache.hadoop.hbase.MetaTableAccessor; 049import org.apache.hadoop.hbase.MetaTableAccessor.QueryType; 050import org.apache.hadoop.hbase.NotServingRegionException; -051import org.apache.hadoop.hbase.RegionLocations; -052import org.apache.hadoop.hbase.ServerName; -053import org.apache.hadoop.hbase.NamespaceDescriptor; -054import org.apache.hadoop.hbase.HConstants; -055import org.apache.hadoop.hbase.TableExistsException; -056import org.apache.hadoop.hbase.TableName; -057import org.apache.hadoop.hbase.AsyncMetaTableAccessor; -058import org.apache.hadoop.hbase.TableNotDisabledException; -059import org.apache.hadoop.hbase.TableNotFoundException; -060import org.apache.hadoop.hbase.UnknownRegionException; -061import org.apache.hadoop.hbase.classification.InterfaceAudience; -062import org.apache.hadoop.hbase.classification.InterfaceStability; -063import org.apache.hadoop.hbase.client.AsyncRpcRetryingCallerFactory.AdminRequestCallerBuilder; -064import org.apache.hadoop.hbase.client.AsyncRpcRetryingCallerFactory.MasterRequestCallerBuilder; -065import org.apache.hadoop.hbase.client.Scan.ReadType; -066import org.apache.hadoop.hbase.client.replication.ReplicationSerDeHelper; -067import org.apache.hadoop.hbase.client.replication.TableCFs; -068import org.apache.hadoop.hbase.exceptions.DeserializationException; -069import org.apache.hadoop.hbase.ipc.HBaseRpcController; -070import org.apache.hadoop.hbase.quotas.QuotaFilter; -071import org.apache.hadoop.hbase.quotas.QuotaSettings; -072import org.apache.hadoop.hbase.quotas.QuotaTableUtil; -073import org.apache.hadoop.hbase.replication.ReplicationException; -074import org.apache.hadoop.hbase.replication.ReplicationPeerConfig; -075import org.apache.hadoop.hbase.replication.ReplicationPeerDescription; -076import org.apache.hadoop.hbase.shaded.com.google.protobuf.RpcCallback; -077import org.apache.hadoop.hbase.shaded.protobuf.ProtobufUtil; -078import org.apache.hadoop.hbase.shaded.protobuf.RequestConverter; -079import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.AdminService; -080import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CloseRegionRequest; -081import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CloseRegionResponse; -082import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.SplitRegionRequest; -083import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.SplitRegionResponse; -084import org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos; -085import org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.TableSchema; -086import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.AddColumnRequest; -087import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.AddColumnResponse; -088import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.AssignRegionRequest; -089import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.AssignRegionResponse; -090import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.BalanceRequest; -091import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.BalanceResponse; -092import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.CreateNamespaceRequest; -093import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.CreateNamespaceResponse; -094import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.DeleteNamespaceRequest; -095import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.DeleteNamespaceResponse; -096import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.DeleteSnapshotRequest; -097import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.DeleteSnapshotResponse; -098import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.DisableTableRequest; -099import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.DisableTableResponse; -100import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.EnableTableRequest; -101import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.EnableTableResponse; -102import
[31/51] [partial] hbase-site git commit: Published site at 82d554e3783372cc6b05489452c815b57c06f6cd.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/31df4674/devapidocs/org/apache/hadoop/hbase/ipc/class-use/NettyRpcServer.Call.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/ipc/class-use/NettyRpcServer.Call.html b/devapidocs/org/apache/hadoop/hbase/ipc/class-use/NettyRpcServer.Call.html new file mode 100644 index 000..711add3 --- /dev/null +++ b/devapidocs/org/apache/hadoop/hbase/ipc/class-use/NettyRpcServer.Call.html @@ -0,0 +1,178 @@ +http://www.w3.org/TR/html4/loose.dtd;> + + + + + +Uses of Class org.apache.hadoop.hbase.ipc.NettyRpcServer.Call (Apache HBase 2.0.0-SNAPSHOT API) + + + + + + + +JavaScript is disabled on your browser. + + + + + +Skip navigation links + + + + +Overview +Package +Class +Use +Tree +Deprecated +Index +Help + + + + +Prev +Next + + +Frames +NoFrames + + +AllClasses + + + + + + + + + + +Uses of Classorg.apache.hadoop.hbase.ipc.NettyRpcServer.Call + + + + + +Packages that use NettyRpcServer.Call + +Package +Description + + + +org.apache.hadoop.hbase.ipc + +Tools to help define network clients and servers. + + + + + + + + + + +Uses of NettyRpcServer.Call in org.apache.hadoop.hbase.ipc + +Fields in org.apache.hadoop.hbase.ipc declared as NettyRpcServer.Call + +Modifier and Type +Field and Description + + + +private NettyRpcServer.Call +NettyRpcServer.CallWriteListener.call + + + + +Constructors in org.apache.hadoop.hbase.ipc with parameters of type NettyRpcServer.Call + +Constructor and Description + + + +CallWriteListener(NettyRpcServer.Callcall) + + + + + + + + + + + + +Skip navigation links + + + + +Overview +Package +Class +Use +Tree +Deprecated +Index +Help + + + + +Prev +Next + + +Frames +NoFrames + + +AllClasses + + + + + + + + + +Copyright 20072017 https://www.apache.org/;>The Apache Software Foundation. All rights reserved. + + http://git-wip-us.apache.org/repos/asf/hbase-site/blob/31df4674/devapidocs/org/apache/hadoop/hbase/ipc/class-use/NettyRpcServer.CallWriteListener.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/ipc/class-use/NettyRpcServer.CallWriteListener.html b/devapidocs/org/apache/hadoop/hbase/ipc/class-use/NettyRpcServer.CallWriteListener.html new file mode 100644 index 000..7a70eeb --- /dev/null +++ b/devapidocs/org/apache/hadoop/hbase/ipc/class-use/NettyRpcServer.CallWriteListener.html @@ -0,0 +1,125 @@ +http://www.w3.org/TR/html4/loose.dtd;> + + + + + +Uses of Class org.apache.hadoop.hbase.ipc.NettyRpcServer.CallWriteListener (Apache HBase 2.0.0-SNAPSHOT API) + + + + + + + +JavaScript is disabled on your browser. + + + + + +Skip navigation links + + + + +Overview +Package +Class +Use +Tree +Deprecated +Index +Help + + + + +Prev +Next + + +Frames +NoFrames + + +AllClasses + + + + + + + + + + +Uses of Classorg.apache.hadoop.hbase.ipc.NettyRpcServer.CallWriteListener + +No usage of org.apache.hadoop.hbase.ipc.NettyRpcServer.CallWriteListener + + + + +Skip navigation links + + + + +Overview +Package +Class +Use +Tree +Deprecated +Index +Help + + + + +Prev +Next + + +Frames +NoFrames + + +AllClasses + + + + + + + + + +Copyright 20072017 https://www.apache.org/;>The Apache Software Foundation. All rights reserved. + + http://git-wip-us.apache.org/repos/asf/hbase-site/blob/31df4674/devapidocs/org/apache/hadoop/hbase/ipc/class-use/NettyRpcServer.ConnectionHeaderHandler.html -- diff --git
[41/51] [partial] hbase-site git commit: Published site at 82d554e3783372cc6b05489452c815b57c06f6cd.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/31df4674/devapidocs/org/apache/hadoop/hbase/client/HBaseAdmin.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/client/HBaseAdmin.html b/devapidocs/org/apache/hadoop/hbase/client/HBaseAdmin.html index f09ea4c..87a681b 100644 --- a/devapidocs/org/apache/hadoop/hbase/client/HBaseAdmin.html +++ b/devapidocs/org/apache/hadoop/hbase/client/HBaseAdmin.html @@ -5440,7 +5440,7 @@ publicbyte[][] execProcedure -publicvoidexecProcedure(http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">Stringsignature, +publicvoidexecProcedure(http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">Stringsignature, http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">Stringinstance, http://docs.oracle.com/javase/8/docs/api/java/util/Map.html?is-external=true; title="class or interface in java.util">Maphttp://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String,http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">Stringprops) throws http://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true; title="class or interface in java.io">IOException @@ -5466,7 +5466,7 @@ publicbyte[][] isProcedureFinished -publicbooleanisProcedureFinished(http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">Stringsignature, +publicbooleanisProcedureFinished(http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">Stringsignature, http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">Stringinstance, http://docs.oracle.com/javase/8/docs/api/java/util/Map.html?is-external=true; title="class or interface in java.util">Maphttp://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">String,http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">Stringprops) throws http://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true; title="class or interface in java.io">IOException @@ -5494,7 +5494,7 @@ publicbyte[][] internalRestoreSnapshotAsync -privatehttp://docs.oracle.com/javase/8/docs/api/java/util/concurrent/Future.html?is-external=true; title="class or interface in java.util.concurrent">Futurehttp://docs.oracle.com/javase/8/docs/api/java/lang/Void.html?is-external=true; title="class or interface in java.lang">VoidinternalRestoreSnapshotAsync(http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">StringsnapshotName, +privatehttp://docs.oracle.com/javase/8/docs/api/java/util/concurrent/Future.html?is-external=true; title="class or interface in java.util.concurrent">Futurehttp://docs.oracle.com/javase/8/docs/api/java/lang/Void.html?is-external=true; title="class or interface in java.lang">VoidinternalRestoreSnapshotAsync(http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true; title="class or interface in java.lang">StringsnapshotName, TableNametableName) throws http://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true; title="class or interface in java.io">IOException, RestoreSnapshotException @@ -5518,7 +5518,7 @@ publicbyte[][] listSnapshots -publichttp://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true; title="class or interface in java.util">ListSnapshotDescriptionlistSnapshots() +publichttp://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true; title="class or interface in java.util">ListSnapshotDescriptionlistSnapshots() throws http://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true; title="class or interface in java.io">IOException Description copied from interface:Admin List completed snapshots. @@ -5538,7 +5538,7 @@ publicbyte[][] listSnapshots -publichttp://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true; title="class or interface in
[25/51] [partial] hbase-site git commit: Published site at 82d554e3783372cc6b05489452c815b57c06f6cd.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/31df4674/devapidocs/overview-tree.html -- diff --git a/devapidocs/overview-tree.html b/devapidocs/overview-tree.html index e3b746f..e6a 100644 --- a/devapidocs/overview-tree.html +++ b/devapidocs/overview-tree.html @@ -1048,6 +1048,7 @@ io.netty.handler.codec.ByteToMessageDecoder +org.apache.hadoop.hbase.ipc.NettyRpcServer.ConnectionHeaderHandler org.apache.hadoop.hbase.security.SaslChallengeDecoder @@ -1058,6 +1059,12 @@ org.apache.hadoop.hbase.ipc.NettyRpcDuplexHandler +io.netty.channel.ChannelInitializerC + +org.apache.hadoop.hbase.ipc.NettyRpcServer.Initializer + + +org.apache.hadoop.hbase.ipc.NettyRpcServer.MessageDecoder io.netty.channel.SimpleChannelInboundHandlerI org.apache.hadoop.hbase.client.ClusterStatusListener.MulticastListener.ClusterStatusHandler @@ -1086,6 +1093,7 @@ org.apache.hadoop.hbase.master.ClusterStatusPublisher.MulticastPublisher.ClusterStatusEncoder +org.apache.hadoop.hbase.ipc.NettyRpcServer.MessageEncoder org.apache.hadoop.hbase.security.SaslWrapHandler @@ -2379,6 +2387,7 @@ org.apache.hadoop.hbase.namespace.NamespaceTableAndRegionInfo org.apache.hadoop.hbase.replication.NamespaceTableCfWALEntryFilter (implements org.apache.hadoop.hbase.replication.WALCellFilter, org.apache.hadoop.hbase.replication.WALEntryFilter) org.apache.hadoop.hbase.ipc.NettyRpcClientConfigHelper +org.apache.hadoop.hbase.ipc.NettyRpcServer.CallWriteListener (implements io.netty.channel.ChannelFutureListener) org.apache.hadoop.hbase.http.NoCacheFilter (implements javax.servlet.Filter) org.apache.hadoop.hbase.regionserver.throttle.NoLimitThroughputController (implements org.apache.hadoop.hbase.regionserver.throttle.ThroughputController) org.apache.hadoop.hbase.util.NonceKey @@ -3074,17 +3083,20 @@ org.apache.hadoop.hbase.ipc.RpcServer (implements org.apache.hadoop.hbase.conf.ConfigurationObserver, org.apache.hadoop.hbase.ipc.RpcServerInterface) +org.apache.hadoop.hbase.ipc.NettyRpcServer org.apache.hadoop.hbase.ipc.SimpleRpcServer org.apache.hadoop.hbase.ipc.RpcServer.BlockingServiceAndInterface org.apache.hadoop.hbase.ipc.RpcServer.Call (implements org.apache.hadoop.hbase.ipc.RpcCall) +org.apache.hadoop.hbase.ipc.NettyRpcServer.Call org.apache.hadoop.hbase.ipc.SimpleRpcServer.Call -org.apache.hadoop.hbase.ipc.RpcServer.Connection +org.apache.hadoop.hbase.ipc.RpcServer.Connection (implements java.io.http://docs.oracle.com/javase/8/docs/api/java/io/Closeable.html?is-external=true; title="class or interface in java.io">Closeable) +org.apache.hadoop.hbase.ipc.NettyRpcServer.NettyConnection org.apache.hadoop.hbase.ipc.SimpleRpcServer.Connection http://git-wip-us.apache.org/repos/asf/hbase-site/blob/31df4674/devapidocs/src-html/org/apache/hadoop/hbase/Version.html -- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/Version.html b/devapidocs/src-html/org/apache/hadoop/hbase/Version.html index 8e47fe2..74c252f 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/Version.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/Version.html @@ -16,11 +16,11 @@ 008@InterfaceAudience.Private 009public class Version { 010 public static final String version = "2.0.0-SNAPSHOT"; -011 public static final String revision = "c8a7e80e0a87fa39a720b3da54c0bcf11520ee9f"; +011 public static final String revision = "ff998ef74fe7b8d304b2e9e5579b019c62f836db"; 012 public static final String user = "jenkins"; -013 public static final String date = "Tue May 2 14:38:55 UTC 2017"; +013 public static final String date = "Wed May 3 14:38:59 UTC 2017"; 014 public static final String url = "git://asf920.gq1.ygridcore.net/home/jenkins/jenkins-slave/workspace/hbase_generate_website/hbase"; -015 public static final String srcChecksum = "1c443c1bdcef1b0d474e1f4b16806dc1"; +015 public static final String srcChecksum = "c626e1fc5636082b9f9d9907601e524f"; 016}
[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/31df4674 Tree: http://git-wip-us.apache.org/repos/asf/hbase-site/tree/31df4674 Diff: http://git-wip-us.apache.org/repos/asf/hbase-site/diff/31df4674 Branch: refs/heads/asf-site Commit: 31df46740d0daeaa3761ea36d6ebf720797be545 Parents: f8a1367 Author: jenkinsAuthored: Wed May 3 14:58:37 2017 + Committer: jenkins Committed: Wed May 3 14:58:37 2017 + -- acid-semantics.html | 4 +- apache_hbase_reference_guide.pdf| 4 +- apache_hbase_reference_guide.pdfmarks | 4 +- .../hbase/filter/ColumnPaginationFilter.html| 2 +- bulk-loads.html | 4 +- checkstyle-aggregate.html | 15346 - checkstyle.rss |30 +- 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 |15 +- devapidocs/index-all.html | 223 +- .../hadoop/hbase/backup/package-tree.html | 4 +- .../org/apache/hadoop/hbase/class-use/Cell.html | 167 +- .../hadoop/hbase/class-use/CellScanner.html | 131 +- .../apache/hadoop/hbase/class-use/Server.html |10 +- .../class-use/InterfaceStability.Evolving.html |25 +- .../hbase/classification/package-tree.html | 4 +- .../apache/hadoop/hbase/client/AsyncAdmin.html | 474 +- ...dmin.AddColumnFamilyProcedureBiConsumer.html | 6 +- .../client/AsyncHBaseAdmin.AdminRpcCall.html| 4 +- .../hbase/client/AsyncHBaseAdmin.Converter.html | 4 +- ...dmin.CreateNamespaceProcedureBiConsumer.html | 6 +- ...aseAdmin.CreateTableProcedureBiConsumer.html | 6 +- ...n.DeleteColumnFamilyProcedureBiConsumer.html | 6 +- ...dmin.DeleteNamespaceProcedureBiConsumer.html | 6 +- ...aseAdmin.DeleteTableProcedureBiConsumer.html | 8 +- ...seAdmin.DisableTableProcedureBiConsumer.html | 6 +- ...aseAdmin.EnableTableProcedureBiConsumer.html | 6 +- .../client/AsyncHBaseAdmin.MasterRpcCall.html | 4 +- ...min.MergeTableRegionProcedureBiConsumer.html | 6 +- ...n.ModifyColumnFamilyProcedureBiConsumer.html | 6 +- ...dmin.ModifyNamespaceProcedureBiConsumer.html | 6 +- ...HBaseAdmin.NamespaceProcedureBiConsumer.html |14 +- .../AsyncHBaseAdmin.ProcedureBiConsumer.html|12 +- .../client/AsyncHBaseAdmin.TableOperator.html | 4 +- ...syncHBaseAdmin.TableProcedureBiConsumer.html |14 +- ...eAdmin.TruncateTableProcedureBiConsumer.html | 6 +- .../hadoop/hbase/client/AsyncHBaseAdmin.html| 587 +- .../client/HBaseAdmin.NamespaceFuture.html |12 +- ...in.ProcedureFuture.WaitForStateCallable.html | 8 +- .../client/HBaseAdmin.ProcedureFuture.html |48 +- .../client/HBaseAdmin.ReplicationState.html |12 +- .../HBaseAdmin.RestoreSnapshotFuture.html | 8 +- ...n.TableFuture.TableWaitForStateCallable.html | 8 +- .../hbase/client/HBaseAdmin.TableFuture.html|30 +- .../client/HBaseAdmin.ThrowableAbortable.html | 8 +- .../apache/hadoop/hbase/client/HBaseAdmin.html | 122 +- .../hadoop/hbase/client/package-tree.html |26 +- .../hbase/conf/ConfigurationObserver.html | 2 +- .../conf/class-use/ConfigurationObserver.html |10 +- .../hadoop/hbase/executor/package-tree.html | 2 +- .../hadoop/hbase/filter/package-tree.html | 8 +- .../hadoop/hbase/io/hfile/package-tree.html | 8 +- .../apache/hadoop/hbase/ipc/BufferChain.html|57 +- .../hadoop/hbase/ipc/NettyRpcDuplexHandler.html | 4 +- .../hadoop/hbase/ipc/NettyRpcServer.Call.html | 395 + .../ipc/NettyRpcServer.CallWriteListener.html | 331 + .../NettyRpcServer.ConnectionHeaderHandler.html | 399 + .../hbase/ipc/NettyRpcServer.Initializer.html | 381 + .../ipc/NettyRpcServer.MessageDecoder.html | 455 + .../ipc/NettyRpcServer.MessageEncoder.html | 338 + .../ipc/NettyRpcServer.NettyConnection.html | 507 + .../apache/hadoop/hbase/ipc/NettyRpcServer.html | 605 + .../hadoop/hbase/ipc/PriorityFunction.html | 4 +- .../org/apache/hadoop/hbase/ipc/RpcCall.html| 2 +- .../apache/hadoop/hbase/ipc/RpcCallContext.html | 2 +-
[09/51] [partial] hbase-site git commit: Published site at 82d554e3783372cc6b05489452c815b57c06f6cd.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/31df4674/devapidocs/src-html/org/apache/hadoop/hbase/client/AsyncHBaseAdmin.NamespaceProcedureBiConsumer.html -- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/client/AsyncHBaseAdmin.NamespaceProcedureBiConsumer.html b/devapidocs/src-html/org/apache/hadoop/hbase/client/AsyncHBaseAdmin.NamespaceProcedureBiConsumer.html index f3f7a46..8750fa2 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/client/AsyncHBaseAdmin.NamespaceProcedureBiConsumer.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/client/AsyncHBaseAdmin.NamespaceProcedureBiConsumer.html @@ -56,2015 +56,2125 @@ 048import org.apache.hadoop.hbase.MetaTableAccessor; 049import org.apache.hadoop.hbase.MetaTableAccessor.QueryType; 050import org.apache.hadoop.hbase.NotServingRegionException; -051import org.apache.hadoop.hbase.RegionLocations; -052import org.apache.hadoop.hbase.ServerName; -053import org.apache.hadoop.hbase.NamespaceDescriptor; -054import org.apache.hadoop.hbase.HConstants; -055import org.apache.hadoop.hbase.TableExistsException; -056import org.apache.hadoop.hbase.TableName; -057import org.apache.hadoop.hbase.AsyncMetaTableAccessor; -058import org.apache.hadoop.hbase.TableNotDisabledException; -059import org.apache.hadoop.hbase.TableNotFoundException; -060import org.apache.hadoop.hbase.UnknownRegionException; -061import org.apache.hadoop.hbase.classification.InterfaceAudience; -062import org.apache.hadoop.hbase.classification.InterfaceStability; -063import org.apache.hadoop.hbase.client.AsyncRpcRetryingCallerFactory.AdminRequestCallerBuilder; -064import org.apache.hadoop.hbase.client.AsyncRpcRetryingCallerFactory.MasterRequestCallerBuilder; -065import org.apache.hadoop.hbase.client.Scan.ReadType; -066import org.apache.hadoop.hbase.client.replication.ReplicationSerDeHelper; -067import org.apache.hadoop.hbase.client.replication.TableCFs; -068import org.apache.hadoop.hbase.exceptions.DeserializationException; -069import org.apache.hadoop.hbase.ipc.HBaseRpcController; -070import org.apache.hadoop.hbase.quotas.QuotaFilter; -071import org.apache.hadoop.hbase.quotas.QuotaSettings; -072import org.apache.hadoop.hbase.quotas.QuotaTableUtil; -073import org.apache.hadoop.hbase.replication.ReplicationException; -074import org.apache.hadoop.hbase.replication.ReplicationPeerConfig; -075import org.apache.hadoop.hbase.replication.ReplicationPeerDescription; -076import org.apache.hadoop.hbase.shaded.com.google.protobuf.RpcCallback; -077import org.apache.hadoop.hbase.shaded.protobuf.ProtobufUtil; -078import org.apache.hadoop.hbase.shaded.protobuf.RequestConverter; -079import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.AdminService; -080import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CloseRegionRequest; -081import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.CloseRegionResponse; -082import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.SplitRegionRequest; -083import org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.SplitRegionResponse; -084import org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos; -085import org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.TableSchema; -086import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.AddColumnRequest; -087import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.AddColumnResponse; -088import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.AssignRegionRequest; -089import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.AssignRegionResponse; -090import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.BalanceRequest; -091import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.BalanceResponse; -092import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.CreateNamespaceRequest; -093import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.CreateNamespaceResponse; -094import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.DeleteNamespaceRequest; -095import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.DeleteNamespaceResponse; -096import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.DeleteSnapshotRequest; -097import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.DeleteSnapshotResponse; -098import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.DisableTableRequest; -099import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.DisableTableResponse; -100import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.EnableTableRequest; -101import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.EnableTableResponse; -102import
[46/51] [partial] hbase-site git commit: Published site at 82d554e3783372cc6b05489452c815b57c06f6cd.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/31df4674/devapidocs/org/apache/hadoop/hbase/class-use/CellScanner.html -- diff --git a/devapidocs/org/apache/hadoop/hbase/class-use/CellScanner.html b/devapidocs/org/apache/hadoop/hbase/class-use/CellScanner.html index e2c48aa..20110fb 100644 --- a/devapidocs/org/apache/hadoop/hbase/class-use/CellScanner.html +++ b/devapidocs/org/apache/hadoop/hbase/class-use/CellScanner.html @@ -513,6 +513,15 @@ Pairorg.apache.hadoop.hbase.shaded.com.google.protobuf.Message,CellScanner +NettyRpcServer.call(org.apache.hadoop.hbase.shaded.com.google.protobuf.BlockingServiceservice, + org.apache.hadoop.hbase.shaded.com.google.protobuf.Descriptors.MethodDescriptormd, +org.apache.hadoop.hbase.shaded.com.google.protobuf.Messageparam, +CellScannercellScanner, +longreceiveTime, +MonitoredRPCHandlerstatus) + + +Pairorg.apache.hadoop.hbase.shaded.com.google.protobuf.Message,CellScanner RpcServerInterface.call(org.apache.hadoop.hbase.shaded.com.google.protobuf.BlockingServiceservice, org.apache.hadoop.hbase.shaded.com.google.protobuf.Descriptors.MethodDescriptormd, org.apache.hadoop.hbase.shaded.com.google.protobuf.Messageparam, @@ -526,7 +535,7 @@ - + Pairorg.apache.hadoop.hbase.shaded.com.google.protobuf.Message,CellScanner SimpleRpcServer.call(org.apache.hadoop.hbase.shaded.com.google.protobuf.BlockingServiceservice, org.apache.hadoop.hbase.shaded.com.google.protobuf.Descriptors.MethodDescriptormd, @@ -537,6 +546,17 @@ longstartTime, inttimeout) + +Pairorg.apache.hadoop.hbase.shaded.com.google.protobuf.Message,CellScanner +NettyRpcServer.call(org.apache.hadoop.hbase.shaded.com.google.protobuf.BlockingServiceservice, + org.apache.hadoop.hbase.shaded.com.google.protobuf.Descriptors.MethodDescriptormd, +org.apache.hadoop.hbase.shaded.com.google.protobuf.Messageparam, +CellScannercellScanner, +longreceiveTime, +MonitoredRPCHandlerstatus, +longstartTime, +inttimeout) + Pairorg.apache.hadoop.hbase.shaded.com.google.protobuf.Message,CellScanner RpcServerInterface.call(RpcCallcall, @@ -615,6 +635,15 @@ Pairorg.apache.hadoop.hbase.shaded.com.google.protobuf.Message,CellScanner +NettyRpcServer.call(org.apache.hadoop.hbase.shaded.com.google.protobuf.BlockingServiceservice, + org.apache.hadoop.hbase.shaded.com.google.protobuf.Descriptors.MethodDescriptormd, +org.apache.hadoop.hbase.shaded.com.google.protobuf.Messageparam, +CellScannercellScanner, +longreceiveTime, +MonitoredRPCHandlerstatus) + + +Pairorg.apache.hadoop.hbase.shaded.com.google.protobuf.Message,CellScanner RpcServerInterface.call(org.apache.hadoop.hbase.shaded.com.google.protobuf.BlockingServiceservice, org.apache.hadoop.hbase.shaded.com.google.protobuf.Descriptors.MethodDescriptormd, org.apache.hadoop.hbase.shaded.com.google.protobuf.Messageparam, @@ -628,7 +657,7 @@ - + Pairorg.apache.hadoop.hbase.shaded.com.google.protobuf.Message,CellScanner SimpleRpcServer.call(org.apache.hadoop.hbase.shaded.com.google.protobuf.BlockingServiceservice, org.apache.hadoop.hbase.shaded.com.google.protobuf.Descriptors.MethodDescriptormd, @@ -639,62 +668,118 @@ longstartTime, inttimeout) + +Pairorg.apache.hadoop.hbase.shaded.com.google.protobuf.Message,CellScanner +NettyRpcServer.call(org.apache.hadoop.hbase.shaded.com.google.protobuf.BlockingServiceservice, + org.apache.hadoop.hbase.shaded.com.google.protobuf.Descriptors.MethodDescriptormd, +org.apache.hadoop.hbase.shaded.com.google.protobuf.Messageparam, +CellScannercellScanner, +longreceiveTime, +MonitoredRPCHandlerstatus, +longstartTime, +inttimeout) + + +abstract RpcServer.Call +RpcServer.Connection.createCall(intid, + org.apache.hadoop.hbase.shaded.com.google.protobuf.BlockingServiceservice, + org.apache.hadoop.hbase.shaded.com.google.protobuf.Descriptors.MethodDescriptormd, + org.apache.hadoop.hbase.shaded.protobuf.generated.RPCProtos.RequestHeaderheader, + org.apache.hadoop.hbase.shaded.com.google.protobuf.Messageparam, + CellScannercellScanner, + RpcServer.Connectionconnection, + longsize, + org.apache.htrace.TraceInfotinfo, + http://docs.oracle.com/javase/8/docs/api/java/net/InetAddress.html?is-external=true; title="class or interface in java.net">InetAddressremoteAddress, + inttimeout, + RpcServer.CallCleanupreqCleanup) + + +RpcServer.Call +SimpleRpcServer.Connection.createCall(intid, + org.apache.hadoop.hbase.shaded.com.google.protobuf.BlockingServiceservice, + org.apache.hadoop.hbase.shaded.com.google.protobuf.Descriptors.MethodDescriptormd, + org.apache.hadoop.hbase.shaded.protobuf.generated.RPCProtos.RequestHeaderheader, +
hbase git commit: HBASE-17867: Implement async procedure RPC API(list/exec/abort/isFinished)
Repository: hbase Updated Branches: refs/heads/master 91995749c -> ff998ef74 HBASE-17867: Implement async procedure RPC API(list/exec/abort/isFinished) Signed-off-by: Guanghao ZhangProject: http://git-wip-us.apache.org/repos/asf/hbase/repo Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/ff998ef7 Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/ff998ef7 Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/ff998ef7 Branch: refs/heads/master Commit: ff998ef74fe7b8d304b2e9e5579b019c62f836db Parents: 9199574 Author: huzheng Authored: Tue May 2 15:56:27 2017 +0800 Committer: Guanghao Zhang Committed: Wed May 3 21:46:37 2017 +0800 -- .../apache/hadoop/hbase/client/AsyncAdmin.java | 55 + .../hadoop/hbase/client/AsyncHBaseAdmin.java| 110 + .../apache/hadoop/hbase/client/HBaseAdmin.java | 63 -- .../hbase/shaded/protobuf/ProtobufUtil.java | 12 ++ .../client/TestAsyncProcedureAdminApi.java | 118 +++ 5 files changed, 316 insertions(+), 42 deletions(-) -- http://git-wip-us.apache.org/repos/asf/hbase/blob/ff998ef7/hbase-client/src/main/java/org/apache/hadoop/hbase/client/AsyncAdmin.java -- diff --git a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/AsyncAdmin.java b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/AsyncAdmin.java index 0782f5a..b764726 100644 --- a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/AsyncAdmin.java +++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/AsyncAdmin.java @@ -25,6 +25,7 @@ import java.util.regex.Pattern; import org.apache.hadoop.hbase.HColumnDescriptor; import org.apache.hadoop.hbase.HRegionInfo; +import org.apache.hadoop.hbase.ProcedureInfo; import org.apache.hadoop.hbase.ServerName; import org.apache.hadoop.hbase.NamespaceDescriptor; import org.apache.hadoop.hbase.TableName; @@ -741,4 +742,58 @@ public interface AsyncAdmin { */ CompletableFuture deleteTableSnapshots(Pattern tableNamePattern, Pattern snapshotNamePattern); + + /** + * Execute a distributed procedure on a cluster. + * @param signature A distributed procedure is uniquely identified by its signature (default the + * root ZK node name of the procedure). + * @param instance The instance name of the procedure. For some procedures, this parameter is + * optional. + * @param props Property/Value pairs of properties passing to the procedure + */ + CompletableFuture execProcedure(String signature, String instance, + Map props); + + /** + * Execute a distributed procedure on a cluster. + * @param signature A distributed procedure is uniquely identified by its signature (default the + * root ZK node name of the procedure). + * @param instance The instance name of the procedure. For some procedures, this parameter is + * optional. + * @param props Property/Value pairs of properties passing to the procedure + * @return data returned after procedure execution. null if no return data. + */ + CompletableFuture execProcedureWithRet(String signature, String instance, + Map props); + + /** + * Check the current state of the specified procedure. There are three possible states: + * + * running - returns false + * finished - returns true + * finished with error - throws the exception that caused the procedure to fail + * + * @param signature The signature that uniquely identifies a procedure + * @param instance The instance name of the procedure + * @param props Property/Value pairs of properties passing to the procedure + * @return true if the specified procedure is finished successfully, false if it is still running. + * The value is vrapped by {@link CompletableFuture} + */ + CompletableFuture isProcedureFinished(String signature, String instance, + Map props); + + /** + * abort a procedure + * @param procId ID of the procedure to abort + * @param mayInterruptIfRunning if the proc completed at least one step, should it be aborted? + * @return true if aborted, false if procedure already completed or does not exist. the value is + * wrapped by {@link CompletableFuture} + */ + CompletableFuture abortProcedure(long procId, boolean mayInterruptIfRunning); + + /** + * List procedures + * @return procedure list wrapped by {@link CompletableFuture} + */ + CompletableFuture listProcedures(); } http://git-wip-us.apache.org/repos/asf/hbase/blob/ff998ef7/hbase-client/src/main/java/org/apache/hadoop/hbase/client/AsyncHBaseAdmin.java
hbase git commit: HBASE-17958 Avoid passing unexpected cell to ScanQueryMatcher when optimize SEEK to SKIP
Repository: hbase Updated Branches: refs/heads/branch-1 58c504e70 -> 9f25836d9 HBASE-17958 Avoid passing unexpected cell to ScanQueryMatcher when optimize SEEK to SKIP Project: http://git-wip-us.apache.org/repos/asf/hbase/repo Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/9f25836d Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/9f25836d Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/9f25836d Branch: refs/heads/branch-1 Commit: 9f25836d99a7468a26bacb6a3009cf0fdc9736a8 Parents: 58c504e Author: Guanghao ZhangAuthored: Tue May 2 16:52:06 2017 +0800 Committer: Guanghao Zhang Committed: Wed May 3 21:39:30 2017 +0800 -- .../java/org/apache/hadoop/hbase/CellUtil.java | 18 + .../hadoop/hbase/regionserver/StoreScanner.java | 107 +++--- .../querymatcher/LegacyScanQueryMatcher.java| 5 - .../querymatcher/ScanQueryMatcher.java | 8 - .../querymatcher/UserScanQueryMatcher.java | 6 - .../hbase/regionserver/TestStoreScanner.java| 381 ++- 6 files changed, 459 insertions(+), 66 deletions(-) -- http://git-wip-us.apache.org/repos/asf/hbase/blob/9f25836d/hbase-common/src/main/java/org/apache/hadoop/hbase/CellUtil.java -- diff --git a/hbase-common/src/main/java/org/apache/hadoop/hbase/CellUtil.java b/hbase-common/src/main/java/org/apache/hadoop/hbase/CellUtil.java index be50069..0290ded 100644 --- a/hbase-common/src/main/java/org/apache/hadoop/hbase/CellUtil.java +++ b/hbase-common/src/main/java/org/apache/hadoop/hbase/CellUtil.java @@ -475,6 +475,24 @@ public final class CellUtil { } /** + * Compares the row and column of two keyvalues for equality + * @param left + * @param right + * @return True if same row and column. + */ + public static boolean matchingRowColumn(final Cell left, final Cell right) { +if ((left.getRowLength() + left.getFamilyLength() + left.getQualifierLength()) != (right +.getRowLength() + right.getFamilyLength() + right.getQualifierLength())) { + return false; +} + +if (!matchingRow(left, right)) { + return false; +} +return matchingColumn(left, right); + } + + /** * @return True if a delete type, a {@link KeyValue.Type#Delete} or a * {KeyValue.Type#DeleteFamily} or a * {@link KeyValue.Type#DeleteColumn} KeyValue type. http://git-wip-us.apache.org/repos/asf/hbase/blob/9f25836d/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/StoreScanner.java -- diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/StoreScanner.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/StoreScanner.java index 28d9ef2..fa33326 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/StoreScanner.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/StoreScanner.java @@ -539,7 +539,6 @@ public class StoreScanner extends NonReversedNonLazyKeyValueScanner prevCell = cell; ScanQueryMatcher.MatchCode qcode = matcher.match(cell); - qcode = optimize(qcode, cell); switch (qcode) { case INCLUDE: case INCLUDE_AND_SEEK_NEXT_ROW: @@ -592,9 +591,9 @@ public class StoreScanner extends NonReversedNonLazyKeyValueScanner // the heap.peek() will any way be in the next row. So the SQM.match(cell) need do // another compareRow to say the current row is DONE matcher.clearCurrentRow(); -seekToNextRow(cell); +seekOrSkipToNextRow(cell); } else if (qcode == ScanQueryMatcher.MatchCode.INCLUDE_AND_SEEK_NEXT_COL) { -seekAsDirection(matcher.getKeyForNextColumn(cell)); +seekOrSkipToNextColumn(cell); } else { this.heap.next(); } @@ -634,11 +633,11 @@ public class StoreScanner extends NonReversedNonLazyKeyValueScanner // the heap.peek() will any way be in the next row. So the SQM.match(cell) need do // another compareRow to say the current row is DONE matcher.clearCurrentRow(); - seekToNextRow(cell); + seekOrSkipToNextRow(cell); break; case SEEK_NEXT_COL: - seekAsDirection(matcher.getKeyForNextColumn(cell)); + seekOrSkipToNextColumn(cell); break; case SKIP: @@ -668,35 +667,47 @@ public class StoreScanner extends NonReversedNonLazyKeyValueScanner return scannerContext.setScannerState(NextState.NO_MORE_VALUES).hasMoreValues(); } + private void seekOrSkipToNextRow(Cell cell) throws IOException { +// If it is a Get Scan, then we know that we are done with this row;
hbase git commit: HBASE-17958 Avoid passing unexpected cell to ScanQueryMatcher when optimize SEEK to SKIP
Repository: hbase Updated Branches: refs/heads/master 4dbd025cc -> 91995749c HBASE-17958 Avoid passing unexpected cell to ScanQueryMatcher when optimize SEEK to SKIP Project: http://git-wip-us.apache.org/repos/asf/hbase/repo Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/91995749 Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/91995749 Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/91995749 Branch: refs/heads/master Commit: 91995749c214135163d96316d915d2a084dfb690 Parents: 4dbd025 Author: Guanghao ZhangAuthored: Thu Apr 27 14:07:21 2017 +0800 Committer: Guanghao Zhang Committed: Wed May 3 21:28:43 2017 +0800 -- .../hadoop/hbase/regionserver/StoreScanner.java | 108 +++-- .../querymatcher/LegacyScanQueryMatcher.java| 9 -- .../querymatcher/ScanQueryMatcher.java | 8 - .../querymatcher/UserScanQueryMatcher.java | 10 -- .../hbase/regionserver/TestStoreScanner.java| 161 +-- 5 files changed, 212 insertions(+), 84 deletions(-) -- http://git-wip-us.apache.org/repos/asf/hbase/blob/91995749/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/StoreScanner.java -- diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/StoreScanner.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/StoreScanner.java index e42979e..d39a6ee 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/StoreScanner.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/StoreScanner.java @@ -49,7 +49,6 @@ import org.apache.hadoop.hbase.regionserver.handler.ParallelSeekHandler; import org.apache.hadoop.hbase.regionserver.querymatcher.CompactionScanQueryMatcher; import org.apache.hadoop.hbase.regionserver.querymatcher.LegacyScanQueryMatcher; import org.apache.hadoop.hbase.regionserver.querymatcher.ScanQueryMatcher; -import org.apache.hadoop.hbase.regionserver.querymatcher.ScanQueryMatcher.MatchCode; import org.apache.hadoop.hbase.regionserver.querymatcher.UserScanQueryMatcher; import org.apache.hadoop.hbase.util.EnvironmentEdgeManager; @@ -572,7 +571,6 @@ public class StoreScanner extends NonReversedNonLazyKeyValueScanner checkScanOrder(prevCell, cell, comparator); prevCell = cell; ScanQueryMatcher.MatchCode qcode = matcher.match(cell); - qcode = optimize(qcode, cell); switch (qcode) { case INCLUDE: case INCLUDE_AND_SEEK_NEXT_ROW: @@ -621,9 +619,9 @@ public class StoreScanner extends NonReversedNonLazyKeyValueScanner return scannerContext.setScannerState(NextState.NO_MORE_VALUES).hasMoreValues(); } matcher.clearCurrentRow(); -seekToNextRow(cell); +seekOrSkipToNextRow(cell); } else if (qcode == ScanQueryMatcher.MatchCode.INCLUDE_AND_SEEK_NEXT_COL) { -seekAsDirection(matcher.getKeyForNextColumn(cell)); +seekOrSkipToNextColumn(cell); } else { this.heap.next(); } @@ -658,11 +656,11 @@ public class StoreScanner extends NonReversedNonLazyKeyValueScanner return scannerContext.setScannerState(NextState.NO_MORE_VALUES).hasMoreValues(); } matcher.clearCurrentRow(); - seekToNextRow(cell); + seekOrSkipToNextRow(cell); break; case SEEK_NEXT_COL: - seekAsDirection(matcher.getKeyForNextColumn(cell)); + seekOrSkipToNextColumn(cell); break; case SKIP: @@ -692,35 +690,47 @@ public class StoreScanner extends NonReversedNonLazyKeyValueScanner return scannerContext.setScannerState(NextState.NO_MORE_VALUES).hasMoreValues(); } + private void seekOrSkipToNextRow(Cell cell) throws IOException { +// If it is a Get Scan, then we know that we are done with this row; there are no more +// rows beyond the current one: don't try to optimize. +if (!get) { + if (trySkipToNextRow(cell)) { +return; + } +} +seekToNextRow(cell); + } + + private void seekOrSkipToNextColumn(Cell cell) throws IOException { +if (!trySkipToNextColumn(cell)) { + seekAsDirection(matcher.getKeyForNextColumn(cell)); +} + } + /** * See if we should actually SEEK or rather just SKIP to the next Cell (see HBASE-13109). - * This method works together with ColumnTrackers and Filters. ColumnTrackers may issue SEEK - * hints, such as seek to next column, next row, or seek to an arbitrary seek key. - * This method intercepts these qcodes and decides whether a seek is the most efficient _actual_ - * way to get us to the requested cell (SEEKs are more expensive than SKIP, SKIP, SKIP inside
[2/2] hbase git commit: HBASE-17263 Netty based rpc server impl
HBASE-17263 Netty based rpc server impl Signed-off-by: zhangduoProject: http://git-wip-us.apache.org/repos/asf/hbase/repo Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/4dbd025c Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/4dbd025c Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/4dbd025c Branch: refs/heads/master Commit: 4dbd025ccf0b6962a863b53c9dbf1c2c42e679d4 Parents: de78c11 Author: binlijin Authored: Wed May 3 17:23:26 2017 +0800 Committer: zhangduo Committed: Wed May 3 17:23:26 2017 +0800 -- .../apache/hadoop/hbase/ipc/BufferChain.java| 10 + .../apache/hadoop/hbase/ipc/NettyRpcServer.java | 540 .../org/apache/hadoop/hbase/ipc/RpcServer.java | 614 +- .../hadoop/hbase/ipc/SimpleRpcServer.java | 643 ++- .../hadoop/hbase/ipc/AbstractTestIPC.java | 2 +- .../hadoop/hbase/ipc/TestNettyRpcServer.java| 109 .../hadoop/hbase/ipc/TestProtoBufRpc.java | 18 + .../hbase/ipc/TestRpcHandlerException.java | 20 +- .../hadoop/hbase/security/TestSecureIPC.java| 29 +- .../security/token/TestTokenAuthentication.java | 48 +- 10 files changed, 1396 insertions(+), 637 deletions(-) -- http://git-wip-us.apache.org/repos/asf/hbase/blob/4dbd025c/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/BufferChain.java -- diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/BufferChain.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/BufferChain.java index 26bc56c..bd0515a 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/BufferChain.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/BufferChain.java @@ -32,11 +32,13 @@ class BufferChain { private final ByteBuffer[] buffers; private int remaining = 0; private int bufferOffset = 0; + private int size; BufferChain(ByteBuffer[] buffers) { for (ByteBuffer b : buffers) { this.remaining += b.remaining(); } +this.size = remaining; this.buffers = buffers; } @@ -108,4 +110,12 @@ class BufferChain { } } } + + int size() { +return size; + } + + ByteBuffer[] getBuffers() { +return this.buffers; + } } http://git-wip-us.apache.org/repos/asf/hbase/blob/4dbd025c/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/NettyRpcServer.java -- diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/NettyRpcServer.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/NettyRpcServer.java new file mode 100644 index 000..be55378 --- /dev/null +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/NettyRpcServer.java @@ -0,0 +1,540 @@ +/** + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +package org.apache.hadoop.hbase.ipc; + +import io.netty.bootstrap.ServerBootstrap; +import io.netty.buffer.ByteBuf; +import io.netty.buffer.PooledByteBufAllocator; +import io.netty.buffer.Unpooled; +import io.netty.channel.Channel; +import io.netty.channel.ChannelFuture; +import io.netty.channel.ChannelFutureListener; +import io.netty.channel.ChannelHandlerContext; +import io.netty.channel.ChannelInboundHandlerAdapter; +import io.netty.channel.ChannelInitializer; +import io.netty.channel.ChannelOption; +import io.netty.channel.ChannelOutboundHandlerAdapter; +import io.netty.channel.ChannelPipeline; +import io.netty.channel.ChannelPromise; +import io.netty.channel.EventLoopGroup; +import io.netty.channel.epoll.EpollEventLoopGroup; +import io.netty.channel.epoll.EpollServerSocketChannel; +import io.netty.channel.group.ChannelGroup; +import io.netty.channel.group.DefaultChannelGroup; +import io.netty.channel.nio.NioEventLoopGroup; +import io.netty.channel.socket.SocketChannel; +import io.netty.channel.socket.nio.NioServerSocketChannel; +import io.netty.handler.codec.ByteToMessageDecoder; +import
[1/2] hbase git commit: HBASE-17263 Netty based rpc server impl
Repository: hbase Updated Branches: refs/heads/master de78c1189 -> 4dbd025cc http://git-wip-us.apache.org/repos/asf/hbase/blob/4dbd025c/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/SimpleRpcServer.java -- diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/SimpleRpcServer.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/SimpleRpcServer.java index c409f6e..f771eec 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/SimpleRpcServer.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/ipc/SimpleRpcServer.java @@ -18,9 +18,6 @@ package org.apache.hadoop.hbase.ipc; -import java.io.ByteArrayInputStream; -import java.io.ByteArrayOutputStream; -import java.io.DataOutputStream; import java.io.IOException; import java.io.InputStream; import java.net.BindException; @@ -32,7 +29,6 @@ import java.net.SocketException; import java.net.UnknownHostException; import java.nio.ByteBuffer; import java.nio.channels.CancelledKeyException; -import java.nio.channels.Channels; import java.nio.channels.ClosedChannelException; import java.nio.channels.GatheringByteChannel; import java.nio.channels.ReadableByteChannel; @@ -40,8 +36,6 @@ import java.nio.channels.SelectionKey; import java.nio.channels.Selector; import java.nio.channels.ServerSocketChannel; import java.nio.channels.SocketChannel; -import java.nio.channels.WritableByteChannel; -import java.security.PrivilegedExceptionAction; import java.util.ArrayList; import java.util.Arrays; import java.util.Collections; @@ -60,9 +54,6 @@ import java.util.concurrent.atomic.LongAdder; import java.util.concurrent.locks.Lock; import java.util.concurrent.locks.ReentrantLock; -import javax.security.sasl.Sasl; -import javax.security.sasl.SaslException; - import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.hbase.CellScanner; import org.apache.hadoop.hbase.DoNotRetryIOException; @@ -73,42 +64,26 @@ import org.apache.hadoop.hbase.classification.InterfaceAudience; import org.apache.hadoop.hbase.classification.InterfaceStability; import org.apache.hadoop.hbase.client.VersionInfoUtil; import org.apache.hadoop.hbase.exceptions.RequestTooBigException; -import org.apache.hadoop.hbase.io.ByteBufferOutputStream; import org.apache.hadoop.hbase.monitoring.MonitoredRPCHandler; import org.apache.hadoop.hbase.nio.ByteBuff; import org.apache.hadoop.hbase.nio.SingleByteBuff; import org.apache.hadoop.hbase.security.AccessDeniedException; import org.apache.hadoop.hbase.security.AuthMethod; import org.apache.hadoop.hbase.security.HBasePolicyProvider; -import org.apache.hadoop.hbase.security.HBaseSaslRpcServer; -import org.apache.hadoop.hbase.security.HBaseSaslRpcServer.SaslDigestCallbackHandler; -import org.apache.hadoop.hbase.security.HBaseSaslRpcServer.SaslGssCallbackHandler; import org.apache.hadoop.hbase.security.SaslStatus; import org.apache.hadoop.hbase.security.SaslUtil; import org.apache.hadoop.hbase.shaded.com.google.protobuf.BlockingService; import org.apache.hadoop.hbase.shaded.com.google.protobuf.CodedInputStream; import org.apache.hadoop.hbase.shaded.com.google.protobuf.Descriptors.MethodDescriptor; import org.apache.hadoop.hbase.shaded.com.google.protobuf.Message; -import org.apache.hadoop.hbase.shaded.com.google.protobuf.TextFormat; -import org.apache.hadoop.hbase.shaded.com.google.protobuf.UnsafeByteOperations; import org.apache.hadoop.hbase.shaded.protobuf.ProtobufUtil; -import org.apache.hadoop.hbase.shaded.protobuf.generated.RPCProtos; -import org.apache.hadoop.hbase.shaded.protobuf.generated.RPCProtos.ConnectionHeader; import org.apache.hadoop.hbase.shaded.protobuf.generated.RPCProtos.RequestHeader; import org.apache.hadoop.hbase.util.Bytes; import org.apache.hadoop.hbase.util.Pair; import org.apache.hadoop.hbase.util.Threads; -import org.apache.hadoop.io.BytesWritable; import org.apache.hadoop.io.IOUtils; import org.apache.hadoop.io.IntWritable; -import org.apache.hadoop.io.Writable; -import org.apache.hadoop.io.WritableUtils; -import org.apache.hadoop.security.UserGroupInformation; -import org.apache.hadoop.security.UserGroupInformation.AuthenticationMethod; -import org.apache.hadoop.security.authorize.AuthorizationException; -import org.apache.hadoop.security.authorize.ProxyUsers; import org.apache.hadoop.security.authorize.ServiceAuthorizationManager; -import org.apache.hadoop.security.token.SecretManager.InvalidToken; import org.apache.hadoop.util.StringUtils; import org.apache.htrace.TraceInfo; @@ -165,8 +140,9 @@ public class SimpleRpcServer extends RpcServer { justification="Can't figure why this complaint is happening... see below") Call(int id, final BlockingService service, final MethodDescriptor md, RequestHeader header, Message param, CellScanner cellScanner, -Connection connection, Responder responder, long size, TraceInfo tinfo, -