This is an automated email from the ASF dual-hosted git repository.
etudenhoefner pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/iceberg.git
The following commit(s) were added to refs/heads/main by this push:
new 23e17ce665 Nessie: Add table() and view() API to NessieIcebergClient
(#9477)
23e17ce665 is described below
commit 23e17ce665031557f4fc918e2fcff9c18904dfb1
Author: Ajantha Bhat <[email protected]>
AuthorDate: Mon Jan 15 19:19:08 2024 +0530
Nessie: Add table() and view() API to NessieIcebergClient (#9477)
---
.../java/org/apache/iceberg/nessie/NessieIcebergClient.java | 10 ++++++++++
1 file changed, 10 insertions(+)
diff --git
a/nessie/src/main/java/org/apache/iceberg/nessie/NessieIcebergClient.java
b/nessie/src/main/java/org/apache/iceberg/nessie/NessieIcebergClient.java
index 5b5d4b194e..0dc9f30497 100644
--- 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 @@ public class NessieIcebergClient implements AutoCloseable {
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);