View api

Author: gabeiglio

pyiceberg/view/__init__.py

@@ -16,12 +16,11 @@
 # under the License.
 from __future__ import annotations
 
-from typing import (
-    Any,
-)
+from typing import Any
 
+from pyiceberg.schema import Schema
 from pyiceberg.typedef import Identifier
-from pyiceberg.view.metadata import ViewMetadata
+from pyiceberg.view.metadata import SQLViewRepresentation, ViewHistoryEntry, ViewMetadata, ViewVersion
 
 
 class View:
@@ -42,6 +41,46 @@ def name(self) -> Identifier:
         """Return the identifier of this view."""
         return self._identifier
 
+    def schema(self) -> Schema:
+        """Return the schema for this view."""
+        return next(schema for schema in self.metadata.schemas if schema.schema_id == self.current_version().schema_id)
+
+    def schemas(self) -> dict[int, Schema]:
+        """Return the schemas for this view."""
+        return {schema.schema_id: schema for schema in self.metadata.schemas}
+
+    def current_version(self) -> ViewVersion:
+        """Get the version of this view."""
+        return next(version for version in self.metadata.versions if version.version_id == self.metadata.current_version_id)
+
+    def versions(self) -> list[ViewVersion]:
+        """Get the versions of this view."""
+        return self.metadata.versions
+
+    def version(self, version_id: int) -> ViewVersion:
+        """Get the version in this view by ID."""
+        return next(version for version in self.metadata.versions if version.version_id == version_id)
+
+    def history(self) -> list[ViewHistoryEntry]:
+        """Get the version of this history view."""
+        return self.metadata.version_log
+
+    def properties(self) -> dict[str, str]:
+        """Return a map of string properties for this view."""
+        return self.metadata.properties
+
+    def location(self) -> str:
+        """Return the view's base location."""
+        return self.metadata.location
+
+    def uuid(self) -> str:
+        """Return the view's UUID."""
+        return self.metadata.view_uuid
+
+    def sql_for(self, dialect: str) -> SQLViewRepresentation:
+        """Return the view representation for the sql dialect."""
+        return next(repr.root for repr in self.current_version().representations if repr.root.dialect == dialect)
+
     def __eq__(self, other: Any) -> bool:
         """Return the equality of two instances of the View class."""
         return self.name() == other.name() and self.metadata == other.metadata if isinstance(other, View) else False