Global Aggregation Prepare aggregation request 下面是一个如何创建聚合请求的例子: AggregationBuilders .global("agg") .subAggregation(AggregationBuilders.terms("genders").field("gender"));……
Aggregations 使用工厂聚合生成器(AggregationBuilders)，并将查询时要计算的每个聚合添加到搜索请求中: SearchResponse sr = node.client().prepareSearch() .setQuery( /* your query */ ) .addAggregation( /* add……
Terminate After 为每个碎片收集的最大文档数量，当达到该数量时，查询执行将提前终止。如果设置好了，您将能够通过在SearchResponse对象中请求isTerminateEarly()来检查操作是否提前终止: SearchResponse sr = client.prepareSearch(INDEX) .setTermi……
ElasticSearch6.X版本Java Api中文详解（十）之Using scrolls in Java、MultiSearch API、Using Aggregations解析
Using scrolls in Java 用法很简单，直接看下面的代码即可理解。 import static org.elasticsearch.index.query.QueryBuilders.*; QueryBuilder qb = termQuery("multi", "test"); SearchResponse scroll……
Search API search API允许执行搜索查询并返回匹配查询的搜索结果。它可以跨一个或多个索引和一个或多个类型执行。可以使用查询Java API提供查询。搜索请求的主体是使用SearchSourceBuilder构建的。举个例子: import org.elasticsearch.action.search.SearchRes……
BulkByScrollResponse response = ReindexAction.INSTANCE.newRequestBuilder(client) .destination("target_index") .filter(QueryBuilders.matchQuery("category", "xzy")) .get();……
updateByQuery 最简单的用法是更新索引中的每个文档，而无需更改源。这种用法允许拾取新属性或另一个在线映射更改。 UpdateByQueryRequestBuilder updateByQuery = UpdateByQueryAction.INSTANCE.newRequestBuilder(client); updateBy……
Using Bulk Processor 提供了一个简单的接口，可以根据请求的数量或大小，或者在给定的时间段后自动刷新批量操作。 要使用它，首先要创建一个处理器实例： import org.elasticsearch.action.bulk.BackoffPolicy; import org.elasticsearch.action.bu……
1.Multi Get API multi get API允许根据它们的索引、类型和id获取文档列表： MultiGetResponse multiGetItemResponses = client.prepareMultiGet() .add("twitter", "tweet", "1") .add("twitter", "tweet……
基本操作 你可以创建一个UpdateRequest并将它发送给客户端： UpdateRequest updateRequest = new UpdateRequest(); updateRequest.index("index"); updateRequest.type("type"); updateRequest.id("1"); up……