Package org.apache.iceberg

Class BaseMetastoreCatalog

java.lang.Object

org.apache.iceberg.BaseMetastoreCatalog

All Implemented Interfaces:

Closeable, AutoCloseable, Catalog

Direct Known Subclasses:

BaseMetastoreViewCatalog, BigQueryMetastoreCatalog, DynamoDbCatalog, EcsCatalog, GlueCatalog, HadoopCatalog, SnowflakeCatalog

public abstract class BaseMetastoreCatalog
extends Object
implements Catalog, Closeable

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected class	BaseMetastoreCatalog.BaseMetastoreCatalogTableBuilder

Nested classes/interfaces inherited from interface org.apache.iceberg.catalog.Catalog

Catalog.TableBuilder

Constructor Summary

Constructors

Constructor	Description
BaseMetastoreCatalog()

Method Summary

Modifier and Type	Method	Description
Catalog.TableBuilder	buildTable(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)
protected boolean	isValidMetadataIdentifier(TableIdentifier identifier)
Table	loadTable(TableIdentifier identifier)	Load a table.
protected MetricsReporter	metricsReporter()
protected abstract TableOperations	newTableOps(TableIdentifier tableIdentifier)
protected Map<String,String>	properties()
Table	registerTable(TableIdentifier identifier, String metadataFileLocation)	Register a table with the catalog if it does not exist.
String	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, registerTable, renameTable, tableExists

Constructor Details

BaseMetastoreCatalog

public BaseMetastoreCatalog()

Method Details

loadTable

public Table loadTable(TableIdentifier identifier)

Description copied from interface: Catalog

Load a table.

Specified by:

loadTable in interface Catalog

Parameters:

identifier - a table identifier

Returns:

instance of Table implementation referred by tableIdentifier

registerTable

public Table registerTable(TableIdentifier identifier,
 String metadataFileLocation)

Description copied from interface: Catalog

Register a table with the catalog if it does not exist.

For overwrite support, see Catalog.registerTable(TableIdentifier, String, boolean).

Specified by:

registerTable in interface Catalog

Parameters:

identifier - a table identifier

metadataFileLocation - the location of a metadata file

Returns:

a Table instance

buildTable

public Catalog.TableBuilder buildTable(TableIdentifier identifier,
 Schema schema)

Description copied from interface: Catalog

Instantiate a builder to either create a table or start a create/replace transaction.

Specified by:

buildTable in interface Catalog

Parameters:

identifier - a table identifier

schema - a schema

Returns:

the builder to create a table or start a create/replace transaction

isValidMetadataIdentifier

protected boolean isValidMetadataIdentifier(TableIdentifier identifier)

isValidIdentifier

protected boolean isValidIdentifier(TableIdentifier tableIdentifier)

properties

protected Map<String,String> properties()

toString

public String toString()

Overrides:

toString in class Object

newTableOps

protected abstract TableOperations newTableOps(TableIdentifier tableIdentifier)

defaultWarehouseLocation

protected abstract String defaultWarehouseLocation(TableIdentifier tableIdentifier)

fullTableName

protected static String fullTableName(String catalogName,
 TableIdentifier identifier)

metricsReporter

protected MetricsReporter metricsReporter()

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Throws:

IOException