Github user revans2 commented on a diff in the pull request:
https://github.com/apache/storm/pull/2828#discussion_r217176354
--- 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()));
+ result.put("executorStats",
componentPageInfo.get_exec_stats().stream().map(
+ e -> getBoltExecutorStats(topologyId, config,
e)).collect(Collectors.toList()));
+ result.putAll(getComponentErrors(componentPageInfo.get_errors(),
topologyId, config));
+ return result;
+ }
+
+ public static Map<String, Object>
unpackSpoutPageInfo(ComponentPageInfo componentPageInfo,
+ String
topologyId, String window, boolean sys,
+ Map config) {
+ Map<String, Object> result = new HashMap();
+ result.put("spoutSummary",
componentPageInfo.get_window_to_stats().entrySet().stream().map(
+ e -> getSpoutAggStatsMap(e.getValue(),
e.getKey())).collect(Collectors.toList()));
+ result.put("outputStats",
componentPageInfo.get_sid_to_output_stats().entrySet().stream().map(
+ e -> getSpoutOutputStats(e.getKey(),
e.getValue())).collect(Collectors.toList()));
--- End diff --
1764: 'lambda arguments' has incorrect indentation level 16, expected level
should be 12.
---
