Nessie: Add table() and view() API to NessieIcebergClient (apache#9477)

alok123t · Jan 15, 2024 · 23e17ce · 23e17ce
1 parent 5a1b0d1
commit 23e17ce
Showing 1 changed file with 10 additions and 0 deletions.
diff --git a/nessie/src/main/java/org/apache/iceberg/nessie/NessieIcebergClient.java b/nessie/src/main/java/org/apache/iceberg/nessie/NessieIcebergClient.java
@@ -195,6 +195,16 @@ private TableIdentifier toIdentifier(EntriesResponse.Entry entry) {
     return TableIdentifier.of(elements.toArray(new String[elements.size()]));
   }
 
+  public IcebergTable table(TableIdentifier tableIdentifier) {
+    IcebergContent icebergContent = fetchContent(tableIdentifier);
+    return icebergContent == null ? null : icebergContent.unwrap(IcebergTable.class).orElse(null);
+  }
+
+  public IcebergView view(TableIdentifier tableIdentifier) {
+    IcebergContent icebergContent = fetchContent(tableIdentifier);
+    return icebergContent == null ? null : icebergContent.unwrap(IcebergView.class).orElse(null);
+  }
+
   public IcebergContent fetchContent(TableIdentifier tableIdentifier) {
     try {
       ContentKey key = NessieUtil.toKey(tableIdentifier);