Class BaseMetastoreCatalog

java.lang.Object
org.apache.iceberg.BaseMetastoreCatalog
All Implemented Interfaces:
Closeable, AutoCloseable, Catalog
Direct Known Subclasses:
BaseMetastoreViewCatalog, DynamoDbCatalog, EcsCatalog, GlueCatalog, HadoopCatalog, SnowflakeCatalog

public abstract class BaseMetastoreCatalog extends Object implements Catalog, Closeable
  • Constructor Details Link icon

    • BaseMetastoreCatalog Link icon

      public BaseMetastoreCatalog()
  • Method Details Link icon

    • loadTable Link icon

      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 Link icon

      public Table registerTable(TableIdentifier identifier, String metadataFileLocation)
      Description copied from interface: Catalog
      Register a table with the catalog if it does not exist.
      Specified by:
      registerTable in interface Catalog
      Parameters:
      identifier - a table identifier
      metadataFileLocation - the location of a metadata file
      Returns:
      a Table instance
    • buildTable Link icon

      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
    • isValidIdentifier Link icon

      protected boolean isValidIdentifier(TableIdentifier tableIdentifier)
    • properties Link icon

      protected Map<String,String> properties()
    • toString Link icon

      public String toString()
      Overrides:
      toString in class Object
    • newTableOps Link icon

      protected abstract TableOperations newTableOps(TableIdentifier tableIdentifier)
    • defaultWarehouseLocation Link icon

      protected abstract String defaultWarehouseLocation(TableIdentifier tableIdentifier)
    • fullTableName Link icon

      protected static String fullTableName(String catalogName, TableIdentifier identifier)
    • metricsReporter Link icon

      protected MetricsReporter metricsReporter()
    • close Link icon

      public void close() throws IOException
      Specified by:
      close in interface AutoCloseable
      Specified by:
      close in interface Closeable
      Throws:
      IOException