MCPcopy Create free account
hub / github.com/featureform/featureform / GetPrimaryTable

Method GetPrimaryTable

provider/sql.go:306–324  ·  view source on GitHub ↗
(id ResourceID)

Source from the content-addressed store, hash-verified

304}
305
306func (store *sqlOfflineStore) GetPrimaryTable(id ResourceID) (PrimaryTable, error) {
307 name, err := GetPrimaryTableName(id)
308 if err != nil {
309 return nil, err
310 }
311 if exists, err := store.tableExists(id); err != nil {
312 return nil, err
313 } else if !exists {
314 return nil, &TableNotFound{id.Name, id.Variant}
315 }
316 columnNames, err := store.query.getColumns(store.db, name)
317
318 return &sqlPrimaryTable{
319 db: store.db,
320 name: name,
321 schema: TableSchema{Columns: columnNames},
322 query: store.query,
323 }, nil
324}
325
326func (store *sqlOfflineStore) GetTransformationTable(id ResourceID) (TransformationTable, error) {
327 name, err := GetPrimaryTableName(id)

Callers

nothing calls this directly

Calls 3

tableExistsMethod · 0.95
GetPrimaryTableNameFunction · 0.85
getColumnsMethod · 0.65

Tested by

no test coverage detected