From 23473d6e8e467d56af0234139efbb6ddbf5b328b Mon Sep 17 00:00:00 2001 From: philippus Date: Tue, 2 Jul 2024 14:25:27 +0200 Subject: [PATCH] Replace buildBulkHttpBody-method --- .../elastic4s/handlers/bulk/BulkHandlers.scala | 10 +--------- 1 file changed, 1 insertion(+), 9 deletions(-) diff --git a/elastic4s-handlers/src/main/scala/com/sksamuel/elastic4s/handlers/bulk/BulkHandlers.scala b/elastic4s-handlers/src/main/scala/com/sksamuel/elastic4s/handlers/bulk/BulkHandlers.scala index 0d5fcd398..1aa079b8f 100644 --- a/elastic4s-handlers/src/main/scala/com/sksamuel/elastic4s/handlers/bulk/BulkHandlers.scala +++ b/elastic4s-handlers/src/main/scala/com/sksamuel/elastic4s/handlers/bulk/BulkHandlers.scala @@ -11,7 +11,7 @@ trait BulkHandlers { implicit object BulkHandler extends Handler[BulkRequest, BulkResponse] { override def build(bulk: BulkRequest): ElasticRequest = { - val httpBody: String = buildBulkHttpBody(bulk) + val httpBody: String = BulkBuilderFn(bulk).mkString("", "\n", "\n") val entity = HttpEntity(httpBody, "application/x-ndjson") if (logger.isDebugEnabled()) { logger.debug("Sending bulk request") @@ -25,12 +25,4 @@ trait BulkHandlers { ElasticRequest("POST", "/_bulk", params.toMap, entity) } } - - private[bulk] def buildBulkHttpBody(bulk: BulkRequest): String = { - val builder = StringBuilder.newBuilder - val rows: Iterator[String] = BulkBuilderFn(bulk) - rows.addString(builder, "", "\n", "") - builder.append("\n") // es seems to require a trailing new line as well - builder.mkString - } }