TCA:Support for string & decimal policy FieldPath
[dcaegen2/analytics/tca.git] / dcae-analytics-tca / src / main / java / org / openecomp / dcae / apod / analytics / tca / processor / TCACEFPolicyThresholdsProcessor.java
index 704151d..0a62aa4 100644 (file)
@@ -32,6 +32,7 @@ import org.openecomp.dcae.apod.analytics.tca.utils.TCAUtils;
 import org.slf4j.Logger;\r
 import org.slf4j.LoggerFactory;\r
 \r
+import java.math.BigDecimal;\r
 import java.util.HashMap;\r
 import java.util.List;\r
 import java.util.Map;\r
@@ -93,11 +94,12 @@ public class TCACEFPolicyThresholdsProcessor extends AbstractTCAECEFPolicyProces
         final Set<String> policyFieldPaths = policyFieldPathsMap.keySet();\r
 \r
         // Get Json Values for Policy Fields\r
-        final Map<String, List<Long>> messageFieldValuesMap = TCAUtils.getJsonPathValue(cefMessage, policyFieldPaths);\r
+        final Map<String, List<BigDecimal>> messageFieldValuesMap =\r
+                TCAUtils.getJsonPathValue(cefMessage, policyFieldPaths);\r
 \r
         // Determine all violated thresholds per message field Path\r
         final Map<String, Threshold> violatedThresholdsMap = new HashMap<>();\r
-        for (Map.Entry<String, List<Long>> messageFieldValuesMapEntry : messageFieldValuesMap.entrySet()) {\r
+        for (Map.Entry<String, List<BigDecimal>> messageFieldValuesMapEntry : messageFieldValuesMap.entrySet()) {\r
             final String messageFieldPath = messageFieldValuesMapEntry.getKey();\r
             final List<Threshold> messageFieldAssociatedPolicyThresholds = policyFieldPathsMap.get(messageFieldPath);\r
             if (messageFieldAssociatedPolicyThresholds != null) {\r