|
16 | 16 | package org.springframework.data.elasticsearch.client.elc; |
17 | 17 |
|
18 | 18 | import static org.springframework.data.elasticsearch.client.elc.TypeUtils.*; |
19 | | -import static org.springframework.util.CollectionUtils.*; |
20 | | - |
21 | | -import co.elastic.clients.elasticsearch._types.Conflicts; |
22 | | -import co.elastic.clients.elasticsearch._types.FieldValue; |
23 | | -import co.elastic.clients.elasticsearch._types.InlineScript; |
24 | | -import co.elastic.clients.elasticsearch._types.OpType; |
25 | | -import co.elastic.clients.elasticsearch._types.SortOptions; |
26 | | -import co.elastic.clients.elasticsearch._types.SortOrder; |
27 | | -import co.elastic.clients.elasticsearch._types.VersionType; |
28 | | -import co.elastic.clients.elasticsearch._types.WaitForActiveShardOptions; |
29 | | -import co.elastic.clients.elasticsearch._types.mapping.FieldType; |
30 | | -import co.elastic.clients.elasticsearch._types.mapping.Property; |
31 | | -import co.elastic.clients.elasticsearch._types.mapping.RuntimeField; |
32 | | -import co.elastic.clients.elasticsearch._types.mapping.RuntimeFieldType; |
33 | | -import co.elastic.clients.elasticsearch._types.mapping.TypeMapping; |
| 19 | +import static org.springframework.util.CollectionUtils.isEmpty; |
| 20 | + |
| 21 | +import co.elastic.clients.elasticsearch._types.*; |
| 22 | +import co.elastic.clients.elasticsearch._types.mapping.*; |
34 | 23 | import co.elastic.clients.elasticsearch._types.query_dsl.FieldAndFormat; |
35 | 24 | import co.elastic.clients.elasticsearch._types.query_dsl.Like; |
36 | 25 | import co.elastic.clients.elasticsearch.cluster.HealthRequest; |
|
58 | 47 | import java.io.StringReader; |
59 | 48 | import java.nio.charset.StandardCharsets; |
60 | 49 | import java.time.Duration; |
61 | | -import java.util.ArrayList; |
62 | | -import java.util.Arrays; |
63 | | -import java.util.Collections; |
64 | | -import java.util.HashMap; |
65 | | -import java.util.LinkedHashMap; |
66 | | -import java.util.List; |
67 | | -import java.util.Map; |
| 50 | +import java.util.*; |
68 | 51 | import java.util.function.Function; |
69 | 52 | import java.util.stream.Collectors; |
70 | 53 |
|
|
74 | 57 | import org.springframework.data.elasticsearch.core.ScriptType; |
75 | 58 | import org.springframework.data.elasticsearch.core.convert.ElasticsearchConverter; |
76 | 59 | import org.springframework.data.elasticsearch.core.document.Document; |
77 | | -import org.springframework.data.elasticsearch.core.index.AliasAction; |
78 | | -import org.springframework.data.elasticsearch.core.index.AliasActionParameters; |
79 | | -import org.springframework.data.elasticsearch.core.index.AliasActions; |
| 60 | +import org.springframework.data.elasticsearch.core.index.*; |
80 | 61 | import org.springframework.data.elasticsearch.core.index.DeleteTemplateRequest; |
81 | 62 | import org.springframework.data.elasticsearch.core.index.ExistsTemplateRequest; |
82 | 63 | import org.springframework.data.elasticsearch.core.index.GetTemplateRequest; |
@@ -1417,7 +1398,11 @@ private void prepareNativeSearch(NativeQuery query, SearchRequest.Builder builde |
1417 | 1398 | .suggest(query.getSuggester()) // |
1418 | 1399 | .collapse(query.getFieldCollapse()) // |
1419 | 1400 | .sort(query.getSortOptions()) // |
1420 | | - .knn(query.getKnnQuery()); |
| 1401 | + ; |
| 1402 | + |
| 1403 | + if (query.getKnnQuery() != null) { |
| 1404 | + builder.knn(query.getKnnQuery()); |
| 1405 | + } |
1421 | 1406 |
|
1422 | 1407 | if (!isEmpty(query.getAggregations())) { |
1423 | 1408 | builder.aggregations(query.getAggregations()); |
|
0 commit comments