(amoro) branch master updated: [AMORO-3383] fix: unified catalog should support iceberg native create_changelog_view procedure (#3383)

[jinsongzhou]

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

jinsongzhou pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/amoro.git


The following commit(s) were added to refs/heads/master by this push:
     new 8d5e5efb2 [AMORO-3383] fix: unified catalog should support iceberg  
native create_changelog_view procedure (#3383)
8d5e5efb2 is described below

commit 8d5e5efb214d3c801869c58d3c2a36a4a134b841
Author: Wang Tao <wtrunw...@gmail.com>
AuthorDate: Fri Jan 10 14:45:00 2025 +0800

    [AMORO-3383] fix: unified catalog should support iceberg  native 
create_changelog_view procedure (#3383)
    
    * unified catalog support iceberg create_changelog_view procedure
    
    * unified catalog support iceberg create_changelog_view procedure
---
 .../main/java/org/apache/amoro/spark/iceberg/IcebergSparkFormat.java    | 2 ++
 1 file changed, 2 insertions(+)

diff --git 
a/amoro-format-mixed/amoro-mixed-spark/amoro-mixed-spark-3-common/src/main/java/org/apache/amoro/spark/iceberg/IcebergSparkFormat.java
 
b/amoro-format-mixed/amoro-mixed-spark/amoro-mixed-spark-3-common/src/main/java/org/apache/amoro/spark/iceberg/IcebergSparkFormat.java
index d733f9124..3bfc10bab 100644
--- 
a/amoro-format-mixed/amoro-mixed-spark/amoro-mixed-spark-3-common/src/main/java/org/apache/amoro/spark/iceberg/IcebergSparkFormat.java
+++ 
b/amoro-format-mixed/amoro-mixed-spark/amoro-mixed-spark-3-common/src/main/java/org/apache/amoro/spark/iceberg/IcebergSparkFormat.java
@@ -33,6 +33,7 @@ public class IcebergSparkFormat implements SparkTableFormat {
   private static final Pattern SNAPSHOT_ID = 
Pattern.compile("snapshot_id_(\\d+)");
   private static final Pattern BRANCH = Pattern.compile("branch_(.*)");
   private static final Pattern TAG = Pattern.compile("tag_(.*)");
+  private static final Pattern CHANGES = Pattern.compile("changes");
 
   @Override
   public TableFormat format() {
@@ -45,6 +46,7 @@ public class IcebergSparkFormat implements SparkTableFormat {
         || AT_TIMESTAMP.matcher(tableName).matches()
         || SNAPSHOT_ID.matcher(tableName).matches()
         || TAG.matcher(tableName).matches()
+        || CHANGES.matcher(tableName).matches()
         || BRANCH.matcher(tableName).matches();
   }