elasticsearch 通过java API的方式使用BulkRequest批量同步,关于分批的疑问

首先,我使用的方式是高级客户端(restHighLevelClient),也就是java api的方式做了批量同步,现在贴上我的代码:

以为贴代码不好控制格式,所以就直接贴图了。代码思路是:

1.先去数据库查询出所有需要同步的数据

2.然后转换成map的格式,因为elasticsearch的批量同步方法貌似只接受map格式的参数

3.然后通过request的add方法,把所有的参数遍历添加到request中

4.最后在add完了之后,我做了一个分批,一千条去同步一次

现在有一个疑问,一千条同步完了之后,我这里的request要怎么处理呢,直接给null的话,下一次add就会报错,request也没有clean的方法,怎么才能解决这个问题呢?

©著作权归作者所有,转载或内容合作请联系作者
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。

推荐阅读更多精彩内容