scala - 在deleteByQuery中传递批处理大小[elasticsearch] [scala]

Question

我需要在使用deletebyQuery时传递批处理大小。
我的要求是:

根据过滤器

获取x行

对它们运行DeletebyQuery

返回此列表

使用过滤器进行搜索时，可以有1000行，但是我只需要前100行就可以了。需要返回这100行并仅对这100行运行deleteByQuery。
这是怎么做的？
这是我尝试过的代码，但最终删除了所有1000行。

val searchQuery =
  search(Index.name)
  .size(100)
    .query(boolQuery.should(
      termQuery(Type.status, Type.state)))

 getElasticsearchClient().execute(searchQuery)

 val result = elasticsearchClient().execute (
    deleteByQuery(Index.name, Index.typeName,
      boolQuery.should(termQuery(Type.status, Type.state))).size(100))

Answer 1

从7.3开始，按查询删除端点支持您可以使用的 max_docs parameter(以前称为size)。
我不确定使用的是哪个版本，但是DeleteByQueryRequest构造函数elastic4s提供了可以使用的 size parameter。