DeleteByQueryAction.INSTANCE.newRequestBuilder(client)
.filter(QueryBuilders.matchAllQuery())
.source("myindexname")
.execute(new ActionListener<BulkIndexByScrollResponse>() {
@Override
public void onResponse(BulkIndexByScrollResponse response) {
long deleted = response.getDeleted();
System.err.println("num:"+deleted);
}
@Override
public void onFailure(Exception e) {
System.err.println(e);
}
});
}
按照官方api写的删除操作,为什么回调函数没有作用?没有运行
.filter(QueryBuilders.matchAllQuery())
.source("myindexname")
.execute(new ActionListener<BulkIndexByScrollResponse>() {
@Override
public void onResponse(BulkIndexByScrollResponse response) {
long deleted = response.getDeleted();
System.err.println("num:"+deleted);
}
@Override
public void onFailure(Exception e) {
System.err.println(e);
}
});
}
按照官方api写的删除操作,为什么回调函数没有作用?没有运行
2 个回复
vikooooooo
赞同来自:
vikooooooo
赞同来自: