TableCatalog¶
TableCatalog
is an extension of the CatalogPlugin abstraction for table catalogs.
Contract¶
alterTable¶
Table alterTable(
Identifier ident,
TableChange... changes)
Used when the following commands are executed:
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:
invalidateTable¶
void invalidateTable(
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:
CatalogV2Util
is requested to load a tableDataFrameReader
is requested to load (for SupportsCatalogOptions providers)DataFrameWriter
is requested to save, insertInto and saveAsTableDelegatingCatalogExtension
is requested to loadTableTableCatalog
is requested to tableExistsV2SessionCatalog
is requested to createTable, alterTable, dropTable, renameTable
renameTable¶
void renameTable(
Identifier oldIdent,
Identifier newIdent)
Used when the following commands are executed:
tableExists¶
boolean tableExists(
Identifier ident)
Used when:
- The following commands are executed:
- AtomicCreateTableAsSelectExec
- AtomicReplaceTableAsSelectExec
- AtomicReplaceTableExec
- CreateTableAsSelectExec
- CreateTableExec
- DropTableExec
- ReplaceTableAsSelectExec
-
V2SessionCatalog
is requested to renameTable
Implementations¶
Last update: 2020-12-28