public abstract class BaseMetastoreCatalog extends java.lang.Object implements Catalog
Modifier and Type | Class and Description |
---|---|
protected class |
BaseMetastoreCatalog.BaseMetastoreCatalogTableBuilder |
Catalog.TableBuilder
Constructor and Description |
---|
BaseMetastoreCatalog() |
Modifier and Type | Method and Description |
---|---|
Catalog.TableBuilder |
buildTable(TableIdentifier identifier,
Schema schema)
/** Instantiate a builder to either create a table or start a create/replace transaction.
|
protected abstract java.lang.String |
defaultWarehouseLocation(TableIdentifier tableIdentifier) |
protected static java.lang.String |
fullTableName(java.lang.String catalogName,
TableIdentifier identifier) |
protected boolean |
isValidIdentifier(TableIdentifier tableIdentifier) |
Table |
loadTable(TableIdentifier identifier)
Load a table.
|
protected abstract TableOperations |
newTableOps(TableIdentifier tableIdentifier) |
protected java.util.Map<java.lang.String,java.lang.String> |
properties() |
Table |
registerTable(TableIdentifier identifier,
java.lang.String metadataFileLocation)
Register a table with the catalog if it does not exist.
|
java.lang.String |
toString() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
createTable, createTable, createTable, createTable, dropTable, dropTable, initialize, invalidateTable, listTables, name, newCreateTableTransaction, newCreateTableTransaction, newCreateTableTransaction, newCreateTableTransaction, newReplaceTableTransaction, newReplaceTableTransaction, newReplaceTableTransaction, newReplaceTableTransaction, renameTable, tableExists
public Table loadTable(TableIdentifier identifier)
Catalog
public Table registerTable(TableIdentifier identifier, java.lang.String metadataFileLocation)
Catalog
registerTable
in interface Catalog
identifier
- a table identifiermetadataFileLocation
- the location of a metadata filepublic Catalog.TableBuilder buildTable(TableIdentifier identifier, Schema schema)
Catalog
buildTable
in interface Catalog
identifier
- a table identifierschema
- a schemaprotected boolean isValidIdentifier(TableIdentifier tableIdentifier)
protected java.util.Map<java.lang.String,java.lang.String> properties()
public java.lang.String toString()
toString
in class java.lang.Object
protected abstract TableOperations newTableOps(TableIdentifier tableIdentifier)
protected abstract java.lang.String defaultWarehouseLocation(TableIdentifier tableIdentifier)
protected static java.lang.String fullTableName(java.lang.String catalogName, TableIdentifier identifier)