HBASE-22878 Show table throttle quotas in table jsp

Author: mymeiyi

hbase-client/src/main/java/org/apache/hadoop/hbase/quotas/ThrottleSettings.java

@@ -32,7 +32,7 @@
 
 @InterfaceAudience.Private
 @InterfaceStability.Evolving
-class ThrottleSettings extends QuotaSettings {
+public class ThrottleSettings extends QuotaSettings {
   final QuotaProtos.ThrottleRequest proto;
 
   ThrottleSettings(final String userName, final TableName tableName, final String namespace,

hbase-server/src/main/resources/hbase-webapps/master/table.jsp

@@ -20,14 +20,13 @@
 <%@page import="java.net.URLEncoder"%>
 <%@ page contentType="text/html;charset=UTF-8"
   import="static org.apache.commons.lang3.StringEscapeUtils.escapeXml"
+  import="java.io.IOException"
   import="java.util.ArrayList"
   import="java.util.Collection"
-  import="java.util.Collections"
   import="java.util.HashMap"
   import="java.util.LinkedHashMap"
   import="java.util.List"
   import="java.util.Map"
-  import="java.util.Objects"
   import="java.util.TreeMap"
   import=" java.util.concurrent.TimeUnit"
   import="org.apache.commons.lang3.StringEscapeUtils"
@@ -51,8 +50,12 @@
   import="org.apache.hadoop.hbase.master.HMaster"
   import="org.apache.hadoop.hbase.master.assignment.RegionStates"
   import="org.apache.hadoop.hbase.master.RegionState"
+  import="org.apache.hadoop.hbase.quotas.QuotaFilter"
+  import="org.apache.hadoop.hbase.quotas.QuotaRetriever"
+  import="org.apache.hadoop.hbase.quotas.QuotaSettings"
   import="org.apache.hadoop.hbase.quotas.QuotaTableUtil"
   import="org.apache.hadoop.hbase.quotas.SpaceQuotaSnapshot"
+  import="org.apache.hadoop.hbase.quotas.ThrottleSettings"
   import="org.apache.hadoop.hbase.util.Bytes"
   import="org.apache.hadoop.hbase.util.FSUtils"
   import="org.apache.hadoop.hbase.zookeeper.MetaTableLocator"
@@ -77,6 +80,20 @@
                     setType(HBaseProtos.RegionSpecifier.RegionSpecifierType.REGION_NAME).
                     setValue(ByteString.copyFrom(regionInfo.getRegionName())).build()).build());
   }
+
+  private List<ThrottleSettings> getThrottles(Configuration conf, QuotaFilter filter)
+    throws IOException {
+    List<ThrottleSettings> throttles = new ArrayList<>();
+    try (QuotaRetriever scanner = QuotaRetriever.open(conf, filter)) {
+      for (QuotaSettings quota : scanner) {
+        if (quota instanceof ThrottleSettings) {
+          ThrottleSettings throttle = (ThrottleSettings) quota;
+          throttles.add(throttle);
+        }
+      }
+    }
+    return throttles;
+  }
 %>
 <%
   HMaster master = (HMaster)getServletContext().getAttribute(HMaster.MASTER);
@@ -356,6 +373,37 @@ if (fqtn != null && master.isInitialized()) {
     </td>
     <td>Information about a Space Quota on this table, if set.</td>
   </tr>
+<%
+    }
+
+    List<ThrottleSettings> throttles = new ArrayList<>();
+    throttles.addAll(getThrottles(conf, new QuotaFilter().setTableFilter(tn.getNameAsString())));
+    throttles.addAll(getThrottles(conf, new QuotaFilter().setUserFilter(".*")
+      .setTableFilter(tn.getNameAsString())));
+    if (throttles.size() > 0) {
+%>
+  <tr>
+    <td>Throttle Quota</td>
+    <td>
+      <table>
+        <tr>
+          <th>User</th>
+          <th>Throttle</th>
+        </tr>
+<%
+    for (ThrottleSettings throttle : throttles) {
+%>
+        <tr>
+          <td><%= throttle.getUserName() == null ? "" : throttle.getUserName()%></td>
+          <td><%= throttle.toString() %></td>
+        </tr>
+<%
+    }
+%>
+      </table>
+    </td>
+    <td>Information about a Throttle Quota on this table, if set.</td>
+  </tr>
 <%
     }
   }