Class BaseMetastoreCatalog

    • Constructor Detail

      • BaseMetastoreCatalog

        public BaseMetastoreCatalog()
    • Method Detail

      • 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,
                                   java.lang.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

        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

        protected boolean isValidIdentifier​(TableIdentifier tableIdentifier)
      • properties

        protected java.util.Map<java.lang.String,​java.lang.String> properties()
      • toString

        public java.lang.String toString()
        Overrides:
        toString in class java.lang.Object
      • defaultWarehouseLocation

        protected abstract java.lang.String defaultWarehouseLocation​(TableIdentifier tableIdentifier)
      • fullTableName

        protected static java.lang.String fullTableName​(java.lang.String catalogName,
                                                        TableIdentifier identifier)
      • close

        public void close()
                   throws java.io.IOException
        Specified by:
        close in interface java.lang.AutoCloseable
        Specified by:
        close in interface java.io.Closeable
        Throws:
        java.io.IOException