JAVA操作ES增删API

PS:this.esClient为以配置完成且注入的对象，该随笔只记录相应API基本写法。

根据ES自动生成的_id进行单一删除：

DeleteResponse response =this.esClient.prepareDelete(INDEX_NAME, INDEX_TYPE, _id).execute().actionGet();

根据查询结果删除（filter内可以使用多种查询）：

DeleteByQueryRequestBuilder builder = DeleteByQueryAction.INSTANCE.newRequestBuilder(this.esClient)

　　　　　　　　　　　　　　　　         .filter(QueryBuilders.matchQuery(字段名, 字段值)).source(INDEX_NAME);

BulkByScrollResponse response2 = builder.get();

long deleted = response2.getDeleted();　　　　　　　　//获得删除的记录条数

Bulk为批量操作，使用bulk可减少请求发送的次数，可提高大数量操作效率，但当bulk的条数过多时，会产生相反效果（比如占用大量内存，一次请求占用太多CPU时间...）。

一次bulk具体数量应多方面权衡，找到最佳平衡点。

BulkRequestBuilder bulkRequestBuilder = this.esClient.prepareBulk();

for (POJO pojo: resultList) {

　　bulkRequestBuilder.add(this.esClient.prepareIndex(INDEX_NAME, INDEX_TYPE).setSource(JSON.toJSONString(pojo), XContentType.JSON));

}

BulkResponse response = bulkRequestBuilder.execute().actionGet();

JAVA操作ES增删API

原文：https://www.cnblogs.com/yan-zm/p/11956667.html