优化文档

Author: admin

document-apis/bulk-api.md

@@ -1,11 +1,13 @@
 
 ### Bulk API
-Bulk API可以批量插入：
 
+Bulk API，批量插入：
 
 ```
 import static org.elasticsearch.common.xcontent.XContentFactory.*;
+```
 
+```
 BulkRequestBuilder bulkRequest = client.prepareBulk();
 
 // either use client#prepare, or use Requests# to directly build index/delete requests
@@ -32,5 +34,6 @@ bulkRequest.add(client.prepareIndex("twitter", "tweet", "2")
 BulkResponse bulkResponse = bulkRequest.get();
 if (bulkResponse.hasFailures()) {
     // process failures by iterating through each bulk response item
+    //处理失败
 }
 ```

document-apis/using-bulk-processor.md

@@ -12,7 +12,9 @@ import org.elasticsearch.action.bulk.BulkProcessor;
 import org.elasticsearch.common.unit.ByteSizeUnit;
 import org.elasticsearch.common.unit.ByteSizeValue;
 import org.elasticsearch.common.unit.TimeValue;
+```
 
+```
 BulkProcessor bulkProcessor = BulkProcessor.builder(
         client,  //增加elasticsearch客户端
         new BulkProcessor.Listener() {
@@ -66,9 +68,9 @@ bulkProcessor.close();
 
 ```
 
-#### 在测试用使用Bulk Processor
+#### 在测试中使用Bulk Processor
 
-可以执行同步方法
+如果你在测试种使用`Bulk Processor`可以执行同步方法
 ```
 BulkProcessor bulkProcessor = BulkProcessor.builder(client, new BulkProcessor.Listener() { /* Listener methods */ })
         .setBulkActions(10000)

search-api.md

@@ -1,4 +1,6 @@
-搜索API可以支持搜索查询，返回查询匹配的结果，它可以搜索一个index / type 或者多个index / type，可以使用 [query Java API](https://www.elastic.co/guide/en/elasticsearch/client/java-api/current/java-query-dsl.html) 作为查询条件，下面是例子：
+# 搜索API
+
+搜索查询，返回查询匹配的结果，搜索一个index / type 或者多个index / type，可以使用 [query Java API](https://www.elastic.co/guide/en/elasticsearch/client/java-api/current/java-query-dsl.html) 作为查询条件，下面是例子：
 
 
 ```
@@ -17,7 +19,7 @@ SearchResponse response = client.prepareSearch("index1", "index2")
         .get();
 ```
 
-所有的参数都是可选的，下面是最小调用：
+所有的参数都是可选的，下面是最简单的调用：
 
 
 ```

search-api/multisearch-api.md

@@ -26,7 +26,6 @@ for (MultiSearchResponse.Item item : sr.getResponses()) {
 
 #### 实例
 
+- [MultiSearchAPI.java](https://gitee.com/quanke/elasticsearch-java-study/blob/master/src/test/java/name/quanke/es/study/search/MultiSearchAPI.java)
 
-```
-
-```
+- [本手册完整实例](https://gitee.com/quanke/elasticsearch-java-study)

search-api/search-template.md

@@ -5,7 +5,7 @@
 
 首先查看 [Search Template](https://www.elastic.co/guide/en/elasticsearch/reference/5.6/search-template.html) 文档
 
-> /_search/template endpoint 允许我们在执行搜索请求和使用模板参数填充现有模板之前，能够使用 mustache 语言预先呈现搜索请求。
+> /_search/template endpoint 允许我们在执行搜索请求和使用模板参数填充现有模板之前，能够使用 `mustache` 语言预先呈现搜索请求。
 
 将模板参数定义为 `Map <String，Object>`：
 

search-api/using-scrolls-in-java.md

@@ -7,11 +7,11 @@
 Scroll API的创建并不是为了实时的用户响应，而是为了处理大量的数据（Scrolling is not intended for real time user requests, but rather for processing large amounts of data）。从 scroll 请求返回的结果只是反映了 search 发生那一时刻的索引状态，就像一个快照(The results that are returned from a scroll request reflect the state of the index at the time that the initial search request was made, like a snapshot in time)。后续的对文档的改动（索引、更新或者删除）都只会影响后面的搜索请求。
 
 
-
-
 ```
 import static org.elasticsearch.index.query.QueryBuilders.*;
+```
 
+```
 QueryBuilder qb = termQuery("multi", "test");
 
 SearchResponse scrollResp = client.prepareSearch(test)
@@ -48,6 +48,7 @@ Caused by: SearchContextMissingException[No search context found for id [2861]]
 ```
 > 虽然当滚动有效时间已过，搜索上下文(Search Context)会自动被清除，但是一值保持滚动代价也是很大的，所以当我们不在使用滚动时要尽快使用Clear-Scroll API进行清除。
 
+## 清除Scroll
 
 ```
   /**
@@ -80,4 +81,49 @@ Caused by: SearchContextMissingException[No search context found for id [2861]]
 
 ```
 
-```
+public class ScrollsAPI extends ElasticsearchClientBase {
+
+    private String scrollId;
+
+    @Test
+    public void testScrolls() throws Exception {
+
+        SearchResponse scrollResp = client.prepareSearch("twitter")
+                .addSort(FieldSortBuilder.DOC_FIELD_NAME, SortOrder.ASC)
+                .setScroll(new TimeValue(60000)) //为了使用 scroll，初始搜索请求应该在查询中指定 scroll 参数，告诉 Elasticsearch 需要保持搜索的上下文环境多长时间（滚动时间）
+                .setQuery(QueryBuilders.termQuery("user", "kimchy"))                 // Query 查询条件
+                .setSize(5).get(); //max of 100 hits will be returned for each scroll
+        //Scroll until no hits are returned
+
+        scrollId = scrollResp.getScrollId();
+        do {
+            for (SearchHit hit : scrollResp.getHits().getHits()) {
+                //Handle the hit...
+
+                System.out.println("" + hit.getSource().toString());
+            }
+
+            scrollResp = client.prepareSearchScroll(scrollId).setScroll(new TimeValue(60000)).execute().actionGet();
+        }
+        while (scrollResp.getHits().getHits().length != 0); // Zero hits mark the end of the scroll and the while loop.
+    }
+
+    @Override
+    public void tearDown() throws Exception {
+        ClearScrollRequestBuilder clearScrollRequestBuilder = client.prepareClearScroll();
+        clearScrollRequestBuilder.addScrollId(scrollId);
+        ClearScrollResponse response = clearScrollRequestBuilder.get();
+
+        if (response.isSucceeded()) {
+            System.out.println("成功清除");
+        }
+
+        super.tearDown();
+    }
+}
+
+```
+
+- [ScrollsAPI.java](https://gitee.com/quanke/elasticsearch-java-study/blob/master/src/test/java/name/quanke/es/study/search/ScrollsAPI.java)
+
+- [本手册完整实例](https://gitee.com/quanke/elasticsearch-java-study)