Github user revans2 commented on a diff in the pull request: https://github.com/apache/storm/pull/2828#discussion_r217176165 --- 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())); + result.put("inputStats", componentPageInfo.get_gsid_to_input_stats().entrySet().stream().map( + e -> getBoltInputStats(e.getKey(), e.getValue())).collect(Collectors.toList())); + result.put("outputStats", componentPageInfo.get_sid_to_output_stats().entrySet().stream().map( + e -> getBoltOutputStats(e.getKey(), e.getValue())).collect(Collectors.toList())); --- End diff -- 1750: 'lambda arguments' has incorrect indentation level 16, expected level should be 12.
---