如何使用 Java return Elasticsearch 中的所有结果?
How to return all the results in Elasticsearch using Java?
我有一个在 elasticsearch 中索引的数据集。 (索引名称:demoindex1,类型名称:SearchTech)。我想使用 Java 以 JSON 格式返回所有结果。我的Java代码如下:
import java.net.InetAddress;
import org.elasticsearch.action.search.SearchResponse;
import org.elasticsearch.client.Client;
import org.elasticsearch.client.transport.TransportClient;
import org.elasticsearch.common.transport.InetSocketTransportAddress;
import org.elasticsearch.common.unit.TimeValue;
import org.elasticsearch.search.SearchHit;
public class App {
public static void main(String[] args) throws Exception {
Client client = TransportClient.builder().build().addTransportAddress(
new InetSocketTransportAddress(InetAddress.getByName("localhost"),
9300));
SearchResponse scrollResp = client.prepareSearch("demoindex1")
.setScroll(new TimeValue(60000)).setTypes("SearchTech").setSize(1000)
.execute().actionGet();
// Scroll until no hits are returned
while (true) {
for (SearchHit hit : scrollResp.getHits()) {
System.out.println(hit.getSourceAsString()); //hit.get
}
scrollResp = client.prepareSearchScroll(scrollResp.getScrollId())
.setScroll(new TimeValue(60000)).execute().actionGet();
// Break condition: No hits are returned
if (scrollResp.getHits().getHits().length == 0) {
break;
}
}
}
}
我的 java 程序 returns 每个命中的源代码部分。但是我想在我们使用查询 GET index/type/_search 进入 Elasticsearch 时取回所有结果。
我需要 JSON 格式的结果数据集。我在这里做错了什么?
-我已经阅读了 elasticsearch 的 JAVA 文档,但我找不到任何关于取回所有结果数据集的信息。
谢谢。
我不能发表评论,所以我只能在这里写下我的评论:我可能已经理解了你的问题,但如果我错了,请指正。
如果您想为 GET index/type/_search 获取整个 JSON,为什么不尝试 scrollResp.toString()?然后您可以使用可用的丰富库之一从字符串中读取 JSON 树,例如 com.fasterxml.jackson.
或者,如果您正在寻找 JSON 作为命中的 _source,您可以使用这些库将 hit.getSourceAsString() 的结果转换为 JSON。
我有一个在 elasticsearch 中索引的数据集。 (索引名称:demoindex1,类型名称:SearchTech)。我想使用 Java 以 JSON 格式返回所有结果。我的Java代码如下:
import java.net.InetAddress;
import org.elasticsearch.action.search.SearchResponse;
import org.elasticsearch.client.Client;
import org.elasticsearch.client.transport.TransportClient;
import org.elasticsearch.common.transport.InetSocketTransportAddress;
import org.elasticsearch.common.unit.TimeValue;
import org.elasticsearch.search.SearchHit;
public class App {
public static void main(String[] args) throws Exception {
Client client = TransportClient.builder().build().addTransportAddress(
new InetSocketTransportAddress(InetAddress.getByName("localhost"),
9300));
SearchResponse scrollResp = client.prepareSearch("demoindex1")
.setScroll(new TimeValue(60000)).setTypes("SearchTech").setSize(1000)
.execute().actionGet();
// Scroll until no hits are returned
while (true) {
for (SearchHit hit : scrollResp.getHits()) {
System.out.println(hit.getSourceAsString()); //hit.get
}
scrollResp = client.prepareSearchScroll(scrollResp.getScrollId())
.setScroll(new TimeValue(60000)).execute().actionGet();
// Break condition: No hits are returned
if (scrollResp.getHits().getHits().length == 0) {
break;
}
}
}
}
我的 java 程序 returns 每个命中的源代码部分。但是我想在我们使用查询 GET index/type/_search 进入 Elasticsearch 时取回所有结果。 我需要 JSON 格式的结果数据集。我在这里做错了什么?
-我已经阅读了 elasticsearch 的 JAVA 文档,但我找不到任何关于取回所有结果数据集的信息。
谢谢。
我不能发表评论,所以我只能在这里写下我的评论:我可能已经理解了你的问题,但如果我错了,请指正。
如果您想为 GET index/type/_search 获取整个 JSON,为什么不尝试 scrollResp.toString()?然后您可以使用可用的丰富库之一从字符串中读取 JSON 树,例如 com.fasterxml.jackson.
或者,如果您正在寻找 JSON 作为命中的 _source,您可以使用这些库将 hit.getSourceAsString() 的结果转换为 JSON。