fix: attributes and sub-attributes naming in aggregation

easy-global-market · Dec 17, 2024 · 074dfe1 · 074dfe1
1 parent 185a4e1
commit 074dfe1
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/...gsild-ckan-processors/src/main/java/egm/io/nifi/processors/ckan/utils/CKANAggregator.java b/...gsild-ckan-processors/src/main/java/egm/io/nifi/processors/ckan/utils/CKANAggregator.java
@@ -322,7 +322,7 @@ public static LinkedHashMap<String, ArrayList<JsonElement>> cropLinkedHashMap(Li
 
     public void aggregateInitialAttributes(String attributePrefix, ArrayList<AttributesLD> attributes, LinkedHashMap<String, ArrayList<JsonElement>> aggregation ) {
         for (AttributesLD attribute : attributes) {
-            String attrName = (attributePrefix.isEmpty() ? attribute.getAttrName() : attributePrefix + "_") + attribute.getAttrName();
+            String attrName = (attributePrefix.isEmpty() ? attributePrefix : attributePrefix + "_") + attribute.getAttrName();
             aggregation.put(attrName, new ArrayList<>());
             aggregation.put(attrName + NGSIConstants.AUTOGENERATED_ATTR_TYPE, new ArrayList<>());
             if (attribute.isHasSubAttrs()) {
@@ -333,7 +333,7 @@ public void aggregateInitialAttributes(String attributePrefix, ArrayList<Attribu
 
     public void aggregateAttributeValues(String attributePrefix, ArrayList<AttributesLD> attributes, LinkedHashMap<String, ArrayList<JsonElement>> aggregation) {
         for (AttributesLD attribute : attributes) {
-            String attrName = (attributePrefix.isEmpty() ? attribute.getAttrName() : attributePrefix + "_") + attribute.getAttrName();
+            String attrName = (attributePrefix.isEmpty() ? attributePrefix : attributePrefix + "_") + attribute.getAttrName();
             String attrType = attribute.getAttrType();
             JsonElement attrValue = new JsonPrimitive(attribute.getAttrValue());
             if (aggregation.containsKey(attrName)) {