|
108 | 108 |
|
109 | 109 | import static org.elasticsearch.cluster.metadata.IndexMetadata.SETTING_INDEX_VERSION_CREATED; |
110 | 110 | import static org.elasticsearch.common.Strings.format; |
111 | | -import static org.elasticsearch.common.Strings.isNullOrBlank; |
112 | 111 | import static org.elasticsearch.common.xcontent.XContentParserUtils.ensureExpectedToken; |
113 | 112 |
|
114 | 113 | /** |
@@ -2428,8 +2427,7 @@ private Query createKnnBitQuery( |
2428 | 2427 | ? new ESDiversifyingChildrenByteKnnVectorQuery(name(), queryVector, filter, k, numCands, parentFilter, searchStrategy) |
2429 | 2428 | : new ESKnnByteVectorQuery(name(), queryVector, k, numCands, filter, searchStrategy); |
2430 | 2429 | // TODO: add saturation threshold and patience params ? |
2431 | | - Query knnQuery = indexOptions.earlyExit() ? |
2432 | | - PatienceKnnVectorQuery.fromByteQuery(knnByteVectorQuery) : knnByteVectorQuery; |
| 2430 | + Query knnQuery = indexOptions.earlyExit() ? PatienceKnnVectorQuery.fromByteQuery(knnByteVectorQuery) : knnByteVectorQuery; |
2433 | 2431 | if (similarityThreshold != null) { |
2434 | 2432 | knnQuery = new VectorSimilarityQuery( |
2435 | 2433 | knnQuery, |
@@ -2459,8 +2457,7 @@ private Query createKnnByteQuery( |
2459 | 2457 | ? new ESDiversifyingChildrenByteKnnVectorQuery(name(), queryVector, filter, k, numCands, parentFilter, searchStrategy) |
2460 | 2458 | : new ESKnnByteVectorQuery(name(), queryVector, k, numCands, filter, searchStrategy); |
2461 | 2459 | // TODO: add saturation threshold and patience params ? |
2462 | | - Query knnQuery = indexOptions.earlyExit() ? |
2463 | | - PatienceKnnVectorQuery.fromByteQuery(knnByteVectorQuery) : knnByteVectorQuery; |
| 2460 | + Query knnQuery = indexOptions.earlyExit() ? PatienceKnnVectorQuery.fromByteQuery(knnByteVectorQuery) : knnByteVectorQuery; |
2464 | 2461 |
|
2465 | 2462 | if (similarityThreshold != null) { |
2466 | 2463 | knnQuery = new VectorSimilarityQuery( |
@@ -2514,11 +2511,18 @@ && isNotUnitVector(squaredMagnitude)) { |
2514 | 2511 | numCands = Math.max(adjustedK, numCands); |
2515 | 2512 | } |
2516 | 2513 | KnnFloatVectorQuery knnFloatVectorQuery = parentFilter != null |
2517 | | - ? new ESDiversifyingChildrenFloatKnnVectorQuery(name(), queryVector, filter, adjustedK, numCands, parentFilter, |
2518 | | - knnSearchStrategy) : new ESKnnFloatVectorQuery(name(), queryVector, adjustedK, numCands, filter, knnSearchStrategy); |
| 2514 | + ? new ESDiversifyingChildrenFloatKnnVectorQuery( |
| 2515 | + name(), |
| 2516 | + queryVector, |
| 2517 | + filter, |
| 2518 | + adjustedK, |
| 2519 | + numCands, |
| 2520 | + parentFilter, |
| 2521 | + knnSearchStrategy |
| 2522 | + ) |
| 2523 | + : new ESKnnFloatVectorQuery(name(), queryVector, adjustedK, numCands, filter, knnSearchStrategy); |
2519 | 2524 | // TODO: add saturation threshold and patience params ? |
2520 | | - Query knnQuery = indexOptions.earlyExit() ? |
2521 | | - PatienceKnnVectorQuery.fromFloatQuery(knnFloatVectorQuery) : knnFloatVectorQuery; |
| 2525 | + Query knnQuery = indexOptions.earlyExit() ? PatienceKnnVectorQuery.fromFloatQuery(knnFloatVectorQuery) : knnFloatVectorQuery; |
2522 | 2526 |
|
2523 | 2527 | if (rescore) { |
2524 | 2528 | knnQuery = new RescoreKnnVectorQuery( |
|
0 commit comments