Skip to content

Commit

Permalink
Clean up.
Browse files Browse the repository at this point in the history
  • Loading branch information
Tang8330 committed Sep 29, 2024
1 parent 906c223 commit 1b1ae21
Showing 1 changed file with 15 additions and 14 deletions.
29 changes: 15 additions & 14 deletions clients/databricks/store.go
Original file line number Diff line number Diff line change
Expand Up @@ -33,27 +33,28 @@ func (s Store) Dialect() sql.Dialect {
}

func (s Store) Dedupe(tableID sql.TableIdentifier, primaryKeys []string, includeArtieUpdatedAt bool) error {
//return shared.Dedupe(s, tableID, primaryKeys, includeArtieUpdatedAt)
panic("not implemented")
}

func (s Store) GetTableConfig(tableData *optimization.TableData) (*types.DwhTableConfig, error) {
tableID := s.IdentifierFor(tableData.TopicConfig(), tableData.Name())
panic("not implemented")
//tableID := s.IdentifierFor(tableData.TopicConfig(), tableData.Name())
//query, args := describeTableQuery(tableID)
return shared.GetTableCfgArgs{
Dwh: s,
TableID: tableID,
ConfigMap: s.configMap,
Query: query,
Args: args,
ColumnNameForName: "column_name",
ColumnNameForDataType: "data_type",
ColumnNameForComment: "description",
DropDeletedColumns: tableData.TopicConfig().DropDeletedColumns,
}.GetTableConfig()
//return shared.GetTableCfgArgs{
// Dwh: s,
// TableID: tableID,
// ConfigMap: s.configMap,
// Query: query,
// Args: args,
// ColumnNameForName: "column_name",
// ColumnNameForDataType: "data_type",
// ColumnNameForComment: "description",
// DropDeletedColumns: tableData.TopicConfig().DropDeletedColumns,
//}.GetTableConfig()
}

func (s Store) PrepareTemporaryTable(tableData *optimization.TableData, tableConfig *types.DwhTableConfig, tempTableID sql.TableIdentifier, parentTableID sql.TableIdentifier, additionalSettings types.AdditionalSettings, createTempTable bool) error {
//return shared.PrepareTemporaryTable(s, tableData, tableConfig, tempTableID, parentTableID, additionalSettings, createTempTable)
panic("not implemented")
}

func LoadStore(cfg config.Config) (Store, error) {
Expand Down

0 comments on commit 1b1ae21

Please sign in to comment.