From 447821d70710960f2e9bce0081d09b121886c0ec Mon Sep 17 00:00:00 2001 From: Gaurav Kumar Date: Mon, 8 Dec 2025 08:36:25 +0530 Subject: [PATCH] Update DataLakeActionService.java --- .../DataLake/Services/DataLakeActionService.java | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) 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("_"));