HBASE-17428 Implement informational RPCs for space quotas Create some RPCs that can expose the in-memory state that the RegionServers and Master hold to drive the space quota "state machine". Then, create some hbase shell commands to interact with those.
Project: http://git-wip-us.apache.org/repos/asf/hbase/repo Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/a1ffeea4 Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/a1ffeea4 Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/a1ffeea4 Branch: refs/heads/HBASE-16961 Commit: a1ffeea4aac904f449fc9cdb3a7a3f57c09052b3 Parents: 376ac5d Author: Josh Elser <els...@apache.org> Authored: Tue Feb 21 15:36:39 2017 -0500 Committer: Josh Elser <els...@apache.org> Committed: Tue Apr 11 13:10:03 2017 -0400 ---------------------------------------------------------------------- .../hbase/client/ConnectionImplementation.java | 9 + .../hadoop/hbase/client/QuotaStatusCalls.java | 125 + .../client/ShortCircuitMasterConnection.java | 7 + .../hadoop/hbase/quotas/QuotaTableUtil.java | 77 + .../hbase/shaded/protobuf/RequestConverter.java | 33 + .../shaded/protobuf/generated/AdminProtos.java | 394 +- .../shaded/protobuf/generated/MasterProtos.java | 92 +- .../shaded/protobuf/generated/QuotaProtos.java | 5686 +++++++++++++++++- .../src/main/protobuf/Admin.proto | 9 + .../src/main/protobuf/Master.proto | 4 + .../src/main/protobuf/Quota.proto | 35 + .../hadoop/hbase/master/MasterRpcServices.java | 40 + .../hbase/quotas/ActivePolicyEnforcement.java | 8 + .../hbase/regionserver/RSRpcServices.java | 57 + .../hadoop/hbase/master/MockRegionServer.java | 18 + .../hbase/quotas/TestQuotaStatusRPCs.java | 192 + hbase-shell/src/main/ruby/hbase/quotas.rb | 16 + hbase-shell/src/main/ruby/shell.rb | 3 + .../ruby/shell/commands/list_quota_snapshots.rb | 59 + .../shell/commands/list_quota_table_sizes.rb | 47 + .../shell/commands/list_quota_violations.rb | 48 + hbase-shell/src/test/ruby/hbase/quotas_test.rb | 24 - .../test/ruby/hbase/quotas_test_no_cluster.rb | 69 + 23 files changed, 6899 insertions(+), 153 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hbase/blob/a1ffeea4/hbase-client/src/main/java/org/apache/hadoop/hbase/client/ConnectionImplementation.java ---------------------------------------------------------------------- diff --git a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/ConnectionImplementation.java b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/ConnectionImplementation.java index 99feb14..3f27e1c 100644 --- a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/ConnectionImplementation.java +++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/ConnectionImplementation.java @@ -94,6 +94,8 @@ import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.SecurityCa import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.SecurityCapabilitiesResponse; import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.SetNormalizerRunningRequest; import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.SetNormalizerRunningResponse; +import org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.GetSpaceQuotaRegionSizesRequest; +import org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.GetSpaceQuotaRegionSizesResponse; import org.apache.hadoop.hbase.shaded.protobuf.generated.ReplicationProtos.AddReplicationPeerRequest; import org.apache.hadoop.hbase.shaded.protobuf.generated.ReplicationProtos.AddReplicationPeerResponse; import org.apache.hadoop.hbase.shaded.protobuf.generated.ReplicationProtos.DisableReplicationPeerRequest; @@ -1731,6 +1733,13 @@ class ConnectionImplementation implements ClusterConnection, Closeable { ListReplicationPeersRequest request) throws ServiceException { return stub.listReplicationPeers(controller, request); } + + @Override + public GetSpaceQuotaRegionSizesResponse getSpaceQuotaRegionSizes( + RpcController controller, GetSpaceQuotaRegionSizesRequest request) + throws ServiceException { + return stub.getSpaceQuotaRegionSizes(controller, request); + } }; } http://git-wip-us.apache.org/repos/asf/hbase/blob/a1ffeea4/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 new file mode 100644 index 0000000..f0f385d --- /dev/null +++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/QuotaStatusCalls.java @@ -0,0 +1,125 @@ +/* + * 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.client; + +import java.io.IOException; +import java.util.concurrent.Callable; + +import org.apache.hadoop.hbase.ServerName; +import org.apache.hadoop.hbase.classification.InterfaceAudience; +import org.apache.hadoop.hbase.ipc.RpcControllerFactory; +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.GetSpaceQuotaEnforcementsResponse; +import org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.GetSpaceQuotaRegionSizesResponse; +import org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.GetSpaceQuotaSnapshotsResponse; + +/** + * Client class to wrap RPCs to HBase servers for space quota status information. + */ +@InterfaceAudience.Private +public class QuotaStatusCalls { + + /** + * {@link #getMasterRegionSizes(Connection, RpcControllerFactory, RpcRetryingCallerFactory, int)} + */ + public static GetSpaceQuotaRegionSizesResponse getMasterRegionSizes( + ClusterConnection clusterConn, int timeout) throws IOException { + RpcControllerFactory rpcController = clusterConn.getRpcControllerFactory(); + RpcRetryingCallerFactory rpcCaller = clusterConn.getRpcRetryingCallerFactory(); + return getMasterRegionSizes(clusterConn, rpcController, rpcCaller, timeout); + } + + /** + * Executes an RPC to the HBase master to fetch its view on the Region sizes. + */ + public static GetSpaceQuotaRegionSizesResponse getMasterRegionSizes( + Connection conn, RpcControllerFactory factory, RpcRetryingCallerFactory rpcCaller, + int timeout) throws IOException { + MasterCallable<GetSpaceQuotaRegionSizesResponse> callable = + new MasterCallable<GetSpaceQuotaRegionSizesResponse>(conn, factory) { + @Override + protected GetSpaceQuotaRegionSizesResponse rpcCall() throws Exception { + return master.getSpaceQuotaRegionSizes( + getRpcController(), RequestConverter.buildGetSpaceQuotaRegionSizesRequest()); + } + }; + RpcRetryingCaller<GetSpaceQuotaRegionSizesResponse> caller = rpcCaller.newCaller(); + try { + return caller.callWithoutRetries(callable, timeout); + } finally { + callable.close(); + } + } + + /** + * {@link #getRegionServerQuotaSnapshot(ClusterConnection, RpcControllerFactory, int, ServerName)} + */ + public static GetSpaceQuotaSnapshotsResponse getRegionServerQuotaSnapshot( + ClusterConnection clusterConn, int timeout, ServerName sn) throws IOException { + RpcControllerFactory rpcController = clusterConn.getRpcControllerFactory(); + return getRegionServerQuotaSnapshot(clusterConn, rpcController, timeout, sn); + } + + /** + * Executes an RPC to the RegionServer identified by the {@code ServerName} to fetch its view + * on space quotas. + */ + public static GetSpaceQuotaSnapshotsResponse getRegionServerQuotaSnapshot( + ClusterConnection conn, RpcControllerFactory factory, + int timeout, ServerName sn) throws IOException { + final AdminService.BlockingInterface admin = conn.getAdmin(sn); + Callable<GetSpaceQuotaSnapshotsResponse> callable = + new Callable<GetSpaceQuotaSnapshotsResponse>() { + @Override + public GetSpaceQuotaSnapshotsResponse call() throws Exception { + return admin.getSpaceQuotaSnapshots( + factory.newController(), RequestConverter.buildGetSpaceQuotaSnapshotsRequest()); + } + }; + return ProtobufUtil.call(callable); + } + + /** + * {@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<GetSpaceQuotaEnforcementsResponse> callable = + new Callable<GetSpaceQuotaEnforcementsResponse>() { + @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/a1ffeea4/hbase-client/src/main/java/org/apache/hadoop/hbase/client/ShortCircuitMasterConnection.java ---------------------------------------------------------------------- diff --git a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/ShortCircuitMasterConnection.java b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/ShortCircuitMasterConnection.java index 72b2a15..30ae79c 100644 --- a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/ShortCircuitMasterConnection.java +++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/ShortCircuitMasterConnection.java @@ -23,6 +23,8 @@ import org.apache.hadoop.hbase.shaded.com.google.protobuf.ServiceException; import org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.CoprocessorServiceRequest; import org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.CoprocessorServiceResponse; import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.*; +import org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.GetSpaceQuotaRegionSizesRequest; +import org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.GetSpaceQuotaRegionSizesResponse; import org.apache.hadoop.hbase.shaded.protobuf.generated.ReplicationProtos.AddReplicationPeerRequest; import org.apache.hadoop.hbase.shaded.protobuf.generated.ReplicationProtos.AddReplicationPeerResponse; import org.apache.hadoop.hbase.shaded.protobuf.generated.ReplicationProtos.DisableReplicationPeerRequest; @@ -478,4 +480,9 @@ public class ShortCircuitMasterConnection implements MasterKeepAliveConnection { return stub.listReplicationPeers(controller, request); } + @Override + public GetSpaceQuotaRegionSizesResponse getSpaceQuotaRegionSizes(RpcController controller, + GetSpaceQuotaRegionSizesRequest request) throws ServiceException { + return stub.getSpaceQuotaRegionSizes(controller, request); + } } http://git-wip-us.apache.org/repos/asf/hbase/blob/a1ffeea4/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 ca525f0..5eb6240 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 @@ -21,6 +21,7 @@ package org.apache.hadoop.hbase.quotas; import java.io.ByteArrayInputStream; import java.io.ByteArrayOutputStream; import java.io.IOException; +import java.util.HashMap; import java.util.List; import java.util.Map; import java.util.Objects; @@ -30,12 +31,15 @@ import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; import org.apache.hadoop.hbase.Cell; import org.apache.hadoop.hbase.NamespaceDescriptor; +import org.apache.hadoop.hbase.ServerName; import org.apache.hadoop.hbase.TableName; import org.apache.hadoop.hbase.classification.InterfaceAudience; import org.apache.hadoop.hbase.classification.InterfaceStability; +import org.apache.hadoop.hbase.client.ClusterConnection; import org.apache.hadoop.hbase.client.Connection; import org.apache.hadoop.hbase.client.Get; import org.apache.hadoop.hbase.client.Put; +import org.apache.hadoop.hbase.client.QuotaStatusCalls; import org.apache.hadoop.hbase.client.Result; import org.apache.hadoop.hbase.client.Scan; import org.apache.hadoop.hbase.client.Table; @@ -45,12 +49,19 @@ import org.apache.hadoop.hbase.filter.FilterList; import org.apache.hadoop.hbase.filter.QualifierFilter; import org.apache.hadoop.hbase.filter.RegexStringComparator; import org.apache.hadoop.hbase.filter.RowFilter; +import org.apache.hadoop.hbase.ipc.RpcControllerFactory; import org.apache.hadoop.hbase.protobuf.ProtobufMagic; import org.apache.hadoop.hbase.shaded.com.google.protobuf.ByteString; import org.apache.hadoop.hbase.shaded.com.google.protobuf.InvalidProtocolBufferException; 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.QuotaProtos; +import org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.GetSpaceQuotaEnforcementsResponse; +import org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.GetSpaceQuotaEnforcementsResponse.TableViolationPolicy; +import org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.GetSpaceQuotaRegionSizesResponse; +import org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.GetSpaceQuotaSnapshotsResponse; +import org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.GetSpaceQuotaSnapshotsResponse.TableQuotaSnapshot; +import org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.GetSpaceQuotaRegionSizesResponse.RegionSizes; import org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.Quotas; import org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.SpaceQuota; import org.apache.hadoop.hbase.util.Bytes; @@ -363,6 +374,72 @@ public class QuotaTableUtil { return p; } + + /* ========================================================================= + * Space quota status RPC helpers + */ + /** + * Fetches the table sizes on the filesystem as tracked by the HBase Master. + */ + public static Map<TableName,Long> getMasterReportedTableSizes( + Connection conn) throws IOException { + if (!(conn instanceof ClusterConnection)) { + throw new IllegalArgumentException("Expected a ClusterConnection"); + } + ClusterConnection clusterConn = (ClusterConnection) conn; + GetSpaceQuotaRegionSizesResponse response = QuotaStatusCalls.getMasterRegionSizes( + clusterConn, 0); + Map<TableName,Long> tableSizes = new HashMap<>(); + for (RegionSizes sizes : response.getSizesList()) { + TableName tn = ProtobufUtil.toTableName(sizes.getTableName()); + tableSizes.put(tn, sizes.getSize()); + } + return tableSizes; + } + + /** + * Fetches the observed {@link SpaceQuotaSnapshot}s observed by a RegionServer. + */ + public static Map<TableName,SpaceQuotaSnapshot> getRegionServerQuotaSnapshots( + Connection conn, ServerName regionServer) throws IOException { + if (!(conn instanceof ClusterConnection)) { + throw new IllegalArgumentException("Expected a ClusterConnection"); + } + ClusterConnection clusterConn = (ClusterConnection) conn; + GetSpaceQuotaSnapshotsResponse response = QuotaStatusCalls.getRegionServerQuotaSnapshot( + clusterConn, 0, regionServer); + Map<TableName,SpaceQuotaSnapshot> snapshots = new HashMap<>(); + for (TableQuotaSnapshot snapshot : response.getSnapshotsList()) { + snapshots.put( + ProtobufUtil.toTableName(snapshot.getTableName()), + SpaceQuotaSnapshot.toSpaceQuotaSnapshot(snapshot.getSnapshot())); + } + return snapshots; + } + + /** + * Fetches the active {@link SpaceViolationPolicy}'s that are being enforced on the + * given RegionServer. + */ + public static Map<TableName,SpaceViolationPolicy> getRegionServerQuotaViolations( + Connection conn, ServerName regionServer) throws IOException { + if (!(conn instanceof ClusterConnection)) { + throw new IllegalArgumentException("Expected a ClusterConnection"); + } + ClusterConnection clusterConn = (ClusterConnection) conn; + RpcControllerFactory rpcController = clusterConn.getRpcControllerFactory(); + GetSpaceQuotaEnforcementsResponse response = + QuotaStatusCalls.getRegionServerSpaceQuotaEnforcements( + clusterConn, rpcController, 0, regionServer); + Map<TableName,SpaceViolationPolicy> policies = new HashMap<>(); + for (TableViolationPolicy policy : response.getViolationPoliciesList()) { + policies.put( + ProtobufUtil.toTableName(policy.getTableName()), + ProtobufUtil.toViolationPolicy(policy.getViolationPolicy())); + } + return policies; + } + /* ========================================================================= * Quotas protobuf helpers */ http://git-wip-us.apache.org/repos/asf/hbase/blob/a1ffeea4/hbase-client/src/main/java/org/apache/hadoop/hbase/shaded/protobuf/RequestConverter.java ---------------------------------------------------------------------- diff --git a/hbase-client/src/main/java/org/apache/hadoop/hbase/shaded/protobuf/RequestConverter.java b/hbase-client/src/main/java/org/apache/hadoop/hbase/shaded/protobuf/RequestConverter.java index a513d66..b37be68 100644 --- a/hbase-client/src/main/java/org/apache/hadoop/hbase/shaded/protobuf/RequestConverter.java +++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/shaded/protobuf/RequestConverter.java @@ -116,6 +116,9 @@ import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.SetNormali import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.SetSplitOrMergeEnabledRequest; import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.TruncateTableRequest; import org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.UnassignRegionRequest; +import org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.GetSpaceQuotaEnforcementsRequest; +import org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.GetSpaceQuotaRegionSizesRequest; +import org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.GetSpaceQuotaSnapshotsRequest; import org.apache.hadoop.hbase.shaded.protobuf.generated.RegionServerStatusProtos.GetLastFlushedSequenceIdRequest; import org.apache.hadoop.hbase.shaded.protobuf.generated.RegionServerStatusProtos.SplitTableRegionRequest; import org.apache.hadoop.hbase.shaded.protobuf.generated.ReplicationProtos; @@ -1695,4 +1698,34 @@ public final class RequestConverter { builder.setNamespaceName(name); return builder.build(); } + + private static final GetSpaceQuotaRegionSizesRequest GET_SPACE_QUOTA_REGION_SIZES_REQUEST = + GetSpaceQuotaRegionSizesRequest.newBuilder().build(); + + /** + * Returns a {@link GetSpaceQuotaRegionSizesRequest} object. + */ + public static GetSpaceQuotaRegionSizesRequest buildGetSpaceQuotaRegionSizesRequest() { + return GET_SPACE_QUOTA_REGION_SIZES_REQUEST; + } + + private static final GetSpaceQuotaSnapshotsRequest GET_SPACE_QUOTA_SNAPSHOTS_REQUEST = + GetSpaceQuotaSnapshotsRequest.newBuilder().build(); + + /** + * Returns a {@link GetSpaceQuotaSnapshotsRequest} object. + */ + public static GetSpaceQuotaSnapshotsRequest buildGetSpaceQuotaSnapshotsRequest() { + return GET_SPACE_QUOTA_SNAPSHOTS_REQUEST; + } + + private static final GetSpaceQuotaEnforcementsRequest GET_SPACE_QUOTA_ENFORCEMENTS_REQUEST = + GetSpaceQuotaEnforcementsRequest.newBuilder().build(); + + /** + * Returns a {@link GetSpaceQuotaEnforcementsRequest} object. + */ + public static GetSpaceQuotaEnforcementsRequest buildGetSpaceQuotaEnforcementsRequest() { + return GET_SPACE_QUOTA_ENFORCEMENTS_REQUEST; + } } http://git-wip-us.apache.org/repos/asf/hbase/blob/a1ffeea4/hbase-protocol-shaded/src/main/java/org/apache/hadoop/hbase/shaded/protobuf/generated/AdminProtos.java ---------------------------------------------------------------------- diff --git a/hbase-protocol-shaded/src/main/java/org/apache/hadoop/hbase/shaded/protobuf/generated/AdminProtos.java b/hbase-protocol-shaded/src/main/java/org/apache/hadoop/hbase/shaded/protobuf/generated/AdminProtos.java index 703de38..9145a63 100644 --- a/hbase-protocol-shaded/src/main/java/org/apache/hadoop/hbase/shaded/protobuf/generated/AdminProtos.java +++ b/hbase-protocol-shaded/src/main/java/org/apache/hadoop/hbase/shaded/protobuf/generated/AdminProtos.java @@ -24902,6 +24902,30 @@ public final class AdminProtos { org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.GetRegionLoadRequest request, org.apache.hadoop.hbase.shaded.com.google.protobuf.RpcCallback<org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.GetRegionLoadResponse> done); + /** + * <pre> + ** Fetches the RegionServer's view of space quotas + * </pre> + * + * <code>rpc GetSpaceQuotaSnapshots(.hbase.pb.GetSpaceQuotaSnapshotsRequest) returns (.hbase.pb.GetSpaceQuotaSnapshotsResponse);</code> + */ + public abstract void getSpaceQuotaSnapshots( + org.apache.hadoop.hbase.shaded.com.google.protobuf.RpcController controller, + org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.GetSpaceQuotaSnapshotsRequest request, + org.apache.hadoop.hbase.shaded.com.google.protobuf.RpcCallback<org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.GetSpaceQuotaSnapshotsResponse> done); + + /** + * <pre> + ** Fetches the RegionServer's space quota active enforcements + * </pre> + * + * <code>rpc GetSpaceQuotaEnforcements(.hbase.pb.GetSpaceQuotaEnforcementsRequest) returns (.hbase.pb.GetSpaceQuotaEnforcementsResponse);</code> + */ + public abstract void getSpaceQuotaEnforcements( + org.apache.hadoop.hbase.shaded.com.google.protobuf.RpcController controller, + org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.GetSpaceQuotaEnforcementsRequest request, + org.apache.hadoop.hbase.shaded.com.google.protobuf.RpcCallback<org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.GetSpaceQuotaEnforcementsResponse> done); + } public static org.apache.hadoop.hbase.shaded.com.google.protobuf.Service newReflectiveService( @@ -25051,6 +25075,22 @@ public final class AdminProtos { impl.getRegionLoad(controller, request, done); } + @java.lang.Override + public void getSpaceQuotaSnapshots( + org.apache.hadoop.hbase.shaded.com.google.protobuf.RpcController controller, + org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.GetSpaceQuotaSnapshotsRequest request, + org.apache.hadoop.hbase.shaded.com.google.protobuf.RpcCallback<org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.GetSpaceQuotaSnapshotsResponse> done) { + impl.getSpaceQuotaSnapshots(controller, request, done); + } + + @java.lang.Override + public void getSpaceQuotaEnforcements( + org.apache.hadoop.hbase.shaded.com.google.protobuf.RpcController controller, + org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.GetSpaceQuotaEnforcementsRequest request, + org.apache.hadoop.hbase.shaded.com.google.protobuf.RpcCallback<org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.GetSpaceQuotaEnforcementsResponse> done) { + impl.getSpaceQuotaEnforcements(controller, request, done); + } + }; } @@ -25109,6 +25149,10 @@ public final class AdminProtos { return impl.updateConfiguration(controller, (org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.UpdateConfigurationRequest)request); case 17: return impl.getRegionLoad(controller, (org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.GetRegionLoadRequest)request); + case 18: + return impl.getSpaceQuotaSnapshots(controller, (org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.GetSpaceQuotaSnapshotsRequest)request); + case 19: + return impl.getSpaceQuotaEnforcements(controller, (org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.GetSpaceQuotaEnforcementsRequest)request); default: throw new java.lang.AssertionError("Can't get here."); } @@ -25159,6 +25203,10 @@ public final class AdminProtos { return org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.UpdateConfigurationRequest.getDefaultInstance(); case 17: return org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.GetRegionLoadRequest.getDefaultInstance(); + case 18: + return org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.GetSpaceQuotaSnapshotsRequest.getDefaultInstance(); + case 19: + return org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.GetSpaceQuotaEnforcementsRequest.getDefaultInstance(); default: throw new java.lang.AssertionError("Can't get here."); } @@ -25209,6 +25257,10 @@ public final class AdminProtos { return org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.UpdateConfigurationResponse.getDefaultInstance(); case 17: return org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.GetRegionLoadResponse.getDefaultInstance(); + case 18: + return org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.GetSpaceQuotaSnapshotsResponse.getDefaultInstance(); + case 19: + return org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.GetSpaceQuotaEnforcementsResponse.getDefaultInstance(); default: throw new java.lang.AssertionError("Can't get here."); } @@ -25361,6 +25413,30 @@ public final class AdminProtos { org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.GetRegionLoadRequest request, org.apache.hadoop.hbase.shaded.com.google.protobuf.RpcCallback<org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.GetRegionLoadResponse> done); + /** + * <pre> + ** Fetches the RegionServer's view of space quotas + * </pre> + * + * <code>rpc GetSpaceQuotaSnapshots(.hbase.pb.GetSpaceQuotaSnapshotsRequest) returns (.hbase.pb.GetSpaceQuotaSnapshotsResponse);</code> + */ + public abstract void getSpaceQuotaSnapshots( + org.apache.hadoop.hbase.shaded.com.google.protobuf.RpcController controller, + org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.GetSpaceQuotaSnapshotsRequest request, + org.apache.hadoop.hbase.shaded.com.google.protobuf.RpcCallback<org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.GetSpaceQuotaSnapshotsResponse> done); + + /** + * <pre> + ** Fetches the RegionServer's space quota active enforcements + * </pre> + * + * <code>rpc GetSpaceQuotaEnforcements(.hbase.pb.GetSpaceQuotaEnforcementsRequest) returns (.hbase.pb.GetSpaceQuotaEnforcementsResponse);</code> + */ + public abstract void getSpaceQuotaEnforcements( + org.apache.hadoop.hbase.shaded.com.google.protobuf.RpcController controller, + org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.GetSpaceQuotaEnforcementsRequest request, + org.apache.hadoop.hbase.shaded.com.google.protobuf.RpcCallback<org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.GetSpaceQuotaEnforcementsResponse> done); + public static final org.apache.hadoop.hbase.shaded.com.google.protobuf.Descriptors.ServiceDescriptor getDescriptor() { @@ -25473,6 +25549,16 @@ public final class AdminProtos { org.apache.hadoop.hbase.shaded.com.google.protobuf.RpcUtil.<org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.GetRegionLoadResponse>specializeCallback( done)); return; + case 18: + this.getSpaceQuotaSnapshots(controller, (org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.GetSpaceQuotaSnapshotsRequest)request, + org.apache.hadoop.hbase.shaded.com.google.protobuf.RpcUtil.<org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.GetSpaceQuotaSnapshotsResponse>specializeCallback( + done)); + return; + case 19: + this.getSpaceQuotaEnforcements(controller, (org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.GetSpaceQuotaEnforcementsRequest)request, + org.apache.hadoop.hbase.shaded.com.google.protobuf.RpcUtil.<org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.GetSpaceQuotaEnforcementsResponse>specializeCallback( + done)); + return; default: throw new java.lang.AssertionError("Can't get here."); } @@ -25523,6 +25609,10 @@ public final class AdminProtos { return org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.UpdateConfigurationRequest.getDefaultInstance(); case 17: return org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.GetRegionLoadRequest.getDefaultInstance(); + case 18: + return org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.GetSpaceQuotaSnapshotsRequest.getDefaultInstance(); + case 19: + return org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.GetSpaceQuotaEnforcementsRequest.getDefaultInstance(); default: throw new java.lang.AssertionError("Can't get here."); } @@ -25573,6 +25663,10 @@ public final class AdminProtos { return org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.UpdateConfigurationResponse.getDefaultInstance(); case 17: return org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.GetRegionLoadResponse.getDefaultInstance(); + case 18: + return org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.GetSpaceQuotaSnapshotsResponse.getDefaultInstance(); + case 19: + return org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.GetSpaceQuotaEnforcementsResponse.getDefaultInstance(); default: throw new java.lang.AssertionError("Can't get here."); } @@ -25863,6 +25957,36 @@ public final class AdminProtos { org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.GetRegionLoadResponse.class, org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.GetRegionLoadResponse.getDefaultInstance())); } + + public void getSpaceQuotaSnapshots( + org.apache.hadoop.hbase.shaded.com.google.protobuf.RpcController controller, + org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.GetSpaceQuotaSnapshotsRequest request, + org.apache.hadoop.hbase.shaded.com.google.protobuf.RpcCallback<org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.GetSpaceQuotaSnapshotsResponse> done) { + channel.callMethod( + getDescriptor().getMethods().get(18), + controller, + request, + org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.GetSpaceQuotaSnapshotsResponse.getDefaultInstance(), + org.apache.hadoop.hbase.shaded.com.google.protobuf.RpcUtil.generalizeCallback( + done, + org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.GetSpaceQuotaSnapshotsResponse.class, + org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.GetSpaceQuotaSnapshotsResponse.getDefaultInstance())); + } + + public void getSpaceQuotaEnforcements( + org.apache.hadoop.hbase.shaded.com.google.protobuf.RpcController controller, + org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.GetSpaceQuotaEnforcementsRequest request, + org.apache.hadoop.hbase.shaded.com.google.protobuf.RpcCallback<org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.GetSpaceQuotaEnforcementsResponse> done) { + channel.callMethod( + getDescriptor().getMethods().get(19), + controller, + request, + org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.GetSpaceQuotaEnforcementsResponse.getDefaultInstance(), + org.apache.hadoop.hbase.shaded.com.google.protobuf.RpcUtil.generalizeCallback( + done, + org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.GetSpaceQuotaEnforcementsResponse.class, + org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.GetSpaceQuotaEnforcementsResponse.getDefaultInstance())); + } } public static BlockingInterface newBlockingStub( @@ -25960,6 +26084,16 @@ public final class AdminProtos { org.apache.hadoop.hbase.shaded.com.google.protobuf.RpcController controller, org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.GetRegionLoadRequest request) throws org.apache.hadoop.hbase.shaded.com.google.protobuf.ServiceException; + + public org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.GetSpaceQuotaSnapshotsResponse getSpaceQuotaSnapshots( + org.apache.hadoop.hbase.shaded.com.google.protobuf.RpcController controller, + org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.GetSpaceQuotaSnapshotsRequest request) + throws org.apache.hadoop.hbase.shaded.com.google.protobuf.ServiceException; + + public org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.GetSpaceQuotaEnforcementsResponse getSpaceQuotaEnforcements( + org.apache.hadoop.hbase.shaded.com.google.protobuf.RpcController controller, + org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.GetSpaceQuotaEnforcementsRequest request) + throws org.apache.hadoop.hbase.shaded.com.google.protobuf.ServiceException; } private static final class BlockingStub implements BlockingInterface { @@ -26184,6 +26318,30 @@ public final class AdminProtos { org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.GetRegionLoadResponse.getDefaultInstance()); } + + public org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.GetSpaceQuotaSnapshotsResponse getSpaceQuotaSnapshots( + org.apache.hadoop.hbase.shaded.com.google.protobuf.RpcController controller, + org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.GetSpaceQuotaSnapshotsRequest request) + throws org.apache.hadoop.hbase.shaded.com.google.protobuf.ServiceException { + return (org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.GetSpaceQuotaSnapshotsResponse) channel.callBlockingMethod( + getDescriptor().getMethods().get(18), + controller, + request, + org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.GetSpaceQuotaSnapshotsResponse.getDefaultInstance()); + } + + + public org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.GetSpaceQuotaEnforcementsResponse getSpaceQuotaEnforcements( + org.apache.hadoop.hbase.shaded.com.google.protobuf.RpcController controller, + org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.GetSpaceQuotaEnforcementsRequest request) + throws org.apache.hadoop.hbase.shaded.com.google.protobuf.ServiceException { + return (org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.GetSpaceQuotaEnforcementsResponse) channel.callBlockingMethod( + getDescriptor().getMethods().get(19), + controller, + request, + org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.GetSpaceQuotaEnforcementsResponse.getDefaultInstance()); + } + } // @@protoc_insertion_point(class_scope:hbase.pb.AdminService) @@ -26389,120 +26547,126 @@ public final class AdminProtos { static { java.lang.String[] descriptorData = { "\n\013Admin.proto\022\010hbase.pb\032\023ClusterStatus.p" + - "roto\032\013HBase.proto\032\tWAL.proto\"[\n\024GetRegio" + - "nInfoRequest\022)\n\006region\030\001 \002(\0132\031.hbase.pb." + - "RegionSpecifier\022\030\n\020compaction_state\030\002 \001(" + - "\010\"\353\001\n\025GetRegionInfoResponse\022)\n\013region_in" + - "fo\030\001 \002(\0132\024.hbase.pb.RegionInfo\022I\n\020compac" + - "tion_state\030\002 \001(\0162/.hbase.pb.GetRegionInf" + - "oResponse.CompactionState\022\024\n\014isRecoverin" + - "g\030\003 \001(\010\"F\n\017CompactionState\022\010\n\004NONE\020\000\022\t\n\005" + - "MINOR\020\001\022\t\n\005MAJOR\020\002\022\023\n\017MAJOR_AND_MINOR\020\003\"", - "P\n\023GetStoreFileRequest\022)\n\006region\030\001 \002(\0132\031" + - ".hbase.pb.RegionSpecifier\022\016\n\006family\030\002 \003(" + - "\014\"*\n\024GetStoreFileResponse\022\022\n\nstore_file\030" + - "\001 \003(\t\"\030\n\026GetOnlineRegionRequest\"D\n\027GetOn" + - "lineRegionResponse\022)\n\013region_info\030\001 \003(\0132" + - "\024.hbase.pb.RegionInfo\"\263\002\n\021OpenRegionRequ" + - "est\022=\n\topen_info\030\001 \003(\0132*.hbase.pb.OpenRe" + - "gionRequest.RegionOpenInfo\022\027\n\017serverStar" + - "tCode\030\002 \001(\004\022\032\n\022master_system_time\030\005 \001(\004\032" + - "\251\001\n\016RegionOpenInfo\022$\n\006region\030\001 \002(\0132\024.hba", - "se.pb.RegionInfo\022\037\n\027version_of_offline_n" + - "ode\030\002 \001(\r\022+\n\rfavored_nodes\030\003 \003(\0132\024.hbase" + - ".pb.ServerName\022#\n\033openForDistributedLogR" + - "eplay\030\004 \001(\010\"\246\001\n\022OpenRegionResponse\022F\n\rop" + - "ening_state\030\001 \003(\0162/.hbase.pb.OpenRegionR" + - "esponse.RegionOpeningState\"H\n\022RegionOpen" + - "ingState\022\n\n\006OPENED\020\000\022\022\n\016ALREADY_OPENED\020\001" + - "\022\022\n\016FAILED_OPENING\020\002\"?\n\023WarmupRegionRequ" + - "est\022(\n\nregionInfo\030\001 \002(\0132\024.hbase.pb.Regio" + - "nInfo\"\026\n\024WarmupRegionResponse\"\313\001\n\022CloseR", - "egionRequest\022)\n\006region\030\001 \002(\0132\031.hbase.pb." + - "RegionSpecifier\022\037\n\027version_of_closing_no" + - "de\030\002 \001(\r\022\036\n\020transition_in_ZK\030\003 \001(\010:\004true" + - "\0220\n\022destination_server\030\004 \001(\0132\024.hbase.pb." + - "ServerName\022\027\n\017serverStartCode\030\005 \001(\004\"%\n\023C" + - "loseRegionResponse\022\016\n\006closed\030\001 \002(\010\"N\n!Cl" + - "oseRegionForSplitOrMergeRequest\022)\n\006regio" + - "n\030\001 \003(\0132\031.hbase.pb.RegionSpecifier\"4\n\"Cl" + - "oseRegionForSplitOrMergeResponse\022\016\n\006clos" + - "ed\030\001 \002(\010\"y\n\022FlushRegionRequest\022)\n\006region", - "\030\001 \002(\0132\031.hbase.pb.RegionSpecifier\022\030\n\020if_" + - "older_than_ts\030\002 \001(\004\022\036\n\026write_flush_wal_m" + - "arker\030\003 \001(\010\"_\n\023FlushRegionResponse\022\027\n\017la" + - "st_flush_time\030\001 \002(\004\022\017\n\007flushed\030\002 \001(\010\022\036\n\026" + - "wrote_flush_wal_marker\030\003 \001(\010\"T\n\022SplitReg" + - "ionRequest\022)\n\006region\030\001 \002(\0132\031.hbase.pb.Re" + - "gionSpecifier\022\023\n\013split_point\030\002 \001(\014\"\025\n\023Sp" + - "litRegionResponse\"`\n\024CompactRegionReques" + - "t\022)\n\006region\030\001 \002(\0132\031.hbase.pb.RegionSpeci" + - "fier\022\r\n\005major\030\002 \001(\010\022\016\n\006family\030\003 \001(\014\"\027\n\025C", - "ompactRegionResponse\"\315\001\n\031UpdateFavoredNo" + - "desRequest\022I\n\013update_info\030\001 \003(\01324.hbase." + - "pb.UpdateFavoredNodesRequest.RegionUpdat" + - "eInfo\032e\n\020RegionUpdateInfo\022$\n\006region\030\001 \002(" + - "\0132\024.hbase.pb.RegionInfo\022+\n\rfavored_nodes" + - "\030\002 \003(\0132\024.hbase.pb.ServerName\".\n\032UpdateFa" + - "voredNodesResponse\022\020\n\010response\030\001 \001(\r\"a\n\010" + - "WALEntry\022\035\n\003key\030\001 \002(\0132\020.hbase.pb.WALKey\022" + - "\027\n\017key_value_bytes\030\002 \003(\014\022\035\n\025associated_c" + - "ell_count\030\003 \001(\005\"\242\001\n\030ReplicateWALEntryReq", - "uest\022!\n\005entry\030\001 \003(\0132\022.hbase.pb.WALEntry\022" + - "\034\n\024replicationClusterId\030\002 \001(\t\022\"\n\032sourceB" + - "aseNamespaceDirPath\030\003 \001(\t\022!\n\031sourceHFile" + - "ArchiveDirPath\030\004 \001(\t\"\033\n\031ReplicateWALEntr" + - "yResponse\"\026\n\024RollWALWriterRequest\"0\n\025Rol" + - "lWALWriterResponse\022\027\n\017region_to_flush\030\001 " + - "\003(\014\"#\n\021StopServerRequest\022\016\n\006reason\030\001 \002(\t" + - "\"\024\n\022StopServerResponse\"\026\n\024GetServerInfoR" + - "equest\"K\n\nServerInfo\022)\n\013server_name\030\001 \002(" + - "\0132\024.hbase.pb.ServerName\022\022\n\nwebui_port\030\002 ", - "\001(\r\"B\n\025GetServerInfoResponse\022)\n\013server_i" + - "nfo\030\001 \002(\0132\024.hbase.pb.ServerInfo\"\034\n\032Updat" + - "eConfigurationRequest\"\035\n\033UpdateConfigura" + - "tionResponse\"?\n\024GetRegionLoadRequest\022\'\n\n" + - "table_name\030\001 \001(\0132\023.hbase.pb.TableName\"C\n" + - "\025GetRegionLoadResponse\022*\n\014region_loads\030\001" + - " \003(\0132\024.hbase.pb.RegionLoad2\203\014\n\014AdminServ" + - "ice\022P\n\rGetRegionInfo\022\036.hbase.pb.GetRegio" + - "nInfoRequest\032\037.hbase.pb.GetRegionInfoRes" + - "ponse\022M\n\014GetStoreFile\022\035.hbase.pb.GetStor", - "eFileRequest\032\036.hbase.pb.GetStoreFileResp" + - "onse\022V\n\017GetOnlineRegion\022 .hbase.pb.GetOn" + - "lineRegionRequest\032!.hbase.pb.GetOnlineRe" + - "gionResponse\022G\n\nOpenRegion\022\033.hbase.pb.Op" + - "enRegionRequest\032\034.hbase.pb.OpenRegionRes" + - "ponse\022M\n\014WarmupRegion\022\035.hbase.pb.WarmupR" + - "egionRequest\032\036.hbase.pb.WarmupRegionResp" + - "onse\022J\n\013CloseRegion\022\034.hbase.pb.CloseRegi" + - "onRequest\032\035.hbase.pb.CloseRegionResponse" + - "\022w\n\032CloseRegionForSplitOrMerge\022+.hbase.p", - "b.CloseRegionForSplitOrMergeRequest\032,.hb" + - "ase.pb.CloseRegionForSplitOrMergeRespons" + - "e\022J\n\013FlushRegion\022\034.hbase.pb.FlushRegionR" + - "equest\032\035.hbase.pb.FlushRegionResponse\022J\n" + - "\013SplitRegion\022\034.hbase.pb.SplitRegionReque" + - "st\032\035.hbase.pb.SplitRegionResponse\022P\n\rCom" + - "pactRegion\022\036.hbase.pb.CompactRegionReque" + - "st\032\037.hbase.pb.CompactRegionResponse\022\\\n\021R" + - "eplicateWALEntry\022\".hbase.pb.ReplicateWAL" + - "EntryRequest\032#.hbase.pb.ReplicateWALEntr", - "yResponse\022Q\n\006Replay\022\".hbase.pb.Replicate" + - "WALEntryRequest\032#.hbase.pb.ReplicateWALE" + - "ntryResponse\022P\n\rRollWALWriter\022\036.hbase.pb" + - ".RollWALWriterRequest\032\037.hbase.pb.RollWAL" + - "WriterResponse\022P\n\rGetServerInfo\022\036.hbase." + - "pb.GetServerInfoRequest\032\037.hbase.pb.GetSe" + - "rverInfoResponse\022G\n\nStopServer\022\033.hbase.p" + - "b.StopServerRequest\032\034.hbase.pb.StopServe" + - "rResponse\022_\n\022UpdateFavoredNodes\022#.hbase." + - "pb.UpdateFavoredNodesRequest\032$.hbase.pb.", - "UpdateFavoredNodesResponse\022b\n\023UpdateConf" + - "iguration\022$.hbase.pb.UpdateConfiguration" + - "Request\032%.hbase.pb.UpdateConfigurationRe" + - "sponse\022P\n\rGetRegionLoad\022\036.hbase.pb.GetRe" + - "gionLoadRequest\032\037.hbase.pb.GetRegionLoad" + + "roto\032\013HBase.proto\032\tWAL.proto\032\013Quota.prot" + + "o\"[\n\024GetRegionInfoRequest\022)\n\006region\030\001 \002(" + + "\0132\031.hbase.pb.RegionSpecifier\022\030\n\020compacti" + + "on_state\030\002 \001(\010\"\353\001\n\025GetRegionInfoResponse" + + "\022)\n\013region_info\030\001 \002(\0132\024.hbase.pb.RegionI" + + "nfo\022I\n\020compaction_state\030\002 \001(\0162/.hbase.pb" + + ".GetRegionInfoResponse.CompactionState\022\024" + + "\n\014isRecovering\030\003 \001(\010\"F\n\017CompactionState\022" + + "\010\n\004NONE\020\000\022\t\n\005MINOR\020\001\022\t\n\005MAJOR\020\002\022\023\n\017MAJOR", + "_AND_MINOR\020\003\"P\n\023GetStoreFileRequest\022)\n\006r" + + "egion\030\001 \002(\0132\031.hbase.pb.RegionSpecifier\022\016" + + "\n\006family\030\002 \003(\014\"*\n\024GetStoreFileResponse\022\022" + + "\n\nstore_file\030\001 \003(\t\"\030\n\026GetOnlineRegionReq" + + "uest\"D\n\027GetOnlineRegionResponse\022)\n\013regio" + + "n_info\030\001 \003(\0132\024.hbase.pb.RegionInfo\"\263\002\n\021O" + + "penRegionRequest\022=\n\topen_info\030\001 \003(\0132*.hb" + + "ase.pb.OpenRegionRequest.RegionOpenInfo\022" + + "\027\n\017serverStartCode\030\002 \001(\004\022\032\n\022master_syste" + + "m_time\030\005 \001(\004\032\251\001\n\016RegionOpenInfo\022$\n\006regio", + "n\030\001 \002(\0132\024.hbase.pb.RegionInfo\022\037\n\027version" + + "_of_offline_node\030\002 \001(\r\022+\n\rfavored_nodes\030" + + "\003 \003(\0132\024.hbase.pb.ServerName\022#\n\033openForDi" + + "stributedLogReplay\030\004 \001(\010\"\246\001\n\022OpenRegionR" + + "esponse\022F\n\ropening_state\030\001 \003(\0162/.hbase.p" + + "b.OpenRegionResponse.RegionOpeningState\"" + + "H\n\022RegionOpeningState\022\n\n\006OPENED\020\000\022\022\n\016ALR" + + "EADY_OPENED\020\001\022\022\n\016FAILED_OPENING\020\002\"?\n\023War" + + "mupRegionRequest\022(\n\nregionInfo\030\001 \002(\0132\024.h" + + "base.pb.RegionInfo\"\026\n\024WarmupRegionRespon", + "se\"\313\001\n\022CloseRegionRequest\022)\n\006region\030\001 \002(" + + "\0132\031.hbase.pb.RegionSpecifier\022\037\n\027version_" + + "of_closing_node\030\002 \001(\r\022\036\n\020transition_in_Z" + + "K\030\003 \001(\010:\004true\0220\n\022destination_server\030\004 \001(" + + "\0132\024.hbase.pb.ServerName\022\027\n\017serverStartCo" + + "de\030\005 \001(\004\"%\n\023CloseRegionResponse\022\016\n\006close" + + "d\030\001 \002(\010\"N\n!CloseRegionForSplitOrMergeReq" + + "uest\022)\n\006region\030\001 \003(\0132\031.hbase.pb.RegionSp" + + "ecifier\"4\n\"CloseRegionForSplitOrMergeRes" + + "ponse\022\016\n\006closed\030\001 \002(\010\"y\n\022FlushRegionRequ", + "est\022)\n\006region\030\001 \002(\0132\031.hbase.pb.RegionSpe" + + "cifier\022\030\n\020if_older_than_ts\030\002 \001(\004\022\036\n\026writ" + + "e_flush_wal_marker\030\003 \001(\010\"_\n\023FlushRegionR" + + "esponse\022\027\n\017last_flush_time\030\001 \002(\004\022\017\n\007flus" + + "hed\030\002 \001(\010\022\036\n\026wrote_flush_wal_marker\030\003 \001(" + + "\010\"T\n\022SplitRegionRequest\022)\n\006region\030\001 \002(\0132" + + "\031.hbase.pb.RegionSpecifier\022\023\n\013split_poin" + + "t\030\002 \001(\014\"\025\n\023SplitRegionResponse\"`\n\024Compac" + + "tRegionRequest\022)\n\006region\030\001 \002(\0132\031.hbase.p" + + "b.RegionSpecifier\022\r\n\005major\030\002 \001(\010\022\016\n\006fami", + "ly\030\003 \001(\014\"\027\n\025CompactRegionResponse\"\315\001\n\031Up" + + "dateFavoredNodesRequest\022I\n\013update_info\030\001" + + " \003(\01324.hbase.pb.UpdateFavoredNodesReques" + + "t.RegionUpdateInfo\032e\n\020RegionUpdateInfo\022$" + + "\n\006region\030\001 \002(\0132\024.hbase.pb.RegionInfo\022+\n\r" + + "favored_nodes\030\002 \003(\0132\024.hbase.pb.ServerNam" + + "e\".\n\032UpdateFavoredNodesResponse\022\020\n\010respo" + + "nse\030\001 \001(\r\"a\n\010WALEntry\022\035\n\003key\030\001 \002(\0132\020.hba" + + "se.pb.WALKey\022\027\n\017key_value_bytes\030\002 \003(\014\022\035\n" + + "\025associated_cell_count\030\003 \001(\005\"\242\001\n\030Replica", + "teWALEntryRequest\022!\n\005entry\030\001 \003(\0132\022.hbase" + + ".pb.WALEntry\022\034\n\024replicationClusterId\030\002 \001" + + "(\t\022\"\n\032sourceBaseNamespaceDirPath\030\003 \001(\t\022!" + + "\n\031sourceHFileArchiveDirPath\030\004 \001(\t\"\033\n\031Rep" + + "licateWALEntryResponse\"\026\n\024RollWALWriterR" + + "equest\"0\n\025RollWALWriterResponse\022\027\n\017regio" + + "n_to_flush\030\001 \003(\014\"#\n\021StopServerRequest\022\016\n" + + "\006reason\030\001 \002(\t\"\024\n\022StopServerResponse\"\026\n\024G" + + "etServerInfoRequest\"K\n\nServerInfo\022)\n\013ser" + + "ver_name\030\001 \002(\0132\024.hbase.pb.ServerName\022\022\n\n", + "webui_port\030\002 \001(\r\"B\n\025GetServerInfoRespons" + + "e\022)\n\013server_info\030\001 \002(\0132\024.hbase.pb.Server" + + "Info\"\034\n\032UpdateConfigurationRequest\"\035\n\033Up" + + "dateConfigurationResponse\"?\n\024GetRegionLo" + + "adRequest\022\'\n\ntable_name\030\001 \001(\0132\023.hbase.pb" + + ".TableName\"C\n\025GetRegionLoadResponse\022*\n\014r" + + "egion_loads\030\001 \003(\0132\024.hbase.pb.RegionLoad2" + + "\346\r\n\014AdminService\022P\n\rGetRegionInfo\022\036.hbas" + + "e.pb.GetRegionInfoRequest\032\037.hbase.pb.Get" + + "RegionInfoResponse\022M\n\014GetStoreFile\022\035.hba", + "se.pb.GetStoreFileRequest\032\036.hbase.pb.Get" + + "StoreFileResponse\022V\n\017GetOnlineRegion\022 .h" + + "base.pb.GetOnlineRegionRequest\032!.hbase.p" + + "b.GetOnlineRegionResponse\022G\n\nOpenRegion\022" + + "\033.hbase.pb.OpenRegionRequest\032\034.hbase.pb." + + "OpenRegionResponse\022M\n\014WarmupRegion\022\035.hba" + + "se.pb.WarmupRegionRequest\032\036.hbase.pb.War" + + "mupRegionResponse\022J\n\013CloseRegion\022\034.hbase" + + ".pb.CloseRegionRequest\032\035.hbase.pb.CloseR" + + "egionResponse\022w\n\032CloseRegionForSplitOrMe", + "rge\022+.hbase.pb.CloseRegionForSplitOrMerg" + + "eRequest\032,.hbase.pb.CloseRegionForSplitO" + + "rMergeResponse\022J\n\013FlushRegion\022\034.hbase.pb" + + ".FlushRegionRequest\032\035.hbase.pb.FlushRegi" + + "onResponse\022J\n\013SplitRegion\022\034.hbase.pb.Spl" + + "itRegionRequest\032\035.hbase.pb.SplitRegionRe" + + "sponse\022P\n\rCompactRegion\022\036.hbase.pb.Compa" + + "ctRegionRequest\032\037.hbase.pb.CompactRegion" + + "Response\022\\\n\021ReplicateWALEntry\022\".hbase.pb" + + ".ReplicateWALEntryRequest\032#.hbase.pb.Rep", + "licateWALEntryResponse\022Q\n\006Replay\022\".hbase" + + ".pb.ReplicateWALEntryRequest\032#.hbase.pb." + + "ReplicateWALEntryResponse\022P\n\rRollWALWrit" + + "er\022\036.hbase.pb.RollWALWriterRequest\032\037.hba" + + "se.pb.RollWALWriterResponse\022P\n\rGetServer" + + "Info\022\036.hbase.pb.GetServerInfoRequest\032\037.h" + + "base.pb.GetServerInfoResponse\022G\n\nStopSer" + + "ver\022\033.hbase.pb.StopServerRequest\032\034.hbase" + + ".pb.StopServerResponse\022_\n\022UpdateFavoredN" + + "odes\022#.hbase.pb.UpdateFavoredNodesReques", + "t\032$.hbase.pb.UpdateFavoredNodesResponse\022" + + "b\n\023UpdateConfiguration\022$.hbase.pb.Update" + + "ConfigurationRequest\032%.hbase.pb.UpdateCo" + + "nfigurationResponse\022P\n\rGetRegionLoad\022\036.h" + + "base.pb.GetRegionLoadRequest\032\037.hbase.pb." + + "GetRegionLoadResponse\022k\n\026GetSpaceQuotaSn" + + "apshots\022\'.hbase.pb.GetSpaceQuotaSnapshot" + + "sRequest\032(.hbase.pb.GetSpaceQuotaSnapsho" + + "tsResponse\022t\n\031GetSpaceQuotaEnforcements\022" + + "*.hbase.pb.GetSpaceQuotaEnforcementsRequ", + "est\032+.hbase.pb.GetSpaceQuotaEnforcements" + "ResponseBH\n1org.apache.hadoop.hbase.shad" + "ed.protobuf.generatedB\013AdminProtosH\001\210\001\001\240" + "\001\001" @@ -26521,6 +26685,7 @@ public final class AdminProtos { org.apache.hadoop.hbase.shaded.protobuf.generated.ClusterStatusProtos.getDescriptor(), org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.getDescriptor(), org.apache.hadoop.hbase.shaded.protobuf.generated.WALProtos.getDescriptor(), + org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.getDescriptor(), }, assigner); internal_static_hbase_pb_GetRegionInfoRequest_descriptor = getDescriptor().getMessageTypes().get(0); @@ -26753,6 +26918,7 @@ public final class AdminProtos { org.apache.hadoop.hbase.shaded.protobuf.generated.ClusterStatusProtos.getDescriptor(); org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.getDescriptor(); org.apache.hadoop.hbase.shaded.protobuf.generated.WALProtos.getDescriptor(); + org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.getDescriptor(); } // @@protoc_insertion_point(outer_class_scope) http://git-wip-us.apache.org/repos/asf/hbase/blob/a1ffeea4/hbase-protocol-shaded/src/main/java/org/apache/hadoop/hbase/shaded/protobuf/generated/MasterProtos.java ---------------------------------------------------------------------- diff --git a/hbase-protocol-shaded/src/main/java/org/apache/hadoop/hbase/shaded/protobuf/generated/MasterProtos.java b/hbase-protocol-shaded/src/main/java/org/apache/hadoop/hbase/shaded/protobuf/generated/MasterProtos.java index 3c78980..d685c4f 100644 --- a/hbase-protocol-shaded/src/main/java/org/apache/hadoop/hbase/shaded/protobuf/generated/MasterProtos.java +++ b/hbase-protocol-shaded/src/main/java/org/apache/hadoop/hbase/shaded/protobuf/generated/MasterProtos.java @@ -63752,7 +63752,7 @@ public final class MasterProtos { * <code>optional .hbase.pb.SpaceLimitRequest space_limit = 8;</code> */ private org.apache.hadoop.hbase.shaded.com.google.protobuf.SingleFieldBuilderV3< - org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.SpaceLimitRequest, org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.SpaceLimitRequest.Builder, org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.SpaceLimitRequestOrBuilder> + org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.SpaceLimitRequest, org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.SpaceLimitRequest.Builder, org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.SpaceLimitRequestOrBuilder> getSpaceLimitFieldBuilder() { if (spaceLimitBuilder_ == null) { spaceLimitBuilder_ = new org.apache.hadoop.hbase.shaded.com.google.protobuf.SingleFieldBuilderV3< @@ -71159,6 +71159,18 @@ public final class MasterProtos { org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.RemoveDrainFromRegionServersRequest request, org.apache.hadoop.hbase.shaded.com.google.protobuf.RpcCallback<org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.RemoveDrainFromRegionServersResponse> done); + /** + * <pre> + ** Fetches the Master's view of space quotas + * </pre> + * + * <code>rpc GetSpaceQuotaRegionSizes(.hbase.pb.GetSpaceQuotaRegionSizesRequest) returns (.hbase.pb.GetSpaceQuotaRegionSizesResponse);</code> + */ + public abstract void getSpaceQuotaRegionSizes( + org.apache.hadoop.hbase.shaded.com.google.protobuf.RpcController controller, + org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.GetSpaceQuotaRegionSizesRequest request, + org.apache.hadoop.hbase.shaded.com.google.protobuf.RpcCallback<org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.GetSpaceQuotaRegionSizesResponse> done); + } public static org.apache.hadoop.hbase.shaded.com.google.protobuf.Service newReflectiveService( @@ -71724,6 +71736,14 @@ public final class MasterProtos { impl.removeDrainFromRegionServers(controller, request, done); } + @java.lang.Override + public void getSpaceQuotaRegionSizes( + org.apache.hadoop.hbase.shaded.com.google.protobuf.RpcController controller, + org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.GetSpaceQuotaRegionSizesRequest request, + org.apache.hadoop.hbase.shaded.com.google.protobuf.RpcCallback<org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.GetSpaceQuotaRegionSizesResponse> done) { + impl.getSpaceQuotaRegionSizes(controller, request, done); + } + }; } @@ -71886,6 +71906,8 @@ public final class MasterProtos { return impl.drainRegionServers(controller, (org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.DrainRegionServersRequest)request); case 69: return impl.removeDrainFromRegionServers(controller, (org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.RemoveDrainFromRegionServersRequest)request); + case 70: + return impl.getSpaceQuotaRegionSizes(controller, (org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.GetSpaceQuotaRegionSizesRequest)request); default: throw new java.lang.AssertionError("Can't get here."); } @@ -72040,6 +72062,8 @@ public final class MasterProtos { return org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.DrainRegionServersRequest.getDefaultInstance(); case 69: return org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.RemoveDrainFromRegionServersRequest.getDefaultInstance(); + case 70: + return org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.GetSpaceQuotaRegionSizesRequest.getDefaultInstance(); default: throw new java.lang.AssertionError("Can't get here."); } @@ -72194,6 +72218,8 @@ public final class MasterProtos { return org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.DrainRegionServersResponse.getDefaultInstance(); case 69: return org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.RemoveDrainFromRegionServersResponse.getDefaultInstance(); + case 70: + return org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.GetSpaceQuotaRegionSizesResponse.getDefaultInstance(); default: throw new java.lang.AssertionError("Can't get here."); } @@ -73073,6 +73099,18 @@ public final class MasterProtos { org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.RemoveDrainFromRegionServersRequest request, org.apache.hadoop.hbase.shaded.com.google.protobuf.RpcCallback<org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.RemoveDrainFromRegionServersResponse> done); + /** + * <pre> + ** Fetches the Master's view of space quotas + * </pre> + * + * <code>rpc GetSpaceQuotaRegionSizes(.hbase.pb.GetSpaceQuotaRegionSizesRequest) returns (.hbase.pb.GetSpaceQuotaRegionSizesResponse);</code> + */ + public abstract void getSpaceQuotaRegionSizes( + org.apache.hadoop.hbase.shaded.com.google.protobuf.RpcController controller, + org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.GetSpaceQuotaRegionSizesRequest request, + org.apache.hadoop.hbase.shaded.com.google.protobuf.RpcCallback<org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.GetSpaceQuotaRegionSizesResponse> done); + public static final org.apache.hadoop.hbase.shaded.com.google.protobuf.Descriptors.ServiceDescriptor getDescriptor() { @@ -73445,6 +73483,11 @@ public final class MasterProtos { org.apache.hadoop.hbase.shaded.com.google.protobuf.RpcUtil.<org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.RemoveDrainFromRegionServersResponse>specializeCallback( done)); return; + case 70: + this.getSpaceQuotaRegionSizes(controller, (org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.GetSpaceQuotaRegionSizesRequest)request, + org.apache.hadoop.hbase.shaded.com.google.protobuf.RpcUtil.<org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.GetSpaceQuotaRegionSizesResponse>specializeCallback( + done)); + return; default: throw new java.lang.AssertionError("Can't get here."); } @@ -73599,6 +73642,8 @@ public final class MasterProtos { return org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.DrainRegionServersRequest.getDefaultInstance(); case 69: return org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.RemoveDrainFromRegionServersRequest.getDefaultInstance(); + case 70: + return org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.GetSpaceQuotaRegionSizesRequest.getDefaultInstance(); default: throw new java.lang.AssertionError("Can't get here."); } @@ -73753,6 +73798,8 @@ public final class MasterProtos { return org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.DrainRegionServersResponse.getDefaultInstance(); case 69: return org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.RemoveDrainFromRegionServersResponse.getDefaultInstance(); + case 70: + return org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.GetSpaceQuotaRegionSizesResponse.getDefaultInstance(); default: throw new java.lang.AssertionError("Can't get here."); } @@ -74823,6 +74870,21 @@ public final class MasterProtos { org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.RemoveDrainFromRegionServersResponse.class, org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.RemoveDrainFromRegionServersResponse.getDefaultInstance())); } + + public void getSpaceQuotaRegionSizes( + org.apache.hadoop.hbase.shaded.com.google.protobuf.RpcController controller, + org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.GetSpaceQuotaRegionSizesRequest request, + org.apache.hadoop.hbase.shaded.com.google.protobuf.RpcCallback<org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.GetSpaceQuotaRegionSizesResponse> done) { + channel.callMethod( + getDescriptor().getMethods().get(70), + controller, + request, + org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.GetSpaceQuotaRegionSizesResponse.getDefaultInstance(), + org.apache.hadoop.hbase.shaded.com.google.protobuf.RpcUtil.generalizeCallback( + done, + org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.GetSpaceQuotaRegionSizesResponse.class, + org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.GetSpaceQuotaRegionSizesResponse.getDefaultInstance())); + } } public static BlockingInterface newBlockingStub( @@ -75180,6 +75242,11 @@ public final class MasterProtos { org.apache.hadoop.hbase.shaded.com.google.protobuf.RpcController controller, org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.RemoveDrainFromRegionServersRequest request) throws org.apache.hadoop.hbase.shaded.com.google.protobuf.ServiceException; + + public org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.GetSpaceQuotaRegionSizesResponse getSpaceQuotaRegionSizes( + org.apache.hadoop.hbase.shaded.com.google.protobuf.RpcController controller, + org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.GetSpaceQuotaRegionSizesRequest request) + throws org.apache.hadoop.hbase.shaded.com.google.protobuf.ServiceException; } private static final class BlockingStub implements BlockingInterface { @@ -76028,6 +76095,18 @@ public final class MasterProtos { org.apache.hadoop.hbase.shaded.protobuf.generated.MasterProtos.RemoveDrainFromRegionServersResponse.getDefaultInstance()); } + + public org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.GetSpaceQuotaRegionSizesResponse getSpaceQuotaRegionSizes( + org.apache.hadoop.hbase.shaded.com.google.protobuf.RpcController controller, + org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.GetSpaceQuotaRegionSizesRequest request) + throws org.apache.hadoop.hbase.shaded.com.google.protobuf.ServiceException { + return (org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.GetSpaceQuotaRegionSizesResponse) channel.callBlockingMethod( + getDescriptor().getMethods().get(70), + controller, + request, + org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.GetSpaceQuotaRegionSizesResponse.getDefaultInstance()); + } + } // @@protoc_insertion_point(class_scope:hbase.pb.MasterService) @@ -76869,7 +76948,7 @@ public final class MasterProtos { "ainFromRegionServersRequest\022)\n\013server_na", "me\030\001 \003(\0132\024.hbase.pb.ServerName\"&\n$Remove" + "DrainFromRegionServersResponse*(\n\020Master" + - "SwitchType\022\t\n\005SPLIT\020\000\022\t\n\005MERGE\020\0012\3013\n\rMas" + + "SwitchType\022\t\n\005SPLIT\020\000\022\t\n\005MERGE\020\0012\2644\n\rMas" + "terService\022e\n\024GetSchemaAlterStatus\022%.hba" + "se.pb.GetSchemaAlterStatusRequest\032&.hbas" + "e.pb.GetSchemaAlterStatusResponse\022b\n\023Get" + @@ -77034,9 +77113,12 @@ public final class MasterProtos { "RegionServersResponse\022}\n\034removeDrainFrom" + "RegionServers\022-.hbase.pb.RemoveDrainFrom" + "RegionServersRequest\032..hbase.pb.RemoveDr" + - "ainFromRegionServersResponseBI\n1org.apac" + - "he.hadoop.hbase.shaded.protobuf.generate" + - "dB\014MasterProtosH\001\210\001\001\240\001\001" + "ainFromRegionServersResponse\022q\n\030GetSpace" + + "QuotaRegionSizes\022).hbase.pb.GetSpaceQuot" + + "aRegionSizesRequest\032*.hbase.pb.GetSpaceQ", + "uotaRegionSizesResponseBI\n1org.apache.ha" + + "doop.hbase.shaded.protobuf.generatedB\014Ma" + + "sterProtosH\001\210\001\001\240\001\001" }; org.apache.hadoop.hbase.shaded.com.google.protobuf.Descriptors.FileDescriptor.InternalDescriptorAssigner assigner = new org.apache.hadoop.hbase.shaded.com.google.protobuf.Descriptors.FileDescriptor. InternalDescriptorAssigner() {