Skip to content

CatalogImpl

CatalogImpl is a Catalog.

CatalogImpl uses SessionCatalog (through SparkSession)

Creating Instance

CatalogImpl takes the following to be created:

CatalogImpl is created when:

  • SparkSession is requested for the Catalog

listColumns

Catalog 
listColumns(
  ident: Seq[String]): Dataset[Column]
listColumns(
  tableName: String): Dataset[Column]
listColumns(
  dbName: String,
  tableName: String): Dataset[Column]

listColumns is part of the Catalog abstraction.

listColumns...FIXME

In the end, listColumns makeDataset with the columns.

getTable

Catalog 
getTable(
  tableName: String): Table
getTable(
  dbName: String,
  tableName: String): Table

getTable is part of the Catalog abstraction.

getTable...FIXME

Looking Up Table

makeTable(
  catalog: TableCatalog,
  ident: Identifier): Option[Table]

makeTable...FIXME

makeTable is used when:

loadTable

loadTable(
  catalog: TableCatalog,
  ident: Identifier): Option[Table]

loadTable...FIXME

getNamespace

getNamespace(
  catalog: CatalogPlugin,
  ns: Seq[String]): Database

getNamespace...FIXME

getNamespace is used when: