TableCatalog¶

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

Contract¶

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

TableChanges to alter a table

Used when:

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

Used when the following commands are executed:

boolean dropTable(
  Identifier ident)

Used when the following commands are executed:

void invalidateTable(
  Identifier ident)

Used when the following commands are executed:

Identifier[] listTables(
  String[] namespace)

Used when the following commands are executed:

Table loadTable(
  Identifier ident)

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

void renameTable(
  Identifier oldIdent,
  Identifier newIdent)

Used when the following commands are executed:

boolean tableExists(
  Identifier ident)

Used when: