[AMORO-2] Flink support for Setting/Altering Amoro table properties

huyuanfeng2018 · Mar 13, 2024 · f288182 · f288182
1 parent 4290bda
commit f288182
Showing 1 changed file with 9 additions and 3 deletions.
diff --git a/mixed/flink/flink-common/src/main/java/com/netease/arctic/flink/catalog/MixedCatalog.java b/mixed/flink/flink-common/src/main/java/com/netease/arctic/flink/catalog/MixedCatalog.java
@@ -106,6 +106,12 @@ public class MixedCatalog extends AbstractCatalog {
    */
   public static final String SQL_LIKE_METHOD = "lookupLikeSourceTable";
 
+  public static final String LOCATION = "location";
+
+  public static final String CHERRY_PICK_SNAPSHOT_ID = "cherry-pick-snapshot-id";
+
+  public static final String CURRENT_SNAPSHOT_ID = "current-snapshot-id";
+
   private final InternalCatalogBuilder catalogBuilder;
 
   private com.netease.arctic.catalog.ArcticCatalog internalCatalog;
@@ -700,11 +706,11 @@ private void alterUnKeyedTable(UnkeyedTable table, CatalogBaseTable newTable) {
         continue;
       }
 
-      if ("location".equalsIgnoreCase(key)) {
+      if (LOCATION.equalsIgnoreCase(key)) {
         setLocation = value;
-      } else if ("current-snapshot-id".equalsIgnoreCase(key)) {
+      } else if (CURRENT_SNAPSHOT_ID.equalsIgnoreCase(key)) {
         setSnapshotId = value;
-      } else if ("cherry-pick-snapshot-id".equalsIgnoreCase(key)) {
+      } else if (CHERRY_PICK_SNAPSHOT_ID.equalsIgnoreCase(key)) {
         pickSnapshotId = value;
       } else {
         setProperties.put(key, value);