CatalogImpl¶

CatalogImpl is a Catalog.

CatalogImpl uses SessionCatalog (through SparkSession)

Creating Instance¶

CatalogImpl takes the following to be created:

SparkSession

CatalogImpl is created when:

SparkSession is requested for the Catalog

listColumns¶

Signature

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¶

Signature

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:

CatalogImpl is requested to listTables and getTable

loadTable¶

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

loadTable...FIXME