aboutsummaryrefslogtreecommitdiff
path: root/src/main/java/dev/morling/onebrc/CalculateAverage_truelive.java
diff options
context:
space:
mode:
authorFilip Hrisafov <filip.hrisafov@gmail.com>2024-01-03 20:15:07 +0100
committerGunnar Morling <gunnar.morling@googlemail.com>2024-01-04 15:35:34 +0100
commita503362c3678f2490073d303750c4f14f1945cf4 (patch)
treebc0192fcabb675aab675cecff4cf84115e08efba /src/main/java/dev/morling/onebrc/CalculateAverage_truelive.java
parentfd92f5e807a3ffdd71b5d150b7b420677546c32c (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.java26
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();