|
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