add abstract methods to additional classes

Author: rambleraptor

pyiceberg/catalog/dynamodb.py

@@ -550,6 +550,9 @@ def drop_view(self, identifier: Union[str, Identifier]) -> None:
     def view_exists(self, identifier: Union[str, Identifier]) -> bool:
         raise NotImplementedError
 
+    def rename_view(self, from_identifier: Union[str, Identifier], to_identifier: Union[str, Identifier]) -> None:
+        raise NotImplementedError
+
     def _get_iceberg_table_item(self, database_name: str, table_name: str) -> Dict[str, Any]:
         try:
             return self._get_dynamo_item(identifier=f"{database_name}.{table_name}", namespace=database_name)

pyiceberg/catalog/glue.py

@@ -826,6 +826,9 @@ def drop_view(self, identifier: Union[str, Identifier]) -> None:
     def view_exists(self, identifier: Union[str, Identifier]) -> bool:
         raise NotImplementedError
 
+    def rename_view(self, from_identifier: Union[str, Identifier], to_identifier: Union[str, Identifier]) -> None:
+        raise NotImplementedError
+
     @staticmethod
     def __is_iceberg_table(table: "TableTypeDef") -> bool:
         return table.get("Parameters", {}).get(TABLE_TYPE, "").lower() == ICEBERG

pyiceberg/catalog/hive.py

@@ -480,6 +480,9 @@ def list_views(self, namespace: Union[str, Identifier]) -> List[Identifier]:
     def view_exists(self, identifier: Union[str, Identifier]) -> bool:
         raise NotImplementedError
 
+    def rename_view(self, from_identifier: Union[str, Identifier], to_identifier: Union[str, Identifier]) -> None:
+        raise NotImplementedError
+
     def _create_lock_request(self, database_name: str, table_name: str) -> LockRequest:
         lock_component: LockComponent = LockComponent(
             level=LockLevel.TABLE, type=LockType.EXCLUSIVE, dbname=database_name, tablename=table_name, isTransactional=True

pyiceberg/catalog/noop.py

@@ -128,3 +128,6 @@ def view_exists(self, identifier: Union[str, Identifier]) -> bool:
 
     def drop_view(self, identifier: Union[str, Identifier]) -> None:
         raise NotImplementedError
+
+    def rename_view(self, from_identifier: Union[str, Identifier], to_identifier: Union[str, Identifier]) -> None:
+        raise NotImplementedError

pyiceberg/catalog/sql.py

@@ -744,3 +744,6 @@ def close(self) -> None:
         """
         if hasattr(self, "engine"):
             self.engine.dispose()
+
+    def rename_view(self, from_identifier: Union[str, Identifier], to_identifier: Union[str, Identifier]) -> None:
+        raise NotImplementedError