在Elasticsearch客户端中执行UpdateByQueryRequest

Question

我想在Elasticsearch上运行一个update-by-query调用。我编写的代码如下所示，它有效，

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

但是，在代码评审过程中，有人告诉我要这么做，而不是通过调用UpdateByQueryRequest类来调用构建器上的get()，这是有意义的。

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

那么UpdateByQueryRequestBuilder#get()是该走的路呢，还是真的可以调用UpdateByQueryRequest呢？

提前谢谢。

Answer 1

直接调用builder.get()，这是块执行，您可以使用执行与ActionListener异步执行。

也许你可以这样做：

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