Skip to content

Commit 1616d2e

Browse files
author
Ray Mattingly
committed
rsOperationDetails UI fixes
1 parent db79ecf commit 1616d2e

3 files changed

Lines changed: 15 additions & 6 deletions

File tree

hbase-client/src/main/java/org/apache/hadoop/hbase/client/OnlineLogRecord.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -378,7 +378,7 @@ public String toString() {
378378
.append("connectionAttributes", connectionAttributes).toString();
379379
}
380380

381-
public static Map<String, String> deserializeAttributes(Map<String, byte[]> attributes) {
381+
private static Map<String, String> deserializeAttributes(Map<String, byte[]> attributes) {
382382
return attributes.entrySet().stream().collect(
383383
Collectors.toMap(Map.Entry::getKey, entry -> Bytes.toStringBinary(entry.getValue())));
384384
}

hbase-client/src/main/java/org/apache/hadoop/hbase/shaded/protobuf/ProtobufUtil.java

Lines changed: 9 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -2196,6 +2196,15 @@ public static SlowLogParams getSlowLogParams(Message message, boolean slowLogSca
21962196
return new SlowLogParams(params);
21972197
}
21982198

2199+
public static Map<String, String> deserializeAttributes(List<NameBytesPair> attributes) {
2200+
return deserializeAttributes(convertNameBytesPairsToMap(attributes));
2201+
}
2202+
2203+
public static Map<String, String> deserializeAttributes(Map<String, byte[]> attributes) {
2204+
return attributes.entrySet().stream().collect(
2205+
Collectors.toMap(Map.Entry::getKey, entry -> Bytes.toStringBinary(entry.getValue())));
2206+
}
2207+
21992208
/**
22002209
* Print out some subset of a MutationProto rather than all of it and its data
22012210
* @param proto Protobuf to print out

hbase-server/src/main/resources/hbase-webapps/regionserver/rsOperationDetails.jsp

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -25,8 +25,8 @@
2525
import="org.apache.hadoop.util.StringUtils"
2626
import="org.apache.hadoop.hbase.regionserver.HRegionServer"
2727
import="org.apache.hadoop.hbase.HConstants"
28-
import="org.apache.hadoop.hbase.client.OnlineLogRecord.deserializeAttributes"
2928
import="org.apache.hadoop.hbase.shaded.protobuf.generated.TooSlowLog"
29+
import="org.apache.hadoop.hbase.shaded.protobuf.ProtobufUtil"
3030
import="org.apache.hadoop.hbase.namequeues.NamedQueueRecorder"
3131
import="org.apache.hadoop.hbase.namequeues.RpcLogDetails"
3232
import="org.apache.hadoop.hbase.namequeues.request.NamedQueueGetRequest"
@@ -130,8 +130,8 @@
130130
<td><%=r.getMultiServiceCalls()%></td>
131131
<td><%=r.getCallDetails()%></td>
132132
<td><%=r.getParam()%></td>
133-
<td><%=deserializeAttributes(r.getRequestAttributes())%></td>
134-
<td><%=deserializeAttributes(r.getConnectionAttributes())%></td>
133+
<td><%=ProtobufUtil.deserializeAttributes(r.getRequestAttributeList())%></td>
134+
<td><%=ProtobufUtil.deserializeAttributes(r.getConnectionAttributeList())%></td>
135135
</tr>
136136
<% } %>
137137
<% } %>
@@ -177,8 +177,8 @@
177177
<td><%=r.getMultiServiceCalls()%></td>
178178
<td><%=r.getCallDetails()%></td>
179179
<td><%=r.getParam()%></td>
180-
<td><%=deserializeAttributes(r.getRequestAttributes())%></td>
181-
<td><%=deserializeAttributes(r.getConnectionAttributes())%></td>
180+
<td><%=ProtobufUtil.deserializeAttributes(r.getRequestAttributeList())%></td>
181+
<td><%=ProtobufUtil.deserializeAttributes(r.getConnectionAttributeList())%></td>
182182
</tr>
183183
<% } %>
184184
<% } %>

0 commit comments

Comments
 (0)