Elasticsearch Java REST高级客户端 条件删除 DeleteByQuery
Elasticsearch 7.2.0
1.条件删除
2.客户端创建
3.maven配置-pom
对人工智能感兴趣点下面链接
现在人工智能非常火爆,很多朋友都想学,但是一般的教程都是为博硕生准备的,太难看懂了。最近发现了一个非常适合小白入门的教程,不仅通俗易懂而且还很风趣幽默。所以忍不住分享一下给大家。点这里可以跳转到教程。
1.条件删除
/**
* 条件删除
*/
public static long deleteQuery() {
RestHighLevelClient client = getClient();
//参数为索引名,可以不指定,可以一个,可以多个
DeleteByQueryRequest request = new DeleteByQueryRequest("hockey");
// 更新时版本冲突
request.setConflicts("proceed");
// 设置查询条件,第一个参数是字段名,第二个参数是字段的值
request.setQuery(new TermQueryBuilder("first", "sam"));
// 更新最大文档数
request.setSize(10);
// 批次大小
request.setBatchSize(1000);
// 并行
request.setSlices(2);
// 使用滚动参数来控制“搜索上下文”存活的时间
request.setScroll(TimeValue.timeValueMinutes(10));
// 超时
request.setTimeout(TimeValue.timeValueMinutes(2));
// 刷新索引
request.setRefresh(true);
try {
BulkByScrollResponse response = client.deleteByQuery(request, RequestOptions.DEFAULT);
return response.getStatus().getUpdated();
} catch (IOException e) {
e.printStackTrace();
}finally {
try {
client.close();
} catch (IOException e) {
e.printStackTrace();
}
}
return -1;
}
2.客户端创建
/**
* 关闭客户端
*
* @param client
*/
private static void close(RestHighLevelClient client) {
try {
client.close();
} catch (IOException e) {
e.printStackTrace();
}
}
/**
* 获取客户端
*
* @return
*/
private static RestHighLevelClient getClient() {
RestHighLevelClient client = new RestHighLevelClient(
RestClient.builder(new HttpHost("elk-node01", 9200, "http"), new HttpHost("elk-node02", 9200, "http"),
new HttpHost("elk-node03", 9200, "http")));
return client;
}
3、maven配置—pom
Elasticsearch Java REST高级客户端 maven配置
版权声明:本文为u014646662原创文章,遵循 CC 4.0 BY-SA 版权协议,转载请附上原文出处链接和本声明。