Skip to content

Commit 8c24a1d

Browse files
committed
Fix use of DisjunctionDISIApproximation API
1 parent 2b6b7d6 commit 8c24a1d

File tree

1 file changed

+3
-5
lines changed

1 file changed

+3
-5
lines changed

x-pack/plugin/ml/src/main/java/org/elasticsearch/xpack/ml/inference/ltr/QueryFeatureExtractor.java

Lines changed: 3 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -42,7 +42,7 @@ public QueryFeatureExtractor(List<String> featureNames, List<Weight> weights) {
4242

4343
@Override
4444
public void setNextReader(LeafReaderContext segmentContext) throws IOException {
45-
DisiPriorityQueue disiPriorityQueue = new DisiPriorityQueue(weights.size());
45+
List<DisiWrapper> wrappers = new ArrayList<>(weights.size());
4646
scorers.clear();
4747
for (Weight weight : weights) {
4848
if (weight == null) {
@@ -51,13 +51,11 @@ public void setNextReader(LeafReaderContext segmentContext) throws IOException {
5151
}
5252
Scorer scorer = weight.scorer(segmentContext);
5353
if (scorer != null) {
54-
disiPriorityQueue.add(new DisiWrapper(scorer, false));
54+
wrappers.add(new DisiWrapper(scorer, false));
5555
}
5656
scorers.add(scorer);
5757
}
58-
var list = new ArrayList<DisiWrapper>();
59-
disiPriorityQueue.iterator().forEachRemaining(list::add);
60-
rankerIterator = new DisjunctionDISIApproximation(list, Long.MAX_VALUE);
58+
rankerIterator = new DisjunctionDISIApproximation(wrappers, Long.MAX_VALUE);
6159
}
6260

6361
@Override

0 commit comments

Comments
 (0)