Undo parallelization of lucene searches
This commit is contained in:
parent
6926292904
commit
3a79e5ba6f
@ -379,17 +379,9 @@ public class LuceneUtils {
|
|||||||
.subscribeOn(scheduler)
|
.subscribeOn(scheduler)
|
||||||
);
|
);
|
||||||
} else {
|
} else {
|
||||||
return hitsFlux
|
return hitsFlux.flatMap(hit -> Mono
|
||||||
.parallel()
|
.fromCallable(() -> mapHitBlocking(hit, indexSearchers, keyFieldName))
|
||||||
.runOn(scheduler)
|
.subscribeOn(scheduler));
|
||||||
.map(hit -> {
|
|
||||||
var result = mapHitBlocking(hit, indexSearchers, keyFieldName);
|
|
||||||
// The "else" value is an errored key score, to filter out next
|
|
||||||
return Objects.requireNonNullElseGet(result, () -> new LLKeyScore(-1, -1, null));
|
|
||||||
})
|
|
||||||
.sequential()
|
|
||||||
// Filter out the errored key scores
|
|
||||||
.filter(ks -> !(ks.docId() == -1 && ks.score() == -1));
|
|
||||||
}
|
}
|
||||||
});
|
});
|
||||||
}
|
}
|
||||||
|
Loading…
x
Reference in New Issue
Block a user