Cwikius-Spring/spring-data-elasticsearch
1
0
Fork 0
mirror of https://github.com/spring-projects/spring-data-elasticsearch.git synced 2025-06-24 13:02:10 +00:00
Code Issues Packages Projects Releases Wiki Activity

Remove client specific code.

Browse Source 
Original Pull Request #2352
Closes #2351
This commit is contained in:
Peter-Josef Meisch 2022-11-03 20:44:25 +01:00 committed by GitHub
parent 049bcf504e
commit 96c9aa8af6
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 6 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
src/main/java/org/springframework/data/elasticsearch/repository/support/SimpleReactiveElasticsearchRepository.java
View File

@ -15,13 +15,13 @@
*/
package org.springframework.data.elasticsearch.repository.support;
import org.springframework.data.elasticsearch.core.query.BaseQuery;
import reactor.core.publisher.Flux;
import reactor.core.publisher.Mono;
import org.reactivestreams.Publisher;
import org.springframework.data.domain.Pageable;
import org.springframework.data.domain.Sort;
import org.springframework.data.elasticsearch.client.erhlc.NativeSearchQueryBuilder;
import org.springframework.data.elasticsearch.core.AbstractReactiveElasticsearchTemplate;
import org.springframework.data.elasticsearch.core.MultiGetItem;
import org.springframework.data.elasticsearch.core.ReactiveElasticsearchOperations;
@ -158,7 +158,11 @@ public class SimpleReactiveElasticsearchRepository<T, ID> implements ReactiveEla
return Flux.from(idStream) //
.map(this::convertId) //
.collectList() //
.map(ids -> new NativeSearchQueryBuilder().withIds(ids).build()) //
.map(ids -> {
var query = new BaseQuery();
query.setIds(ids);
return query;
}) //
.flatMapMany(query -> {
IndexCoordinates index = entityInformation.getIndexCoordinates();
return operations.multiGet(query, entityInformation.getJavaType(), index) //