java - 在 Elasticsearch Java 客户端中执行 UpdateByQueryRequest

Question

我想在 Elasticsearch 上运行update-by-query 调用。我编写了如下执行的代码并且它有效，

UpdateByQueryRequestBuilder builder = buildUpdateByQueryRequestBuilder();
builder.get();

但是，在代码审查期间，有人告诉我，不要通过调用 builder.request() 来使用 UpdateByQueryRequest 类，而不是在构建器上调用 get()，这有点有道理。

但问题是，我不知道如何执行 UpdateByQueryRequest。我查看了在线文档，但似乎没有任何文档。

那么 UpdateByQueryRequestBuilder#get() 是可行的方法还是可以实际调用 UpdateByQueryRequest ？

提前致谢。

Answer 1

直接调用builder.get()，这是一个 block 执行，可以使用execute与 ActionListener异步执行。

也许你可以这样做:

builder.execute(new ActionListner<BulkIndexByScrollResponse> {
   void onResponse(Response response) {
   // do something
   }
   void onFailure(Exception e) {
   // do something
   }
}