|
6 | 6 | import co.elastic.clients.elasticsearch._types.aggregations.StringTermsBucket;
|
7 | 7 | import co.elastic.clients.elasticsearch._types.query_dsl.*;
|
8 | 8 | import de.numcodex.feasibility_gui_backend.common.api.Criterion;
|
9 |
| -import de.numcodex.feasibility_gui_backend.common.api.TermCode; |
10 | 9 | import de.numcodex.feasibility_gui_backend.terminology.api.EsSearchResult;
|
11 | 10 | import de.numcodex.feasibility_gui_backend.terminology.api.EsSearchResultEntry;
|
12 | 11 | import de.numcodex.feasibility_gui_backend.terminology.api.RelationEntry;
|
|
23 | 22 | import org.springframework.data.elasticsearch.client.elc.NativeQuery;
|
24 | 23 | import org.springframework.data.elasticsearch.client.elc.NativeQueryBuilder;
|
25 | 24 | import org.springframework.data.elasticsearch.core.ElasticsearchOperations;
|
26 |
| -import org.springframework.data.elasticsearch.core.SearchHit; |
27 | 25 | import org.springframework.data.elasticsearch.core.SearchHits;
|
28 | 26 | import org.springframework.data.util.Pair;
|
29 | 27 | import org.springframework.lang.Nullable;
|
@@ -255,12 +253,13 @@ public RelationEntry getRelationEntryByHash(String hash) {
|
255 | 253 |
|
256 | 254 | private TermFilter getFilter(String termApi) {
|
257 | 255 | final var termElastic = termApi.equalsIgnoreCase("context") ? "context.code" : termApi;
|
258 |
| - var aggQuery = NativeQuery.builder() |
| 256 | + var aggregationQuery = NativeQuery.builder() |
259 | 257 | .withAggregation(termElastic, Aggregation.of(a -> a
|
260 |
| - .terms(ta -> ta.field(termElastic)))) |
| 258 | + .terms(ta -> ta.field(termElastic).size(50)))) |
| 259 | + .withMaxResults(0) |
261 | 260 | .build();
|
262 | 261 |
|
263 |
| - SearchHits<OntologyListItemDocument> searchHits = operations.search(aggQuery, OntologyListItemDocument.class); |
| 262 | + SearchHits<OntologyListItemDocument> searchHits = operations.search(aggregationQuery, OntologyListItemDocument.class); |
264 | 263 | ElasticsearchAggregations aggregations = (ElasticsearchAggregations) searchHits.getAggregations();
|
265 | 264 | assert aggregations != null;
|
266 | 265 | List<StringTermsBucket> buckets = aggregations.aggregationsAsMap().get(termElastic).aggregation().getAggregate().sterms().buckets().array();
|
|
0 commit comments