You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@amoro.apache.org by ji...@apache.org on 2025/01/10 06:45:03 UTC
(amoro) branch master updated: [AMORO-3383] fix: unified catalog should support iceberg native create_changelog_view procedure (#3383)
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 <wt...@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();
}