Mark Druffel
10/18/2024, 7:38 PMraw_tracks:
type: ibis.TableDataset
table_name: raw_tracks
connection:
backend: pyspark
database: comms_media_dev.dart_extensions
def load(self) -> ir.Table:
return self.connection.table(self._table_name)
I think updating load() seems fairly simple, something like the code below works, but was the initial intent that we could pass a catalog / database through the config here? If yes on the latter I think perhaps I'm not using the spark config properly or databricks is doing something strange... posted a question about that here for context.
def load(self) -> ir.Table:
return self.connection.table(name = self._table_name, database = self._database)
Deepyaman Datta
10/18/2024, 7:42 PMMark Druffel
10/18/2024, 7:42 PMDeepyaman Datta
10/18/2024, 7:43 PMI was just rereading that to try to figure that out, somehow already forgot about it 🤯
So did I 😀
Mark Druffel
10/18/2024, 7:43 PM