java es批处理

Posted 2020-11-27 波动平静的心

tags:

篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了java es批处理相关的知识，希望对你有一定的参考价值。

private static TransportClient client = ElasticSearch.getClientSingle();

BulkRequestBuilder bulkRequestBuilder = client.prepareBulk();

List<Map<String,Object>> data = tbInformationMapper.tbData(map);

for(int i = 0; i < data.size(); i++) {
    Map<String, Object> data= data.get(i);
    bulkRequestBuilder.add(client.prepareIndex(index, type, data.get("id").toString()).setSource(data));
    if (i % 1000 == 0) {
        bulkRequestBuilder.execute().actionGet();
        bulkRequestBuilder.request().requests().clear();
    }
}
if(!bulkRequestBuilder.request().requests().isEmpty()) {
    bulkRequestBuilder.execute().actionGet();
    bulkRequestBuilder.request().requests().clear();
}

以上是关于java es批处理的主要内容，如果未能解决你的问题，请参考以下文章