SplinkDataFrame -> ABC

splink/splink_dataframe.py

@@ -1,6 +1,7 @@
 from __future__ import annotations
 
 import logging
+from abc import ABC, abstractmethod, abstractproperty
 from pathlib import Path
 from typing import TYPE_CHECKING
 
@@ -13,7 +14,7 @@
     from .database_api import DatabaseAPI
 
 
-class SplinkDataFrame:
+class SplinkDataFrame(ABC):
     """Abstraction over dataframe to handle basic operations like retrieving data and
     retrieving column names, which need different implementations depending on whether
     it's a spark dataframe, sqlite table etc.
@@ -35,7 +36,7 @@ def __init__(
         self.sql_used_to_create = None
         self.metadata = metadata or {}
 
-    @property
+    @abstractproperty
     def columns(self) -> list[InputColumn]:
         pass
 
@@ -44,6 +45,7 @@ def columns_escaped(self):
         cols = self.columns
         return [c.name for c in cols]
 
+    @abstractmethod
     def validate(self):
         pass