diff options
| author | Gunnar Morling <gunnar.morling@googlemail.com> | 2024-01-16 22:31:34 +0100 |
|---|---|---|
| committer | Gunnar Morling <gunnar.morling@googlemail.com> | 2024-01-16 22:31:50 +0100 |
| commit | 7ed5e1b0d4885b04fe09728ac979171aef45fc91 (patch) | |
| tree | 8c8576f2a7f37d4cdafd4c48cbf545a0f922fe62 /src/main/java/dev/morling/onebrc/CalculateAverage_adriacabeza.java | |
| parent | 1804fc5b5f48c20c26c6e12a7a34315796f2fae3 (diff) | |
Leaderboard, formatting
Diffstat (limited to 'src/main/java/dev/morling/onebrc/CalculateAverage_adriacabeza.java')
| -rw-r--r-- | src/main/java/dev/morling/onebrc/CalculateAverage_adriacabeza.java | 20 |
1 files changed, 10 insertions, 10 deletions
diff --git a/src/main/java/dev/morling/onebrc/CalculateAverage_adriacabeza.java b/src/main/java/dev/morling/onebrc/CalculateAverage_adriacabeza.java index 56a2c4d..a1a6953 100644 --- a/src/main/java/dev/morling/onebrc/CalculateAverage_adriacabeza.java +++ b/src/main/java/dev/morling/onebrc/CalculateAverage_adriacabeza.java @@ -62,6 +62,7 @@ public class CalculateAverage_adriacabeza { } } + private final Map<String, StationData> resultMap; public Result() { @@ -76,7 +77,8 @@ public class CalculateAverage_adriacabeza { resultMap.compute(city, (_, resultRow) -> { if (resultRow == null) { return new StationData(value); - } else { + } + else { resultRow.update(value); return resultRow; } @@ -84,14 +86,13 @@ public class CalculateAverage_adriacabeza { } public void merge(Result other) { - other.getResultMap().forEach((city, resultRow) -> - resultMap.merge(city, resultRow, (existing, incoming) -> { - existing.min = Math.min(existing.min, incoming.min); - existing.max = Math.max(existing.max, incoming.max); - existing.sum += incoming.sum; - existing.count += incoming.count; - return existing; - })); + other.getResultMap().forEach((city, resultRow) -> resultMap.merge(city, resultRow, (existing, incoming) -> { + existing.min = Math.min(existing.min, incoming.min); + existing.max = Math.max(existing.max, incoming.max); + existing.sum += incoming.sum; + existing.count += incoming.count; + return existing; + })); } public String toString() { @@ -129,7 +130,6 @@ public class CalculateAverage_adriacabeza { return channel.size(); // Return the end of the file if no newline is found after the current position } - /** * Gets the mapped byte buffers for parallel processing. * |
