How to generate below query using elasticsearch java api

Question

I want to generate similar query using Elasticsearch JAVA API . I am trying to apply filters at an aggregation level.

{
    "query":{
        "filtered":{
            "filter":{ "terms":{ "family_name":"Brown" } } //filter_1
        }
    },
    "aggs":{
        "young_age":{
            "filter":{
                "terms" : {
                   "gender" : "male" //filter_2
                 } 
            },
            "aggs":{
                "age":{
                    "terms":{
                        "field":"age"
                    }
                }
            }
        }
    }
}

Please find the sample code that i am up to

TermFilterBuilder family_filter_1 = FilterBuilders.termFilter("family_name","Brown");

FilteredQueryBuilder qbuilder =QueryBuilders.filteredQuery(QueryBuilders.matchAllQuery(),family_filter_1);


SearchRequestBuilder search  = client.prepareSearch("test_index")
.setTypes("test_type")
.setSearchType(SearchType.COUNT)
.setQuery(qbuilder);

search.addAggregation(terms("age").field("age") 
.size(0)// Size 0 returns all the "group by keys"
.order(Terms.Order.count(true))); // to sort the output 

System.out.println(""+search);

and response i am getting . Please suggest how to add filter_2

{
  "query" : {
    "filtered" : {
      "query" : {
        "match_all" : { }
      },
      "filter" : {
        "term" : {
          "family_name" : "Brown"
        }
      }
    }
  },
  "aggregations" : {
    "age" : {
      "terms" : {
        "field" : "age",
        "size" : 0,
        "order" : {
          "_count" : "asc"
        }
      }
    }
  }
}

Thanks in advance..

You're missing the name of the field on which the range filter aggregation is run, i.e. the field on which filter_2 is run. — Val
– Val, Commented Nov 17, 2015 at 4:49
@val That's just for an example... Modified the question.. Thanks — gsuresh92
– gsuresh92, Commented Nov 17, 2015 at 4:54

Val · Accepted Answer · 2015-11-17 04:59:31Z

1

You can do it like this:

// same as your code
TermFilterBuilder family_filter_1 = ...;
FilteredQueryBuilder qbuilder = ...;
SearchRequestBuilder search = ...;

// build the range filter
RangeQuery ageRange = QueryBuilders.rangeQuery("age")
    .from(18).to(40).includeLower(false).includeUpper(false);

// build the terms sub-aggregation
TermsAggregation age = AggregationBuilders.terms("age")
    .field("age") 
    .size(0)
    .order(Terms.Order.count(true));

// build the filter top-aggregation
FilterAggregationBuilder youngAge = AggregationBuilders
    .filter("young_age")
    .filter(ageRange)
    .subAggregation(age);


search.addAggregation(youngAge);

answered Nov 17, 2015 at 4:59

Val

218k14 gold badges377 silver badges384 bronze badges

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

1 Comment

gsuresh92 Over a year ago

Thanks for AggregationBuilders logic

Collectives™ on Stack Overflow

How to generate below query using elasticsearch java api

1 Answer 1

1 Comment

Your Answer

Hot Network Questions

Collectives™ on Stack Overflow

1 Answer 1

1 Comment

Your Answer

Sign up or log in

Post as a guest

Related