This is an automated email from the ASF dual-hosted git repository. bchapuis pushed a commit to branch data-refactoring in repository https://gitbox.apache.org/repos/asf/incubator-baremaps.git
commit 777ea4ff90e64cf754f1e12f510956aab4aa040b Author: Bertil Chapuis <[email protected]> AuthorDate: Sat Apr 5 13:17:58 2025 +0200 Format code --- .../apache/baremaps/workflow/WorkflowContext.java | 10 +++++----- .../data/collection/FixedSizeDataList.java | 2 +- .../baremaps/data/collection/IndexedDataList.java | 2 +- .../data/collection/MonotonicPairedDataMap.java | 2 +- .../org/apache/baremaps/data/DataListTest.java | 22 +++++++++++----------- .../apache/baremaps/data/SizedDataListTest.java | 12 ++++++------ 6 files changed, 25 insertions(+), 25 deletions(-) diff --git a/baremaps-core/src/main/java/org/apache/baremaps/workflow/WorkflowContext.java b/baremaps-core/src/main/java/org/apache/baremaps/workflow/WorkflowContext.java index 037b1c40a..f940edc3d 100644 --- a/baremaps-core/src/main/java/org/apache/baremaps/workflow/WorkflowContext.java +++ b/baremaps-core/src/main/java/org/apache/baremaps/workflow/WorkflowContext.java @@ -85,11 +85,11 @@ public class WorkflowContext { Path mapDir = Files.createDirectories(cacheDir.resolve(name)); Path keysDir = Files.createDirectories(mapDir.resolve("keys")); Path valuesDir = Files.createDirectories(mapDir.resolve("values")); - MemoryAlignedDataList<PairDataType.Pair<Long, Long>> keys = MemoryAlignedDataList - .<PairDataType.Pair<Long, Long>>builder() - .dataType(new PairDataType<>(new LongDataType(), new LongDataType())) - .memory(new MemoryMappedDirectory(keysDir)) - .build(); + MemoryAlignedDataList<PairDataType.Pair<Long, Long>> keys = + MemoryAlignedDataList.<PairDataType.Pair<Long, Long>>builder() + .dataType(new PairDataType<>(new LongDataType(), new LongDataType())) + .memory(new MemoryMappedDirectory(keysDir)) + .build(); AppendOnlyLog<T> values = AppendOnlyLog.<T>builder() .dataType(dataType) .values(new MemoryMappedDirectory(valuesDir)) diff --git a/baremaps-data/src/main/java/org/apache/baremaps/data/collection/FixedSizeDataList.java b/baremaps-data/src/main/java/org/apache/baremaps/data/collection/FixedSizeDataList.java index e2732d839..eacab78c4 100644 --- a/baremaps-data/src/main/java/org/apache/baremaps/data/collection/FixedSizeDataList.java +++ b/baremaps-data/src/main/java/org/apache/baremaps/data/collection/FixedSizeDataList.java @@ -94,7 +94,7 @@ public class FixedSizeDataList<E> implements DataList<E> { if (memory == null) { memory = new OffHeapMemory(); } - + return new FixedSizeDataList<>(dataType, memory); } } diff --git a/baremaps-data/src/main/java/org/apache/baremaps/data/collection/IndexedDataList.java b/baremaps-data/src/main/java/org/apache/baremaps/data/collection/IndexedDataList.java index a383fa402..763546e3f 100644 --- a/baremaps-data/src/main/java/org/apache/baremaps/data/collection/IndexedDataList.java +++ b/baremaps-data/src/main/java/org/apache/baremaps/data/collection/IndexedDataList.java @@ -90,7 +90,7 @@ public class IndexedDataList<E> implements DataList<E> { .dataType(new LongDataType()) .build(); } - + return new IndexedDataList<>(index, values); } } diff --git a/baremaps-data/src/main/java/org/apache/baremaps/data/collection/MonotonicPairedDataMap.java b/baremaps-data/src/main/java/org/apache/baremaps/data/collection/MonotonicPairedDataMap.java index 07c285f9d..8662b2df0 100644 --- a/baremaps-data/src/main/java/org/apache/baremaps/data/collection/MonotonicPairedDataMap.java +++ b/baremaps-data/src/main/java/org/apache/baremaps/data/collection/MonotonicPairedDataMap.java @@ -100,7 +100,7 @@ public class MonotonicPairedDataMap<E> implements DataMap<Long, E> { .dataType(new LongDataType()) .build(); } - + return new MonotonicPairedDataMap<>(offsets, values); } } diff --git a/baremaps-data/src/test/java/org/apache/baremaps/data/DataListTest.java b/baremaps-data/src/test/java/org/apache/baremaps/data/DataListTest.java index f242356af..6f697fba8 100644 --- a/baremaps-data/src/test/java/org/apache/baremaps/data/DataListTest.java +++ b/baremaps-data/src/test/java/org/apache/baremaps/data/DataListTest.java @@ -76,18 +76,18 @@ class DataListTest { static Stream<Arguments> listProvider() { return Stream.of( Arguments.of(FixedSizeDataList.<Long>builder() - .dataType(new LongDataType()) - .build()), + .dataType(new LongDataType()) + .build()), Arguments.of(IndexedDataList.<Long>builder() - .index(MemoryAlignedDataList.<Long>builder() - .dataType(new LongDataType()) - .build()) - .values(AppendOnlyLog.<Long>builder() - .dataType(new LongDataType()) - .build()) - .build()), - Arguments.of(MemoryAlignedDataList.<Long>builder() + .index(MemoryAlignedDataList.<Long>builder() .dataType(new LongDataType()) - .build())); + .build()) + .values(AppendOnlyLog.<Long>builder() + .dataType(new LongDataType()) + .build()) + .build()), + Arguments.of(MemoryAlignedDataList.<Long>builder() + .dataType(new LongDataType()) + .build())); } } diff --git a/baremaps-data/src/test/java/org/apache/baremaps/data/SizedDataListTest.java b/baremaps-data/src/test/java/org/apache/baremaps/data/SizedDataListTest.java index e50c2de82..cb96ea10d 100644 --- a/baremaps-data/src/test/java/org/apache/baremaps/data/SizedDataListTest.java +++ b/baremaps-data/src/test/java/org/apache/baremaps/data/SizedDataListTest.java @@ -37,18 +37,18 @@ class SizedDataListTest { var dataType = new LongDataType(); var memory = new OffHeapMemory(4); assertThrows(DataCollectionException.class, () -> FixedSizeDataList.<Long>builder() - .dataType(dataType) - .memory(memory) - .build()); + .dataType(dataType) + .memory(memory) + .build()); } @ParameterizedTest @MethodSource("org.apache.baremaps.data.memory.MemoryProvider#memories") void appendFixedSizeValues(Memory memory) throws IOException { var list = FixedSizeDataList.<Long>builder() - .dataType(new LongDataType()) - .memory(memory) - .build(); + .dataType(new LongDataType()) + .memory(memory) + .build(); for (int i = 0; i < 1 << 10; i++) { assertEquals(i, list.addIndexed((long) i)); }
