Skip to content

Commit

Permalink
initialized the base table in the base table dataset
Browse files Browse the repository at this point in the history
  • Loading branch information
MinuraPunchihewa committed Oct 4, 2024
1 parent f219ca4 commit 58a8691
Showing 1 changed file with 13 additions and 1 deletion.
14 changes: 13 additions & 1 deletion kedro-datasets/kedro_datasets/databricks/_base_table_dataset.py
Original file line number Diff line number Diff line change
Expand Up @@ -325,7 +325,19 @@ def _create_table( # noqa: PLR0913
Returns:
``BaseTable``: The new ``BaseTable`` instance.
"""
raise NotImplementedError
return BaseTable(
table=table,
catalog=catalog,
database=database,
format=format,
write_mode=write_mode,
location=location,
dataframe_type=dataframe_type,
json_schema=json_schema,
partition_columns=partition_columns,
owner_group=owner_group,
primary_key=primary_key,
)

def _load(self) -> DataFrame | pd.DataFrame:
"""Loads the version of data in the format defined in the init
Expand Down

0 comments on commit 58a8691

Please sign in to comment.