Skip to content

TableCatalog

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

Contract

Altering Table

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

Changes (alters) a table based on the given TableChanges

Used when:

createTable

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

Used when the following commands are executed:

dropTable

boolean dropTable(
  Identifier ident)

Used when the following commands are executed:

Listing Tables

Identifier[] listTables(
  String[] namespace)

Used when the following commands are executed:

Loading Table

Table loadTable(
  Identifier ident)

Used when:

renameTable

void renameTable(
  Identifier oldIdent,
  Identifier newIdent)

Used when the following commands are executed:

  • RenameTableExec

tableExists

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