Github user revans2 commented on a diff in the pull request:
https://github.com/apache/storm/pull/2828#discussion_r217176027
--- Diff:
storm-webapp/src/main/java/org/apache/storm/daemon/ui/UIHelpers.java ---
@@ -1540,6 +1737,37 @@ public static String getWorkerDumpLink(String host,
long port, String topologyId
}
+ public static Map<String, Object> unpackBoltPageInfo(ComponentPageInfo
componentPageInfo,
+ String
topologyId, String window, boolean sys,
+ Map config) {
+ Map<String, Object> result = new HashMap();
+
+ result.put("boltStats",
componentPageInfo.get_window_to_stats().entrySet().stream().map(
+ e -> getBoltAggStatsMap(e.getValue(),
e.getKey())).collect(Collectors.toList()));
--- End diff --
1746: 'lambda arguments' has incorrect indentation level 16, expected level
should be 12.
---
