Как выполнить много операций с индексом Elasticsearch за один вызов API с помощью Scala?

Question

Я добавляю данные в индекс в Elasticsearch.Инъекция с помощью операций POST одна занимает много времени.Ранее я использовал Bulk API в Java для выполнения многих операций с индексами за один вызов API.Это значительно увеличило скорость индексации.

Я хочу сделать то же самое в проекте Scala.

Я попытался найти Bulk API, который работает с Scala, но безуспешно.

это часть моего кода Java (это то, что я хочу выполнить в Scala):

for (int i = 0; i < 96; i++) {

  String startDate =(dateTime.plusMinutes(15*i)).format(DATE_FORMAT);

  String uniqueKey = "blabla" 

  IndexRequest indexRequest = new IndexRequest(REQ_URL_PREF+ 
  convertToIndexMonth(startDate), REQ_URL_SUFF, uniqueKey);

  String jsonString = JsonGenerator.createRequestBody(...).toJSONString();

  indexRequest.source(jsonString, XContentType.JSON);

  bulkRequest.add(indexRequest);

}

BulkResponse bulkResponse = client.bulk(bulkRequest);


```````````````