risadmin_prod/authsec_springboot
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Update DataLakeActionService.java

Browse Source
This commit is contained in:
Gaurav Kumar
2025-12-08 08:36:25 +05:30
parent bc41959594
commit 447821d707
1 changed files with 5 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
backend/src/main/java/com/realnet/DataLake/Services/DataLakeActionService.java
View File

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