(iceberg) branch main updated: Refactor: populate writeOptions in extraSnapshotMetadata using common util (#14604)

[huaxingao]

This is an automated email from the ASF dual-hosted git repository.

huaxingao pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/iceberg.git


The following commit(s) were added to refs/heads/main by this push:
     new 8c7ffec48f Refactor: populate writeOptions in extraSnapshotMetadata 
using common util (#14604)
8c7ffec48f is described below

commit 8c7ffec48ffd8d51e0ec7c8eb12d9aaeee214212
Author: yingjianwu98 <151791653+yingjianw...@users.noreply.github.com>
AuthorDate: Mon Nov 17 21:10:46 2025 -0800

    Refactor: populate writeOptions in extraSnapshotMetadata using common util 
(#14604)
    
    * small refactor for writeOptions when populating extraSnapshotMetadata to 
use common util
    
    * reformat
    
    ---------
    
    Co-authored-by: Yingjian Wu <yingji...@netflix.com>
---
 .../src/main/java/org/apache/iceberg/spark/SparkWriteConf.java   | 9 ++-------
 1 file changed, 2 insertions(+), 7 deletions(-)

diff --git 
a/spark/v4.0/spark/src/main/java/org/apache/iceberg/spark/SparkWriteConf.java 
b/spark/v4.0/spark/src/main/java/org/apache/iceberg/spark/SparkWriteConf.java
index c4f43d7b77..96131e0e56 100644
--- 
a/spark/v4.0/spark/src/main/java/org/apache/iceberg/spark/SparkWriteConf.java
+++ 
b/spark/v4.0/spark/src/main/java/org/apache/iceberg/spark/SparkWriteConf.java
@@ -261,13 +261,8 @@ public class SparkWriteConf {
             SparkSQLProperties.SNAPSHOT_PROPERTY_PREFIX));
 
     // Add write options, overriding session configuration if necessary
-    writeOptions.forEach(
-        (key, value) -> {
-          if (key.startsWith(SnapshotSummary.EXTRA_METADATA_PREFIX)) {
-            extraSnapshotMetadata.put(
-                key.substring(SnapshotSummary.EXTRA_METADATA_PREFIX.length()), 
value);
-          }
-        });
+    extraSnapshotMetadata.putAll(
+        PropertyUtil.propertiesWithPrefix(writeOptions, 
SnapshotSummary.EXTRA_METADATA_PREFIX));
 
     return extraSnapshotMetadata;
   }