From cd76b91e9dc081ad25b0a17729cc266851089247 Mon Sep 17 00:00:00 2001 From: Kellen Dye Date: Wed, 18 Sep 2024 08:44:51 -0400 Subject: [PATCH] wip --- .../main/scala/com/spotify/scio/iceberg/IcebergIO.scala | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/scio-managed/src/main/scala/com/spotify/scio/iceberg/IcebergIO.scala b/scio-managed/src/main/scala/com/spotify/scio/iceberg/IcebergIO.scala index 81c17bf662..4343cd3244 100644 --- a/scio-managed/src/main/scala/com/spotify/scio/iceberg/IcebergIO.scala +++ b/scio-managed/src/main/scala/com/spotify/scio/iceberg/IcebergIO.scala @@ -43,10 +43,10 @@ final case class IcebergIO[T: RowType: Coder](table: String, catalogName: Option configProperties: Map[String, String] ): Map[String, AnyRef] = { val b = Map.newBuilder[String, AnyRef] - b.addOne("table" -> table) - catalogName.foreach(name => b.addOne("catalog_name" -> name)) - Option(catalogProperties).foreach(p => b.addOne("catalog_properties" -> p)) - Option(configProperties).foreach(p => b.addOne("config_properties" -> p)) + b += ("table" -> table) + catalogName.foreach(name => b += ("catalog_name" -> name)) + Option(catalogProperties).foreach(p => b += ("catalog_properties" -> p)) + Option(configProperties).foreach(p => b += ("config_properties" -> p)) b.result() }