API, Core: Add uuid() to View (#8851)

apache · Oct 31, 2023 · 4433aa8 · 4433aa8
1 parent 86bb1c0
commit 4433aa8
Show file tree

Hide file tree

Showing 3 changed files with 19 additions and 0 deletions.
diff --git a/api/src/main/java/org/apache/iceberg/view/View.java b/api/src/main/java/org/apache/iceberg/view/View.java
@@ -20,6 +20,7 @@
 
 import java.util.List;
 import java.util.Map;
+import java.util.UUID;
 import org.apache.iceberg.Schema;
 import org.apache.iceberg.UpdateLocation;
 
@@ -111,4 +112,13 @@ default ReplaceViewVersion replaceVersion() {
   default UpdateLocation updateLocation() {
     throw new UnsupportedOperationException("Updating a view's location is not supported");
   }
+
+  /**
+   * Returns the view's UUID
+   *
+   * @return the view's UUID
+   */
+  default UUID uuid() {
+    throw new UnsupportedOperationException("Retrieving a view's uuid is not supported");
+  }
 }
diff --git a/core/src/main/java/org/apache/iceberg/view/BaseView.java b/core/src/main/java/org/apache/iceberg/view/BaseView.java
@@ -21,6 +21,7 @@
 import java.io.Serializable;
 import java.util.List;
 import java.util.Map;
+import java.util.UUID;
 import org.apache.iceberg.Schema;
 import org.apache.iceberg.UpdateLocation;
 
@@ -97,4 +98,9 @@ public ReplaceViewVersion replaceVersion() {
   public UpdateLocation updateLocation() {
     return new SetViewLocation(ops);
   }
+
+  @Override
+  public UUID uuid() {
+    return UUID.fromString(ops.current().uuid());
+  }
 }
diff --git a/core/src/test/java/org/apache/iceberg/view/ViewCatalogTests.java b/core/src/test/java/org/apache/iceberg/view/ViewCatalogTests.java
@@ -24,6 +24,7 @@
 
 import java.nio.file.Path;
 import java.nio.file.Paths;
+import java.util.UUID;
 import org.apache.iceberg.Schema;
 import org.apache.iceberg.Transaction;
 import org.apache.iceberg.UpdateLocation;
@@ -158,6 +159,8 @@ public void completeCreateView() {
     }
 
     // validate view settings
+    assertThat(view.uuid())
+        .isEqualTo(UUID.fromString(((BaseView) view).operations().current().uuid()));
     assertThat(view.name()).isEqualTo(ViewUtil.fullViewName(catalog().name(), identifier));
     assertThat(view.properties()).containsEntry("prop1", "val1").containsEntry("prop2", "val2");
     assertThat(view.history())