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

fix parallelism when listing live files

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

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

@ -571,9 +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 {
return ((LLLocalDictionary) dict.dictionary) var liveFiles = StreamUtils.toListOn(dict.getDbReadPool(),
.getAllLiveFiles() ((LLLocalDictionary) dict.dictionary).getAllLiveFiles());
.sequential() return liveFiles.stream()
.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;