Package org.apache.iceberg
Class BaseMetastoreCatalog
java.lang.Object
org.apache.iceberg.BaseMetastoreCatalog
- All Implemented Interfaces:
Closeable
,AutoCloseable
,Catalog
- Direct Known Subclasses:
BaseMetastoreViewCatalog
,DynamoDbCatalog
,EcsCatalog
,GlueCatalog
,HadoopCatalog
,HiveCatalog
,SnowflakeCatalog
-
Nested Class Summary
Modifier and TypeClassDescriptionprotected class
Nested classes/interfaces inherited from interface org.apache.iceberg.catalog.Catalog
Catalog.TableBuilder
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionbuildTable
(TableIdentifier identifier, Schema schema) /** Instantiate a builder to either create a table or start a create/replace transaction.void
close()
protected abstract String
defaultWarehouseLocation
(TableIdentifier tableIdentifier) protected static String
fullTableName
(String catalogName, TableIdentifier identifier) protected boolean
isValidIdentifier
(TableIdentifier tableIdentifier) loadTable
(TableIdentifier identifier) Load a table.protected MetricsReporter
protected abstract TableOperations
newTableOps
(TableIdentifier tableIdentifier) registerTable
(TableIdentifier identifier, String metadataFileLocation) Register a table with the catalog if it does not exist.toString()
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
Methods inherited from interface org.apache.iceberg.catalog.Catalog
createTable, createTable, createTable, createTable, dropTable, dropTable, initialize, invalidateTable, listTables, name, newCreateTableTransaction, newCreateTableTransaction, newCreateTableTransaction, newCreateTableTransaction, newReplaceTableTransaction, newReplaceTableTransaction, newReplaceTableTransaction, newReplaceTableTransaction, renameTable, tableExists
-
Constructor Details
-
BaseMetastoreCatalog
public BaseMetastoreCatalog()
-
-
Method Details
-
loadTable
Description copied from interface:Catalog
Load a table. -
registerTable
Description copied from interface:Catalog
Register a table with the catalog if it does not exist.- Specified by:
registerTable
in interfaceCatalog
- Parameters:
identifier
- a table identifiermetadataFileLocation
- the location of a metadata file- Returns:
- a Table instance
-
buildTable
Description copied from interface:Catalog
/** Instantiate a builder to either create a table or start a create/replace transaction.- Specified by:
buildTable
in interfaceCatalog
- Parameters:
identifier
- a table identifierschema
- a schema- Returns:
- the builder to create a table or start a create/replace transaction
-
isValidIdentifier
-
properties
-
toString
-
newTableOps
-
defaultWarehouseLocation
-
fullTableName
-
metricsReporter
-
close
- Specified by:
close
in interfaceAutoCloseable
- Specified by:
close
in interfaceCloseable
- Throws:
IOException
-