1

我有一个在弹性搜索中索引的数据集。（索引名称：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 程序返回每个命中的源部分。但是我想在使用查询 GET index/type/_search 进入 Elasticsearch 时返回所有结果。我需要返回 JSON 格式的结果数据集。我在这里做错了什么？

- 我已经阅读了 elasticsearch 的 JAVA 文档，但我找不到任何关于取回所有结果数据集的信息。

谢谢你。

4

1 回答 1

1

我不能发表评论，所以我只能在这里写我的评论：我可能已经理解你的问题，但如果我错了，请纠正我。

如果您想为 GET index/type/_search 获取整个 JSON，为什么不尝试使用 scrollResp.toString()？然后，您可以使用可用的丰富库之一从字符串中读取 JSON 树，例如 com.fasterxml.jackson。

或者，如果您正在寻找命中的 _source 的 JSON，您可以使用这些库将 hit.getSourceAsString() 的结果转换为 JSON。

于 2016-04-21T04:34:21.437 回答