1
2
3
4
5

 <dependency><groupId>org.elasticsearch</groupId><artifactId>elasticsearch</artifactId><version>1.1.0</version>
</dependency>

1
2
3
4
5

        Settings settings = ImmutableSettings.settingsBuilder().put("client.transport.sniff", true).build();TransportClient client = new TransportClient(settings);

1
2
3
4
5
6
7
8
9
10

       SearchResponse actionGet = client.prepareSearch("indexName").setTypes("typeName").setQuery(                  QueryBuilders.boolQuery().must(QueryBuilders.termQuery("attr1", "value1"))).execute().actionGet();SearchHits hits = actionGet.getHits();List<Map<String, Object>> matchRsult = new LinkedList<Map<String, Object>>();for (SearchHit hit : hits.getHits()){matchRsult.add(hit.getSource());}

1
2

QueryBuilders.inQuery("attr1", new String[{"value1","value2","value3"});
QueryBuilders.rangeQuery("attr1").gt("value1")//gt lt eq gte lte;

1
2

FilterBuilders.orFilter(FilterBuilders.termFilter("attr1", "value1"),FilterBuilders.termFilter("attr2", "value2"));
FilterBuilders.andFilter(FilterBuilders.termFilter("attr1", "value1"),FilterBuilders.termFilter("attr2", "value2"));

1
2
3
4
5
6
7
8

SearchResponse actionGet = elasticClient.prepareSearch("indexName").setTypes("typeName").setQuery(
QueryBuilders.boolQuery().must(QueryBuilders.termQuery("attr1", "value1"))).setFrom(100).setSize(200).execute().actionGet();

1
2
3
4
5
6
7
8

SearchResponse actionGet = elasticClient.prepareSearch("indexName").setTypes("typeName").setQuery(             QueryBuilders.boolQuery().must(QueryBuilders.termQuery("attr1", "value1")) ).setScroll(new TimeValue(60000)).setSize(200).execute().actionGet();String scrollId = actionGet.getScrollId();

1
2
3

SearchResponse actionGet = elasticClient.prepareSearchScroll(actionGet.getScrollId()).setScroll(new TimeValue(600000)).execute().actionGet();