andreacavalli/CavalliumDBEngine
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

Fix parallelism bug

Browse Source
This commit is contained in:
Andrea Cavalli 2024-10-01 23:44:16 +02:00
parent e1e6065036
commit c859b8238f
1 changed files with 1 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
src/main/java/it/cavallium/dbengine/database/collections/DatabaseMapDictionary.java
View File

@ -571,10 +571,9 @@ public class DatabaseMapDictionary<T, U> extends DatabaseMapDictionaryDeep<T, U,
public static <T, U> Stream<Stream<Entry<T, U>>> getAllEntriesFastUnsafe(DatabaseMapDictionary<T, U> dict, public static <T, U> Stream<Stream<Entry<T, U>>> getAllEntriesFastUnsafe(DatabaseMapDictionary<T, U> dict,
BiConsumer<Entry<Buf, Buf>, Throwable> deserializationErrorHandler) { BiConsumer<Entry<Buf, Buf>, Throwable> deserializationErrorHandler) {
try { try {
Comparator<RocksDBFile> comparator = Comparator.<RocksDBFile>comparingInt(x -> x.getMetadata().level()).reversed();
return ((LLLocalDictionary) dict.dictionary) return ((LLLocalDictionary) dict.dictionary)
.getAllLiveFiles() .getAllLiveFiles()
.sorted(comparator) .sequential()
.map(file -> file.iterate(new SSTRangeFull()).map(state -> switch (state) { .map(file -> file.iterate(new SSTRangeFull()).map(state -> switch (state) {
case RocksDBFileIterationStateBegin rocksDBFileIterationStateBegin: case RocksDBFileIterationStateBegin rocksDBFileIterationStateBegin:
yield null; yield null;