public abstract class AbstractCatalog extends Object implements Catalog
Catalog
.Catalog.DatabaseAlreadyExistException, Catalog.DatabaseNotEmptyException, Catalog.DatabaseNotExistException, Catalog.TableAlreadyExistException, Catalog.TableNotExistException
Modifier and Type | Field and Description |
---|---|
protected static String |
DB_SUFFIX |
DEFAULT_DATABASE, SYSTEM_TABLE_SPLITTER
Constructor and Description |
---|
AbstractCatalog() |
Modifier and Type | Method and Description |
---|---|
protected org.apache.flink.core.fs.Path |
databasePath(String database) |
Table |
getTable(org.apache.flink.table.catalog.ObjectPath tablePath)
Return a
Table identified by the given ObjectPath . |
org.apache.flink.core.fs.Path |
getTableLocation(org.apache.flink.table.catalog.ObjectPath tablePath)
Return the table location path identified by the given
ObjectPath . |
protected abstract String |
warehouse() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
alterTable, createDatabase, createTable, databaseExists, dropDatabase, dropTable, getTableSchema, listDatabases, listTables, lockFactory, renameTable, tableExists
close
protected static final String DB_SUFFIX
public org.apache.flink.core.fs.Path getTableLocation(org.apache.flink.table.catalog.ObjectPath tablePath)
Catalog
ObjectPath
.getTableLocation
in interface Catalog
tablePath
- Path of the tablepublic Table getTable(org.apache.flink.table.catalog.ObjectPath tablePath) throws Catalog.TableNotExistException
Catalog
Table
identified by the given ObjectPath
.getTable
in interface Catalog
tablePath
- Path of the tableCatalog.TableNotExistException
- if the target does not existprotected org.apache.flink.core.fs.Path databasePath(String database)
protected abstract String warehouse()
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.