[IcebergIO]Create tables with Iceberg Table properties

Author: tarun-google

sdks/java/io/iceberg/src/main/java/org/apache/beam/sdk/io/iceberg/IcebergCatalogConfig.java

@@ -84,26 +84,17 @@ public org.apache.iceberg.catalog.Catalog catalog() {
   }
 
   public void createTable(
-      String tableIdentifier,
-      Schema tableSchema,
-      @Nullable List<String> partitionFields,
-      @Nullable Map<String, String> tableProperties) {
+      String tableIdentifier, Schema tableSchema, @Nullable List<String> partitionFields) {
     TableIdentifier icebergIdentifier = TableIdentifier.parse(tableIdentifier);
     org.apache.iceberg.Schema icebergSchema = IcebergUtils.beamSchemaToIcebergSchema(tableSchema);
     PartitionSpec icebergSpec = PartitionUtils.toPartitionSpec(partitionFields, tableSchema);
     try {
-      catalog()
-          .createTable(
-              icebergIdentifier,
-              icebergSchema,
-              icebergSpec,
-              tableProperties == null ? Maps.newHashMap() : tableProperties);
+      catalog().createTable(icebergIdentifier, icebergSchema, icebergSpec);
       LOG.info(
-          "Created table '{}' with schema: {}\n, partition spec: {}, table properties: {}",
+          "Created table '{}' with schema: {}\n, partition spec: {}",
           icebergIdentifier,
           icebergSchema,
-          icebergSpec,
-          tableProperties);
+          icebergSpec);
     } catch (AlreadyExistsException e) {
       throw new TableAlreadyExistsException(e);
     }

website/www/site/content/en/documentation/io/managed-io.md

@@ -97,9 +97,8 @@ and Beam SQL is invoked via the Managed API under the hood.
         keep (<code>list[<span style="color: green;">str</span>]</code>)<br>
         only (<code style="color: green">str</code>)<br>
         partition_fields (<code>list[<span style="color: green;">str</span>]</code>)<br>
+        table_properties (<code>map[<span style="color: green;">str</span>, <span style="color: green;">str</span>]</code>)<br>
         triggering_frequency_seconds (<code style="color: #f54251">int32</code>)<br>
-        table_properties (<code>map[<span style="color: green;">str</span>, <span style="color: green;
-        ">str</span>]</code>)<br>
       </td>
     </tr>
     <tr>
@@ -424,26 +423,25 @@ For more information on partition transforms, please visit https://iceberg.apach
     </tr>
     <tr>
       <td>
-        triggering_frequency_seconds
+        table_properties
       </td>
       <td>
-        <code style="color: #f54251">int32</code>
+        <code>map[<span style="color: green;">str</span>, <span style="color: green;">str</span>]</code>
       </td>
       <td>
-        For a streaming pipeline, sets the frequency at which snapshots are produced.
+        Iceberg table properties to be set on the table when it is created.
+For more information on table properties, please visit https://iceberg.apache.org/docs/latest/configuration/#table-properties.
       </td>
     </tr>
     <tr>
       <td>
-        table_properties
+        triggering_frequency_seconds
       </td>
       <td>
-        <code>map[<span style="color: green;">str</span>, <span style="color: green;">str</span>]</code>
+        <code style="color: #f54251">int32</code>
       </td>
       <td>
-        Table Properties set while creating Iceberg Table.
-
-For more information on table properties, please visit https://iceberg.apache.org/docs/latest/configuration/#table-properties
+        For a streaming pipeline, sets the frequency at which snapshots are produced.
       </td>
     </tr>
   </table>