Elasticsearch complex query using Java API

Question

I am trying to query on ElasticSearch using Java API, my query is:

curl -XGET 'http://localhost:9200/logstash-*/_search?search_type=count' -d '
{
    "query": {
        "filtered": {
            "query": {
                "match_all": {}
            },
            "filter": {
               "and" : [
               {
                  "range": {
                     "timestamp": {
                          "gte": "2015-08-20",
                          "lt": "2015-08-21",
                          "format": "yyyy-MM-dd",
                          "time_zone": "+8:00"
                     }
                  }
                  },
                  {"query": { 
                      "match": { 
                         "request": {
                            "query": "/v2/brand"
                          }
                       }
                     }
                  },
                  {"term": { "response" : "200"}
                  }
               ]
            }
        }
    },
    "aggs": {
        "group_by_device_id": {
            "terms": {
                "field": "clientip"
            }
        }
    }
}'

The similar sql logic is:

select distinct(clientip) from table where timestamp between '2015-08-20' and '2015-08-21' and request like '/v2/brand%' and response = '200'

How to implement it using Java API? Please guide I am new to ElasticSearch. Thanks in advance!

Why don't you start with elastic.co/guide/en/elasticsearch/client/java-api/current/… and come up with some solution first? — bittusarkar
– bittusarkar, Commented Sep 6, 2015 at 8:59

user3484518 · Accepted Answer · 2015-09-06 13:47:47Z

1

I have resolved the problem, below is my codes:

SearchResponse scrollResp1 = client.prepareSearch("logstash-*").setSearchType(SearchType.SCAN).
                    setQuery(QueryBuilders.filteredQuery(QueryBuilders.matchAllQuery(),
                            FilterBuilders.andFilter(FilterBuilders.termFilter("response", "200")
                                    , FilterBuilders.rangeFilter("timestamp").gte(startDate).lt
                                            (endDate), FilterBuilders.queryFilter
                                            (QueryBuilders.matchQuery("request", "signup"))
                            )))
                    .addAggregation(AggregationBuilders.terms
                            ("group_by_client_ip").size(0).field("clientip")).get();

answered Sep 6, 2015 at 13:47

user3484518

991 silver badge6 bronze badges

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

Collectives™ on Stack Overflow

Elasticsearch complex query using Java API

1 Answer 1

Comments

Your Answer

Hot Network Questions

Collectives™ on Stack Overflow

1 Answer 1

Comments

Your Answer

Sign up or log in

Post as a guest

Related