Java API aggregation with Elasticsearch 1.x

Question

I am new to aggregations with Elasticsearch and am stuck with a very simple example taken from this link.

Basically I am trying to do the Java API version of this very simple working aggregation:

http://localhost:9200/cars/transactions/_search?search_type=count
{
 "aggs" : {
  "colors" : {
    "terms" : {
    "field" : "color"
   }
  }
 }
}

and this is the Java version I am trying to build but it returns empty buckets:

SearchResponse sr = client
            .prepareSearch("cars")
            .setTypes("transactions")
            .setSearchType(SearchType.COUNT)
            .addAggregation(AggregationBuilders.terms("colors").field("color"))
            .execute()
            .actionGet();

while using the Elastic DSL I get a proper response with buckets grouped by colors, but with the Java version I get an empty bucket.

Update

It turns out the code is correct, the issue I had is related to using it in a test case; when used against a running cluster it works.

Emmanuel Guiton · Accepted Answer · 2017-01-10 13:05:39Z

0

I suspect your issue is not with your Java version of the request, which is just fine. I tried it on some test data I have and got the expected result. The cluster is running Elasticsearch 1.7.5.

The Java code snippet I used :

        final SearchResponse sr = client
            .prepareSearch("index")
            .setTypes("docType")
            .setSearchType(SearchType.COUNT)
            .addAggregation(AggregationBuilders.terms("aggName").field("fieldName"))
            .execute()
            .actionGet();

        System.out.println(sr);

The result I got :

{
    "took" : 130,
    "timed_out" : false,
    "_shards" : {
        "total" : 5,
        "successful" : 5,
        "failed" : 0
    },
    "hits" : {
        "total" : 1927227,
        "max_score" : 0.0,
        "hits" : [ ]
    },
    "aggregations" : {
        "aggName" : {
            "doc_count_error_upper_bound" : 0,
            "sum_other_doc_count" : 0,
            "buckets" : [ {
                "key" : "key1",
                "doc_count" : 757843
            }, {
                "key" : "key2",
                "doc_count" : 620033
            }, {
                "key" : "key3",
                "doc_count" : 549351
            } ]
        }
    }
}

answered Jan 10, 2017 at 13:05

Emmanuel Guiton

1,49515 silver badges25 bronze badges

Sign up to request clarification or add additional context in comments.

1 Comment

groo Over a year ago

OMG... huge facepalm here... indeed, just tested and the code is working, the issue I had is because I had this inside a testcase and for some reason some queries would proper work against the embedded elastic while this one was failing... not sure what causes it but yes, tested against a running cluster it works.

premkumar · Accepted Answer · 2017-01-10 11:40:08Z

0

You are doing SearchType as Count which is not correct for aggregations. Can you please remove searchtype and construct the query as below

SearchResponse sr = client
        .prepareSearch("cars")
        .setTypes("transactions")
        .addAggregation(AggregationBuilders.terms("colors").field("color"))
        .execute()
        .actionGet();

answered Jan 10, 2017 at 11:40

premkumar

471 silver badge11 bronze badges

1 Comment

groo Over a year ago

Hi, thank you for your suggestion, however I've tried this before(and double checked now) but still same results. Count is used here to avoid the fetch fase as described in this link: elastic.co/guide/en/elasticsearch/guide/1.x/…

Collectives™ on Stack Overflow

Java API aggregation with Elasticsearch 1.x

Update

2 Answers 2

1 Comment

1 Comment

Your Answer

Hot Network Questions

Collectives™ on Stack Overflow

Update

2 Answers 2

1 Comment

1 Comment

Your Answer

Sign up or log in

Post as a guest

Related