diff --git a/backend/src/main/java/com/realnet/DataLake/Services/DataLakeActionService.java b/backend/src/main/java/com/realnet/DataLake/Services/DataLakeActionService.java index d26a40e..8788168 100644 --- a/backend/src/main/java/com/realnet/DataLake/Services/DataLakeActionService.java +++ b/backend/src/main/java/com/realnet/DataLake/Services/DataLakeActionService.java @@ -604,15 +604,15 @@ public class DataLakeActionService { case "sum": aggResult = numericValues.stream().mapToDouble(Double::doubleValue).sum(); break; - case "average": + case "avg": aggResult = numericValues.isEmpty() ? 0.0 : numericValues.stream().mapToDouble(Double::doubleValue).average().orElse(0.0); break; - case "minimum": + case "min": aggResult = numericValues.isEmpty() ? null : numericValues.stream().mapToDouble(Double::doubleValue).min().orElse(0.0); break; - case "maximum": + case "max": aggResult = numericValues.isEmpty() ? null : numericValues.stream().mapToDouble(Double::doubleValue).max().orElse(0.0); break; @@ -622,7 +622,7 @@ public class DataLakeActionService { case "mode": aggResult = calculateMode(numericValues); break; - case "standard deviation": + case "stdev": aggResult = calculateStdDev(numericValues); break; default: @@ -725,7 +725,7 @@ public class DataLakeActionService { return null; double num = toDouble(values.get(0)); double den = toDouble(values.get(1)); - return den == 0 ? null : (num / den) * 100; + return den == 0 ? null : (num * den) / 100; case "concat": return values.stream().map(Object::toString).collect(Collectors.joining("_"));