diff --git a/bundles/io.github.linkedfactory.core/src/main/java/io/github/linkedfactory/core/kvin/parquet/ParquetHelpers.java b/bundles/io.github.linkedfactory.core/src/main/java/io/github/linkedfactory/core/kvin/parquet/ParquetHelpers.java index 8ea7b13a..8cd2e7ce 100644 --- a/bundles/io.github.linkedfactory.core/src/main/java/io/github/linkedfactory/core/kvin/parquet/ParquetHelpers.java +++ b/bundles/io.github.linkedfactory.core/src/main/java/io/github/linkedfactory/core/kvin/parquet/ParquetHelpers.java @@ -76,7 +76,7 @@ static ParquetWriter getParquetDataWriter(Path dataFile) thro .withPageSize(PAGE_SIZE) .withDictionaryPageSize(DICT_PAGE_SIZE) .withDataModel(reflectData) - .withBloomFilterEnabled("id", true) + //.withBloomFilterEnabled("id", true) .build(); } @@ -90,7 +90,7 @@ static ParquetWriter getParquetMappingWriter(Path dataFile) throws IOExc .withRowGroupSize(ROW_GROUP_SIZE_MAPPINGS) .withPageSize(PAGE_SIZE) .withDictionaryPageSize(DICT_PAGE_SIZE) - .withBloomFilterEnabled("value", true) + //.withBloomFilterEnabled("value", true) .withDataModel(reflectData) .build(); } diff --git a/bundles/io.github.linkedfactory.core/src/test/java/io/github/linkedfactory/core/kvin/parquet/benchmark/KvinParquetBenchmark.java b/bundles/io.github.linkedfactory.core/src/test/java/io/github/linkedfactory/core/kvin/parquet/benchmark/KvinParquetBenchmark.java index f01d7724..504946f0 100644 --- a/bundles/io.github.linkedfactory.core/src/test/java/io/github/linkedfactory/core/kvin/parquet/benchmark/KvinParquetBenchmark.java +++ b/bundles/io.github.linkedfactory.core/src/test/java/io/github/linkedfactory/core/kvin/parquet/benchmark/KvinParquetBenchmark.java @@ -38,8 +38,8 @@ @State(Scope.Benchmark) @Fork(value = 1, jvmArgs = {"-Dorg.slf4j.simpleLogger.defaultLogLevel=warn", "-agentlib:jdwp=transport=dt_socket,server=y,suspend=n,address=1044"}) -@Warmup(iterations = 3, time = 500, timeUnit = TimeUnit.MILLISECONDS) -@Measurement(iterations = 3, time = 500, timeUnit = TimeUnit.MILLISECONDS) +@Warmup(iterations = 3, time = 5000, timeUnit = TimeUnit.MILLISECONDS) +@Measurement(iterations = 3, time = 5000, timeUnit = TimeUnit.MILLISECONDS) @BenchmarkMode(Mode.AverageTime) @OutputTimeUnit(TimeUnit.MILLISECONDS) public class KvinParquetBenchmark { @@ -97,7 +97,7 @@ public KvinParquetBenchmark() { public static void main(String[] args) throws RunnerException { Options opt = new OptionsBuilder() - .include(KvinParquetBenchmark.class.getSimpleName() + ".testKvinParquetReadPerformanceForProcessUseCase") // adapt to control which benchmark tests to run + .include(KvinParquetBenchmark.class.getSimpleName()) // adapt to control which benchmark tests to run .forks(1) .build();