Elasticsearch Java API 2.3 麻烦

Question

社区：最近，当我在使用 Elasticsearch[2.3.1] 的项目中工作时，我尝试使用 java API 在 .jar 中编译对 ES 进行简单查询（elasticsearch.2.3.1.jar) 我添加到项目中的文件，但是当我接下来编写代码时：

QueryBuilder qb = simpleQueryStringQuery("+kimchy -elasticsearch");

IDE 没有重新定义指令 "simpleQueryStringQuery("+kimchy -elasticsearch")" 但在互联网和 ES 官方网站的所有示例中都以这种形式出现。做错了什么？提前致谢。

 import java.net.InetAddress;
 import java.net.UnknownHostException;

 import org.elasticsearch.action.search.SearchResponse;
 import org.elasticsearch.client.Client;
 import org.elasticsearch.client.transport.TransportClient;
 import org.elasticsearch.common.settings.Settings;
 import org.elasticsearch.common.transport.InetSocketTransportAddress;
 import org.elasticsearch.common.unit.TimeValue;
 import org.elasticsearch.index.query.QueryBuilder;
 import org.elasticsearch.index.query.QueryBuilders;
 import org.elasticsearch.search.SearchHit;
 import org.elasticsearch.search.sort.SortOrder;
 import org.elasticsearch.search.sort.SortParseElement;

  public class Search {


 public static void main(String[] args) {
    Client client;
    Settings settings = Settings.settingsBuilder()
            .put("client.transport.ignore_cluster_name", true).build();
    try {
        client = TransportClient
                .builder()
                .settings(settings)
                .build()
                .addTransportAddress(
                        new InetSocketTransportAddress(InetAddress
                                .getByName("localhost"), 9300));

    } catch (UnknownHostException e) {
        // TODO Auto-generated catch block
        e.printStackTrace();
    }
    QueryBuilder qb = simpleQueryStringQuery("+kimchy -elasticsearch");

    SearchResponse scrollResp = client.prepareSearch("thing")
            .addSort(SortParseElement.DOC_FIELD_NAME, SortOrder.ASC)
            .setScroll(new TimeValue(60000))
            .setQuery(qb)
            .setSize(100).execute().actionGet(); //100 hits per shard will be returned for each scroll
    //Scroll until no hits are returned
    while (true) {

        for (SearchHit hit : scrollResp.getHits().getHits()) {
            //Handle the hit...
        }
        scrollResp = client.prepareSearchScroll(scrollResp.getScrollId()).setScroll(new TimeValue(60000)).execute().actionGet();
        //Break condition: No hits are returned
        if (scrollResp.getHits().getHits().length == 0) {
            break;
        }
    }   


}



 }

Answer 1

你知道方法和导入是如何工作的吗？出现错误是因为您的 class 没有名为 simpleQueryStringQuery 的方法并且您没有导入该方法。

你真正想要的是：要么使用QueryBuilders.simpleQueryStringQuery("...")

或者对 QueryBuilders.simpleQueryStringQuery 使用 静态导入。参见：http://docs.oracle.com/javase/1.5.0/docs/guide/language/static-import.html or https://en.wikipedia.org/wiki/Static_import

Elasticsearch Java API 2.3 麻烦

Elasticesearch Java API 2.3 Trouble

java

elasticsearch

elasticsearch-java-api