diff --git a/src/main/java/dev/morling/onebrc/CalculateAverage_ashikur2146.java b/src/main/java/dev/morling/onebrc/CalculateAverage_ashikur2146.java index 8e7803b6f..20a83dc3c 100644 --- a/src/main/java/dev/morling/onebrc/CalculateAverage_ashikur2146.java +++ b/src/main/java/dev/morling/onebrc/CalculateAverage_ashikur2146.java @@ -27,7 +27,7 @@ public static void main(String[] args) { private static Map processFile(String filePath) throws IOException { try { Path path = Paths.get(filePath); - return Files.lines(path).parallel().map(line -> line.split(";")).filter(parts -> parts.length == 2) + return Files.lines(path).map(line -> line.split(";")).parallel().filter(parts -> parts.length == 2) .collect(Collectors.groupingByConcurrent(parts -> parts[0], Collectors.mapping(parts -> new TemperatureStats(Double.parseDouble(parts[1])), Collectors.reducing(TemperatureStats::merge))))