TableCatalog¶

TableCatalog is an extension of the CatalogPlugin abstraction for table catalogs.

Contract¶

Alter Table¶

Table alterTable(
  Identifier ident,
  TableChange... changes)

Changes (alters) a table based on the given TableChanges

Used when:

• AlterTableExec physical command is executed
• DelegatingCatalogExtension is requested to alterTable

Create Table¶

Table createTable(
  Identifier ident,
  Column[] columns,
  Transform[] partitions,
  Map<String, String> properties)

See:

• V2SessionCatalog

Used when the following commands are executed:

• CreateTableExec
• ReplaceTableExec
• CreateTableAsSelectExec
• ReplaceTableAsSelectExec

Drop Table¶

boolean dropTable(
  Identifier ident)

Used when the following commands are executed:

• DropTableExec
• ReplaceTableExec
• CreateTableAsSelectExec
• ReplaceTableAsSelectExec

List Tables¶

Identifier[] listTables(
  String[] namespace)

Used when the following commands are executed:

• DropNamespaceExec
• ShowTablesExec

Load Table¶

Table loadTable(
  Identifier ident)
Table loadTable(
  Identifier ident,
  long timestamp)
Table loadTable(
  Identifier ident,
  String version)

Used when:

• CatalogV2Util is requested to load a table
• DataFrameReader is requested to load (for SupportsCatalogOptions providers)
• DataFrameWriter is requested to save, insertInto and saveAsTable
• DelegatingCatalogExtension is requested to loadTable
• TableCatalog is requested to tableExists
• V2SessionCatalog is requested to createTable, alterTable, dropTable, renameTable

Rename Table¶

void renameTable(
  Identifier oldIdent,
  Identifier newIdent)

Used when the following commands are executed:

• RenameTableExec

Table Exists¶

boolean tableExists(
  Identifier ident)

Used when:

• The following commands are executed:
• AtomicCreateTableAsSelectExec
• AtomicReplaceTableAsSelectExec
• AtomicReplaceTableExec
• CreateTableAsSelectExec
• CreateTableExec
• DropTableExec
• ReplaceTableAsSelectExec

• ReplaceTableExec

• V2SessionCatalog is requested to renameTable

Implementations¶

• CatalogExtension
• JDBCTableCatalog
• StagingTableCatalog
• V2SessionCatalog