Playground/1brc
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Formatting

Browse Source
This commit is contained in:
Gunnar Morling 2024-01-12 22:26:55 +01:00
parent 5594a1b72b
commit 457c263a34
1 changed files with 7 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
src/main/java/dev/morling/onebrc/CalculateAverage_maximz101.java
View File

@ -93,7 +93,8 @@ public class CalculateAverage_maximz101 {
try (FileChannel channel = FileChannel.open(Paths.get(FILE), StandardOpenOption.READ)) { try (FileChannel channel = FileChannel.open(Paths.get(FILE), StandardOpenOption.READ)) {
MappedByteBuffer buffer = channel.map(MapMode.READ_ONLY, chunk.start(), chunk.end() - chunk.start()); MappedByteBuffer buffer = channel.map(MapMode.READ_ONLY, chunk.start(), chunk.end() - chunk.start());
return process(buffer); return process(buffer);
} catch (IOException e) { }
catch (IOException e) {
throw new RuntimeException(e); throw new RuntimeException(e);
} }
} }
@ -123,7 +124,8 @@ public class CalculateAverage_maximz101 {
} }
currentChunk++; currentChunk++;
} }
} catch (IOException e) { }
catch (IOException e) {
throw new RuntimeException(e); throw new RuntimeException(e);
} }
return list; return list;
@ -167,8 +169,7 @@ public class CalculateAverage_maximz101 {
private static Measurement parseLine(byte[] lineBytes, int separatorIdx, int eolIdx) { private static Measurement parseLine(byte[] lineBytes, int separatorIdx, int eolIdx) {
return new Measurement( return new Measurement(
new String(lineBytes, 0, separatorIdx, StandardCharsets.UTF_8), new String(lineBytes, 0, separatorIdx, StandardCharsets.UTF_8),
bytesToDouble(lineBytes, separatorIdx + 1, eolIdx) bytesToDouble(lineBytes, separatorIdx + 1, eolIdx));
);
} }
private static double bytesToDouble(byte[] bytes, int startIdx, int endIdx) { private static double bytesToDouble(byte[] bytes, int startIdx, int endIdx) {
@ -185,7 +186,8 @@ public class CalculateAverage_maximz101 {
double n = bytes[i] - '0'; double n = bytes[i] - '0';
if (afterDot) { if (afterDot) {
d = d + n / Math.pow(10, dots++); d = d + n / Math.pow(10, dots++);
} else { }
else {
d = d * Math.pow(10, i - numberStartIdx) + n; d = d * Math.pow(10, i - numberStartIdx) + n;
} }
} }