mondodb: fix 'sum' aggregation operator

opencb · Dec 12, 2024 · 26c9628 · 26c9628
1 parent 84d1f92
commit 26c9628
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/...tastore-mongodb/src/main/java/org/opencb/commons/datastore/mongodb/MongoDBQueryUtils.java b/...tastore-mongodb/src/main/java/org/opencb/commons/datastore/mongodb/MongoDBQueryUtils.java
@@ -63,6 +63,7 @@ public class MongoDBQueryUtils {
     public static final String OTHER = "Other";
 
     public static final String COUNTS_SUFFIX = "Counts";
+    public static final String SUM_SUFFIX = "Sum";
     public static final String AVG_SUFFIX = "Avg";
     public static final String MIN_SUFFIX = "Min";
     public static final String MAX_SUFFIX = "Max";
@@ -771,6 +772,10 @@ private static Facet getMongoDBFacet(String field, Accumulator accumulator, List
                 facet = new Facet(field + COUNTS_SUFFIX, Arrays.asList(Aggregates.group(id, Accumulators.sum(count.name(), 1))));
                 break;
             }
+            case sum: {
+                facet = new Facet(field + SUM_SUFFIX, Arrays.asList(Aggregates.group(id, Accumulators.sum(sum.name(), id))));
+                break;
+            }
             case avg: {
                 facet = new Facet(field + AVG_SUFFIX, Arrays.asList(Aggregates.group(field, Accumulators.avg(avg.name(), id))));
                 break;