[ambari-metrics] branch master updated: AMBARI-25984: Ambari metrics summary API missing daily aggregator info (#122)

[vishalsuvagia]

This is an automated email from the ASF dual-hosted git repository.

vishalsuvagia pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/ambari-metrics.git


The following commit(s) were added to refs/heads/master by this push:
     new 2c9e5e5  AMBARI-25984: Ambari metrics summary API missing daily 
aggregator info (#122)
2c9e5e5 is described below

commit 2c9e5e599239d08de20b21b1b38189056337450a
Author: Mohammad Arshad <ars...@apache.org>
AuthorDate: Mon Aug 14 14:12:07 2023 +0530

    AMBARI-25984: Ambari metrics summary API missing daily aggregator info 
(#122)
---
 .../core/timeline/availability/MetricCollectorHAController.java   | 8 ++++++--
 1 file changed, 6 insertions(+), 2 deletions(-)

diff --git 
a/ambari-metrics-timelineservice/src/main/java/org/apache/ambari/metrics/core/timeline/availability/MetricCollectorHAController.java
 
b/ambari-metrics-timelineservice/src/main/java/org/apache/ambari/metrics/core/timeline/availability/MetricCollectorHAController.java
index a27d13a..a5d4318 100644
--- 
a/ambari-metrics-timelineservice/src/main/java/org/apache/ambari/metrics/core/timeline/availability/MetricCollectorHAController.java
+++ 
b/ambari-metrics-timelineservice/src/main/java/org/apache/ambari/metrics/core/timeline/availability/MetricCollectorHAController.java
@@ -22,7 +22,7 @@ import static 
org.apache.helix.model.IdealState.RebalanceMode.FULL_AUTO;
 
 import java.util.ArrayList;
 import java.util.Date;
-import java.util.HashMap;
+import java.util.LinkedHashMap;
 import java.util.List;
 import java.util.Map;
 import java.util.TreeSet;
@@ -296,7 +296,7 @@ public class MetricCollectorHAController {
   }
 
   public Map<String, String> getAggregationSummary() {
-    Map<String, String> summary = new HashMap<>();
+    Map<String, String> summary = new LinkedHashMap<>();
 
     CheckpointManager checkpointManager = 
aggregationTaskRunner.getCheckpointManager();
 
@@ -304,6 +304,8 @@ public class MetricCollectorHAController {
       new 
Date(checkpointManager.readCheckpoint(AggregationTaskRunner.AGGREGATOR_NAME.METRIC_RECORD_MINUTE)).toString());
     
summary.put(ACTUAL_AGGREGATOR_NAMES.get(AggregationTaskRunner.AGGREGATOR_NAME.METRIC_RECORD_HOURLY),
       new 
Date(checkpointManager.readCheckpoint(AggregationTaskRunner.AGGREGATOR_NAME.METRIC_RECORD_HOURLY)).toString());
+    
summary.put(ACTUAL_AGGREGATOR_NAMES.get(AggregationTaskRunner.AGGREGATOR_NAME.METRIC_RECORD_DAILY),
+      new 
Date(checkpointManager.readCheckpoint(AggregationTaskRunner.AGGREGATOR_NAME.METRIC_RECORD_DAILY)).toString());
 
     
summary.put(ACTUAL_AGGREGATOR_NAMES.get(AggregationTaskRunner.AGGREGATOR_NAME.METRIC_AGGREGATE_SECOND),
       new 
Date(checkpointManager.readCheckpoint(AggregationTaskRunner.AGGREGATOR_NAME.METRIC_AGGREGATE_SECOND)).toString());
@@ -311,6 +313,8 @@ public class MetricCollectorHAController {
       new 
Date(checkpointManager.readCheckpoint(AggregationTaskRunner.AGGREGATOR_NAME.METRIC_AGGREGATE_MINUTE)).toString());
     
summary.put(ACTUAL_AGGREGATOR_NAMES.get(AggregationTaskRunner.AGGREGATOR_NAME.METRIC_AGGREGATE_HOURLY),
       new 
Date(checkpointManager.readCheckpoint(AggregationTaskRunner.AGGREGATOR_NAME.METRIC_AGGREGATE_HOURLY)).toString());
+    
summary.put(ACTUAL_AGGREGATOR_NAMES.get(AggregationTaskRunner.AGGREGATOR_NAME.METRIC_AGGREGATE_DAILY),
+      new 
Date(checkpointManager.readCheckpoint(AggregationTaskRunner.AGGREGATOR_NAME.METRIC_AGGREGATE_DAILY)).toString());
 
     return summary;
   }


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@ambari.apache.org
For additional commands, e-mail: commits-h...@ambari.apache.org