[hbase] 02/02: HBASE-25469 Add detailed RIT info in JSON format for consumption as metrics (#3555)

[apurtell]

This is an automated email from the ASF dual-hosted git repository.

apurtell pushed a commit to branch branch-2.4
in repository https://gitbox.apache.org/repos/asf/hbase.git

commit 428cff499ddf038b9c10f252a5132308d7a1cd73
Author: caroliney14 <carolinez...@berkeley.edu>
AuthorDate: Wed Aug 4 18:04:44 2021 -0700

    HBASE-25469 Add detailed RIT info in JSON format for consumption as metrics 
(#3555)
    
    Signed-off-by: Andrew Purtell <apurt...@apache.org>
    Signed-off-by: Bharath Vissapragada <bhara...@apache.org>
---
 .../main/resources/hbase-webapps/master/rits.jsp   | 42 ++++++++++++++++++++--
 1 file changed, 40 insertions(+), 2 deletions(-)

diff --git a/hbase-server/src/main/resources/hbase-webapps/master/rits.jsp 
b/hbase-server/src/main/resources/hbase-webapps/master/rits.jsp
index 17d0090..3fc960e 100644
--- a/hbase-server/src/main/resources/hbase-webapps/master/rits.jsp
+++ b/hbase-server/src/main/resources/hbase-webapps/master/rits.jsp
@@ -21,11 +21,17 @@
          import="static org.apache.commons.lang3.StringEscapeUtils.escapeXml"
          import="java.util.Collections"
          import="java.util.Comparator"
+         import="java.util.ArrayList"
          import="java.util.List"
+         import="java.util.HashMap"
+         import="java.util.Map"
          import="java.util.stream.Collectors"
          import="org.apache.hadoop.hbase.master.HMaster"
+         import="org.apache.hadoop.hbase.master.RegionState"
          import="org.apache.hadoop.hbase.master.assignment.RegionStateNode"
          
import="org.apache.hadoop.hbase.master.assignment.TransitRegionStateProcedure"
+         import="org.apache.hadoop.hbase.util.GsonUtil"
+         import="org.apache.hbase.thirdparty.com.google.gson.Gson"
 %>
 <%
     HMaster master = (HMaster) 
getServletContext().getAttribute(HMaster.MASTER);
@@ -69,6 +75,7 @@
         <div class="page-header">
             <a 
href="/rits.jsp?format=txt&filter=region&table=<%=table%>&state=<%=state%>" 
class="btn btn-primary">Regions in text format</a>
             <a 
href="/rits.jsp?format=txt&filter=procedure&table=<%=table%>&state=<%=state%>" 
class="btn btn-info">Procedures in text format</a>
+            <a href="/rits.jsp?format=json&table=<%=table%>&state=<%=state%>" 
class="btn btn-info">RIT info as JSON</a>
             <p>regions and procedures in text format can be copied and passed 
to command-line utils such as hbck2</p>
         </div>
     </div>
@@ -79,14 +86,18 @@
                 <th>Region</th>
                 <th>Table</th>
                 <th>RegionState</th>
+                <th>Server</th>
                 <th>Procedure</th>
                 <th>ProcedureState</th>
+                <th>Start Time</th>
+                <th>Duration (ms)</th>
             </tr>
             <% for (RegionStateNode regionStateNode : rit) { %>
             <tr>
                 <td><%= regionStateNode.getRegionInfo().getEncodedName() 
%></td>
                 <td><%= regionStateNode.getRegionInfo().getTable() %></td>
                 <td><%= regionStateNode.getState() %></td>
+                <td><%= regionStateNode.getRegionLocation().getServerName() 
%></td>
                 <%
                     TransitRegionStateProcedure procedure = 
regionStateNode.getProcedure();
 
@@ -98,6 +109,10 @@
                     <td><%= procedure.getProcId() %></td>
                     <td><%= escapeXml(procedure.getState().toString() + 
(procedure.isBypass() ? "(Bypassed)" : "")) %></td>
                 <% } %>
+
+                <% RegionState rs = regionStateNode.toRegionState(); %>
+                <td><%= rs.getStamp() %></td>
+                <td><%= System.currentTimeMillis() - rs.getStamp() %></td>
             </tr>
             <% } %>
             <p><%= rit.size() %> region(s) in transition.</p>
@@ -107,7 +122,30 @@
     <% } %>
 </div>
 <jsp:include page="footer.jsp" />
-
+<% } else if (format.equals("json")) { %>
+<%
+    Gson GSON = GsonUtil.createGson().create();
+    Map<String, List<Map<String, Object>>> map = new HashMap<>();
+    List<Map<String, Object>> rits = new ArrayList<>();
+    map.put("rits", rits);
+    for (RegionStateNode regionStateNode : rit) {
+        Map<String, Object> r = new HashMap<>();
+        r.put("region", regionStateNode.getRegionInfo().getEncodedName());
+        r.put("table", 
regionStateNode.getRegionInfo().getTable().getNameAsString());
+        r.put("state", regionStateNode.getState());
+        r.put("server", regionStateNode.getRegionLocation().getServerName());
+        TransitRegionStateProcedure procedure = regionStateNode.getProcedure();
+        if (procedure != null) {
+          r.put("procedureId", procedure.getProcId());
+          r.put("procedureState", procedure.getState().toString());
+        }
+        RegionState rs = regionStateNode.toRegionState();
+        r.put("startTime", rs.getStamp());
+        r.put("duration", System.currentTimeMillis() - rs.getStamp());
+        rits.add(r);
+      }
+    %>
+    <%= GSON.toJson(map) %>
 <% } else { %>
 <div class="container-fluid content">
     <div class="row">
@@ -127,4 +165,4 @@
         </p>
     </div>
 </div>
-<% } %>
\ No newline at end of file
+<% } %>