Github user revans2 commented on a diff in the pull request:
https://github.com/apache/storm/pull/2385#discussion_r149164648
--- Diff:
storm-server/src/main/java/org/apache/storm/scheduler/resource/ResourceUtils.java
---
@@ -238,4 +277,57 @@ public static double sum(Collection<Double> list) {
public static double avg(Collection<Double> list) {
return sum(list) / list.size();
}
+
+ /**
+ * Normalizes a supervisor resource map or topology details map's keys
to universal resource names.
+ * @param resourceMap resource map of either Supervisor or Topology
+ * @return the resource map with common resource names
+ */
+ public static Map<String, Double> normalizedResourceMap(Map<String,
Double> resourceMap) {
+ Map<String, Double> result = new HashMap();
+
+ result.putAll(resourceMap);
+ for(Map.Entry entry: resourceMap.entrySet()) {
--- End diff --
nit: space after the for.
---