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

Fix NPE

Browse Source
This commit is contained in:
Andrea Cavalli 2022-02-14 00:31:31 +01:00
parent 89200c2ed5
commit b90a78ef21
1 changed files with 15 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
src/main/java/it/cavallium/dbengine/lucene/LuceneUtils.java
View File

@ -356,11 +356,22 @@ public class LuceneUtils {
return hitsFlux
.buffer(Queues.XS_BUFFER_SIZE, () -> new ArrayList<Object>(Queues.XS_BUFFER_SIZE))
.flatMap(shardHits -> Mono.fromCallable(() -> {
for (int i = 0, size = shardHits.size(); i < size; i++) {
shardHits.set(i, mapHitBlocking((ScoreDoc) shardHits.get(i), indexSearchers, keyFieldName));
int i2 = 0;
int size = shardHits.size();
for (int i = 0; i < size; i++) {
var el = mapHitBlocking((ScoreDoc) shardHits.get(i), indexSearchers, keyFieldName);
if (el != null) {
shardHits.set(i2, el);
i2++;
}
}
if (i2 < size) {
//noinspection unchecked
return (List<LLKeyScore>) (List<?>) shardHits.subList(0, i2);
} else {
//noinspection unchecked
return (List<LLKeyScore>) (List<?>) shardHits;
}
//noinspection unchecked
return (List<LLKeyScore>) (List<?>) shardHits;
}).subscribeOn(uninterruptibleScheduler(Schedulers.boundedElastic())))
.flatMapIterable(a -> a)
.publishOn(Schedulers.parallel());