diff options
| author | Filip Hrisafov <filip.hrisafov@gmail.com> | 2024-01-03 20:15:07 +0100 |
|---|---|---|
| committer | Gunnar Morling <gunnar.morling@googlemail.com> | 2024-01-04 15:35:34 +0100 |
| commit | a503362c3678f2490073d303750c4f14f1945cf4 (patch) | |
| tree | bc0192fcabb675aab675cecff4cf84115e08efba /src/main/java/dev/morling/onebrc/CalculateAverage_truelive.java | |
| parent | fd92f5e807a3ffdd71b5d150b7b420677546c32c (diff) | |
Auto reformat classes
Diffstat (limited to 'src/main/java/dev/morling/onebrc/CalculateAverage_truelive.java')
| -rw-r--r-- | src/main/java/dev/morling/onebrc/CalculateAverage_truelive.java | 26 |
1 files changed, 13 insertions, 13 deletions
diff --git a/src/main/java/dev/morling/onebrc/CalculateAverage_truelive.java b/src/main/java/dev/morling/onebrc/CalculateAverage_truelive.java index b71cadf..5f2c806 100644 --- a/src/main/java/dev/morling/onebrc/CalculateAverage_truelive.java +++ b/src/main/java/dev/morling/onebrc/CalculateAverage_truelive.java @@ -105,9 +105,8 @@ public class CalculateAverage_truelive { } private static Map<String, Measurement> combineMaps( - final Map<String, Measurement> map1, - final Map<String, Measurement> map2 - ) { + final Map<String, Measurement> map1, + final Map<String, Measurement> map2) { for (final var entry : map2.entrySet()) { map1.merge(entry.getKey(), entry.getValue(), Measurement::combineWith); } @@ -116,7 +115,7 @@ public class CalculateAverage_truelive { } public static void main(final String[] args) throws IOException { - //long before = System.currentTimeMillis(); + // long before = System.currentTimeMillis(); /** * Shoutout to bjhara */ @@ -136,8 +135,7 @@ public class CalculateAverage_truelive { final MappedByteBuffer mbb = in.map( FileChannel.MapMode.READ_ONLY, start, - Math.min(CHUNK_SIZE, total - start) - ); + Math.min(CHUNK_SIZE, total - start)); int realEnd = mbb.limit() - 1; while (mbb.get(realEnd) != '\n') { realEnd--; @@ -148,16 +146,17 @@ public class CalculateAverage_truelive { start += realEnd; return mbb; - } catch (final IOException e) { + } + catch (final IOException e) { throw new RuntimeException(e); } } }; final Map<String, Measurement> reduce = StreamSupport.stream(Spliterators.spliteratorUnknownSize( - iterator, Spliterator.IMMUTABLE), true) - .parallel() - .map(CalculateAverage_truelive::parseBuffer) - .reduce(CalculateAverage_truelive::combineMaps).get(); + iterator, Spliterator.IMMUTABLE), true) + .parallel() + .map(CalculateAverage_truelive::parseBuffer) + .reduce(CalculateAverage_truelive::combineMaps).get(); System.out.print("{"); System.out.print( @@ -169,7 +168,7 @@ public class CalculateAverage_truelive { .collect(Collectors.joining(", "))); System.out.println("}"); - //System.out.println("Took: " + (System.currentTimeMillis() - before)); + // System.out.println("Took: " + (System.currentTimeMillis() - before)); } @@ -189,7 +188,8 @@ public class CalculateAverage_truelive { name = new String(arr, 0, len); bug.position(pos); bug.mark(); - } else if (c == '\n') { + } + else if (c == '\n') { final int pos = bug.position(); bug.reset(); final int len = pos - bug.position(); |
