diff --git a/src/main/java/it/cavallium/dbengine/client/LazyHitEntry.java b/src/main/java/it/cavallium/dbengine/client/LazyHitEntry.java index feb94d8..03cf552 100644 --- a/src/main/java/it/cavallium/dbengine/client/LazyHitEntry.java +++ b/src/main/java/it/cavallium/dbengine/client/LazyHitEntry.java @@ -8,4 +8,8 @@ public record LazyHitEntry(Mono key, Mono value, float score) { public Mono> resolve() { return Mono.zip(key, value, (k, v) -> new HitEntry<>(k, v, score)); } + + public Mono> resolveKey() { + return key.map(k -> new HitKey<>(k, score)); + } } diff --git a/src/main/java/it/cavallium/dbengine/database/disk/LLLocalKeyValueDatabase.java b/src/main/java/it/cavallium/dbengine/database/disk/LLLocalKeyValueDatabase.java index be22e6c..9af6e39 100644 --- a/src/main/java/it/cavallium/dbengine/database/disk/LLLocalKeyValueDatabase.java +++ b/src/main/java/it/cavallium/dbengine/database/disk/LLLocalKeyValueDatabase.java @@ -205,6 +205,7 @@ public class LLLocalKeyValueDatabase implements LLKeyValueDatabase { .setPartitionFilters(true) .setIndexType(IndexType.kTwoLevelIndexSearch) .setFormatVersion(5) + //todo: replace with kxxhash3 .setChecksumType(ChecksumType.kxxHash) .setBlockCacheCompressed(optionsWithCache.compressedCache()) .setBlockCache(optionsWithCache.standardCache())