Skip to content

Commit

Permalink
wip
Browse files Browse the repository at this point in the history
  • Loading branch information
kellen committed Sep 18, 2024
1 parent eb57321 commit cd76b91
Showing 1 changed file with 4 additions and 4 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -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()
}

Expand Down

0 comments on commit cd76b91

Please sign in to comment.