0

我想update-by-query在 Elasticsearch 上拨打电话。我编写了如下执行的代码,它可以工作,

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

但是,在代码审查期间,有人告诉我,不要在构建器上调用 get() 来UpdateByQueryRequest通过调用builder.request()哪种类型有意义来使用类。

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

那么是UpdateByQueryRequestBuilder#get()要走的路还是可以UpdateByQueryRequest实际调用?

提前致谢。

4

1 回答 1

2

直接调用builder.get(),这是一个块执行,你可以使用执行ActionListener异步执行。

也许你可以这样做:

builder.execute(new ActionListner<BulkIndexByScrollResponse> {
   void onResponse(Response response) {
   // do something
   }
   void onFailure(Exception e) {
   // do something
   }
}
于 2017-01-13T05:48:00.850 回答