diff --git a/servc/svc/com/storage/delta.py b/servc/svc/com/storage/delta.py index 9f606d5..b550ac0 100644 --- a/servc/svc/com/storage/delta.py +++ b/servc/svc/com/storage/delta.py @@ -6,6 +6,7 @@ from pyarrow import Schema, Table from servc.svc.com.storage.lake import Lake, LakeTable +from servc.svc.com.storage.tenant import TenantTable from servc.svc.config import Config @@ -186,3 +187,7 @@ def _close(self): self._isOpen = False return True return False + + +class DeltaTenant(TenantTable, Delta): + pass diff --git a/servc/svc/com/storage/iceberg.py b/servc/svc/com/storage/iceberg.py index c8e53da..e12459d 100644 --- a/servc/svc/com/storage/iceberg.py +++ b/servc/svc/com/storage/iceberg.py @@ -12,6 +12,7 @@ from pyiceberg.types import NestedField from servc.svc.com.storage.lake import Lake, LakeTable +from servc.svc.com.storage.tenant import TenantTable from servc.svc.config import Config @@ -198,3 +199,7 @@ def read( ) -> paTable: data = self.readRaw(columns, partitions, version, options) return data.to_arrow() + + +class IceBergTenant(TenantTable, IceBerg): + pass