diff --git a/src/main/java/it/cavallium/dbengine/lucene/LuceneUtils.java b/src/main/java/it/cavallium/dbengine/lucene/LuceneUtils.java index 5e1322e..8990cbd 100644 --- a/src/main/java/it/cavallium/dbengine/lucene/LuceneUtils.java +++ b/src/main/java/it/cavallium/dbengine/lucene/LuceneUtils.java @@ -189,14 +189,6 @@ public class LuceneUtils { return tokenStream; } - /** - * - * @return false if the result is not relevant - */ - public static boolean filterTopDoc(float score, Float minCompetitiveScore) { - return minCompetitiveScore == null || score >= minCompetitiveScore; - } - /** * @throws NoSuchElementException when the key is not found * @throws IOException when an error occurs when reading the document @@ -344,17 +336,6 @@ public class LuceneUtils { } } - @Nullable - public static FieldDoc getLastFieldDoc(ScoreDoc[] scoreDocs) { - if (scoreDocs == null) { - return null; - } - if (scoreDocs.length == 0) { - return null; - } - return (FieldDoc) scoreDocs[scoreDocs.length - 1]; - } - @Nullable public static ScoreDoc getLastScoreDoc(ScoreDoc[] scoreDocs) { if (scoreDocs == null) { @@ -427,21 +408,6 @@ public class LuceneUtils { } } - /** - * Transform a flux of results to take elements while the minimum competitive score is valid - */ - public static Flux filterTopDoc(Flux flux, LocalQueryParams queryParams) { - if (queryParams.scoreMode().needsScores() && queryParams.minCompetitiveScore() != null) { - if (queryParams.sort() != null && queryParams.sort().needsScores()) { - return flux.takeWhile(entry -> LuceneUtils.filterTopDoc(entry.score(), queryParams.minCompetitiveScore())); - } else { - return flux.filter(entry -> LuceneUtils.filterTopDoc(entry.score(), queryParams.minCompetitiveScore())); - } - } else { - return flux; - } - } - public static TopDocs mergeTopDocs(Sort sort, @Nullable Integer startN, @Nullable Integer topN, @@ -521,16 +487,6 @@ public class LuceneUtils { } } - public static Scheduler newLuceneSearcherScheduler(boolean multi) { - return Schedulers.newBoundedElastic( - 4, - Schedulers.DEFAULT_BOUNDED_ELASTIC_QUEUESIZE, - multi ? "lucene-searcher-multi" : "lucene-searcher-shard", - 60, - true - ); - } - public static Mono getMoreLikeThisQuery( List indexSearchers, LocalQueryParams localQueryParams,