Skip to content

Commit 2584d1a

Browse files
committed
fixes ES
1 parent 359d9d4 commit 2584d1a

File tree

1 file changed

+0
-24
lines changed
  • elasticsearch-driver/src/main/java/org/eclipse/jnosql/diana/elasticsearch/document

1 file changed

+0
-24
lines changed

elasticsearch-driver/src/main/java/org/eclipse/jnosql/diana/elasticsearch/document/EntityConverter.java

Lines changed: 0 additions & 24 deletions
Original file line numberDiff line numberDiff line change
@@ -92,30 +92,6 @@ private static Stream<DocumentEntity> executeStatement(DocumentQuery query, Rest
9292
}
9393

9494

95-
static void queryAsync(DocumentQuery query, RestHighLevelClient client, String index,
96-
Consumer<Stream<DocumentEntity>> callBack) {
97-
98-
FindAsyncListener listener = new FindAsyncListener(callBack, query.getDocumentCollection());
99-
QueryConverterResult select = QueryConverter.select(query);
100-
101-
if (!select.getIds().isEmpty()) {
102-
MultiGetRequest multiGetRequest = new MultiGetRequest();
103-
104-
select.getIds().stream()
105-
.map(id -> new MultiGetRequest.Item(index, query.getDocumentCollection(), id))
106-
.forEach(multiGetRequest::add);
107-
client.mgetAsync(multiGetRequest, RequestOptions.DEFAULT, listener.getIds());
108-
}
109-
110-
if (select.hasStatement()) {
111-
SearchRequest searchRequest = new SearchRequest(index);
112-
if (select.hasQuery()) {
113-
setQueryBuilder(query, select, searchRequest);
114-
}
115-
client.searchAsync(searchRequest, RequestOptions.DEFAULT, listener.getSearch());
116-
}
117-
118-
}
11995

12096
private static Consumer<Document> feedJSON(Map<String, Object> jsonObject) {
12197
return d -> {

0 commit comments

Comments
 (0)