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

Update LLLocalDictionary

Browse Source
This commit is contained in:
Andrea Cavalli 2021-02-26 19:14:45 +01:00
parent a4340cdd2b
commit 6095f9eba9
1 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
src/main/java/it/cavallium/dbengine/database/disk/LLLocalDictionary.java
View File

@ -38,6 +38,7 @@ import org.warp.commonutils.log.LoggerFactory;
import reactor.core.publisher.Flux;
import reactor.core.publisher.Mono;
import reactor.core.scheduler.Scheduler;
import reactor.core.scheduler.Schedulers;
@NotAtomic
public class LLLocalDictionary implements LLDictionary {
@ -572,7 +573,7 @@ public class LLLocalDictionary implements LLDictionary {
}
private Flux<List<Entry<byte[],byte[]>>> getRangeMultiGrouped(LLSnapshot snapshot, LLRange range, int prefixLength) {
return new BoundedGroupedRocksFluxIterable<Entry<byte[], byte[]>>(dbScheduler, db, cfh, range, prefixLength) {
return new BoundedGroupedRocksFluxIterable<Entry<byte[], byte[]>>(Schedulers.boundedElastic(), db, cfh, range, prefixLength) {
@Override
protected ReadOptions getReadOptions() {
@ -599,7 +600,7 @@ public class LLLocalDictionary implements LLDictionary {
@Override
public Flux<List<byte[]>> getRangeKeysGrouped(@Nullable LLSnapshot snapshot, LLRange range, int prefixLength) {
return new BoundedGroupedRocksFluxIterable<byte[]>(dbScheduler, db, cfh, range, prefixLength) {
return new BoundedGroupedRocksFluxIterable<byte[]>(Schedulers.boundedElastic(), db, cfh, range, prefixLength) {
@Override
protected ReadOptions getReadOptions() {