(self, config)
| 3 | |
| 4 | class BaseTask: |
| 5 | def __init__(self, config): |
| 6 | self.config = config |
| 7 | self.spark = config.get_spark() |
| 8 | self.logger = logging.getLogger(f"template.{self.__class__.__name__}") |
| 9 | |
| 10 | def cluster_by(self, table: str, *cols: str) -> None: |
| 11 | """Set Delta liquid-clustering keys on an existing table. |