@@ -109,9 +109,7 @@ public class StatsUtil {
109109 private static final FromGlobalStreamIdTransformer FROM_GSID = new FromGlobalStreamIdTransformer ();
110110
111111
112- // =====================================================================================
113112 // aggregation stats methods
114- // =====================================================================================
115113
116114 /**
117115 * Aggregates number executed, process latency, and execute latency across all streams.
@@ -1315,9 +1313,7 @@ public static List<WorkerSummary> aggWorkerStats(String stormId, String stormNam
13151313 return new ArrayList <WorkerSummary >(workerSummaryMap .values ());
13161314 }
13171315
1318- // =====================================================================================
13191316 // convert thrift stats to java maps
1320- // =====================================================================================
13211317
13221318 /**
13231319 * convert thrift executor heartbeats into a java HashMap.
@@ -1478,9 +1474,7 @@ public static List<Map<String, Object>> extractNodeInfosFromHbForComp(
14781474 }
14791475
14801476
1481- // =====================================================================================
14821477 // heartbeats related
1483- // =====================================================================================
14841478
14851479 /**
14861480 * extracts a list of executor data from heart beats.
@@ -1873,9 +1867,7 @@ private static <K> Map<String, Map<K, List>> mergeWithAddPair(Map<String, Map<K,
18731867 return ret ;
18741868 }
18751869
1876- // =====================================================================================
18771870 // thriftify stats methods
1878- // =====================================================================================
18791871
18801872 /**
18811873 * Used for local test.
@@ -2089,9 +2081,7 @@ private static ExecutorSpecificStats thriftifySpecificStats(Map stats) {
20892081 }
20902082
20912083
2092- // =====================================================================================
20932084 // helper methods
2094- // =====================================================================================
20952085
20962086 private static GlobalStreamId toGlobalStreamId (List list ) {
20972087 return new GlobalStreamId ((String ) list .get (0 ), (String ) list .get (1 ));
@@ -2352,9 +2342,7 @@ private static ErrorInfo getLastError(IStormClusterState stormClusterState, Stri
23522342 }
23532343
23542344
2355- // =====================================================================================
23562345 // key transformers
2357- // =====================================================================================
23582346
23592347 public static <K > Map windowSetConverter (Map stats , ClientStatsUtil .KeyTransformer <K > firstKeyFunc ) {
23602348 return ClientStatsUtil .windowSetConverter (stats , ClientStatsUtil .IDENTITY , firstKeyFunc );
0 commit comments