如何使用批量处理器捕获批量响应？（Java 高级休息客户端）

Question

我是 Elasticsearch Java API 的新手。我知道批量操作有两种方式：

1. 构造一个批量请求，使用客户端对象。

2. 构造一个批量处理器，向它添加请求。

我模拟了一大堆mock数据（约1M条），并用Java高级rest客户端将它们索引到Elasticsearch(5.6.3)中。

但是，如果我使用批量请求来索引大批量，

java.lang.OutOfMemoryError: nullexception

当我使用 client.bulk() 方法时发生。

然后我尝试使用批量处理器，它可以工作。 代码如下：

RestHighLevelClient client = initESclient();
BulkProcessor bulkProcessor = initES(client);

logger.info("Use bulk request to load data:");
logger.info("start to generate random data...");
String bossMockIndex = customSetting.getMockIndex();
String soapMockType = customSetting.getSoapType();
Long start = System.currentTimeMillis();
Integer batch = customSetting.getMockBatch();
logger.info("Batch:"+batch);
List<IndexRequest> indexRequesList = bossMockDataService.indexRequestGenerator(batch, bossMockIndex, soapMockType);
Long endCreateData = System.currentTimeMillis();
logger.info("Consumption for creating "+batch+" pieces of mock data:"+(endCreateData-start)/1000.0d+"s");

for (IndexRequest indexRequest : indexRequesList) {
    bulkProcessor.add(indexRequest);
}

我想知道如何使用BulkProcessor 获得这个批量响应，就像我使用BulkRequest 时一样。我需要更新这批数据中的一些数据。

Answer 1

BulkResponse bulkResponse = bulkProcessor.execute().actionGet();