public interface ExternalCatalog
ExternalCatalog
is the connector between an external database catalog and Flink's
Table API.
It provides information about catalogs, databases and tables such as names, schema, statistics, and access information.
Modifier and Type | Method and Description |
---|---|
ExternalCatalog |
getSubCatalog(String dbName)
Gets a sub catalog from this catalog.
|
ExternalCatalogTable |
getTable(String tableName)
Get a table from this catalog.
|
List<String> |
listSubCatalogs()
Gets the names of all sub catalogs registered in this catalog.
|
List<String> |
listTables()
Gets the names of all tables registered in this catalog.
|
ExternalCatalogTable getTable(String tableName) throws TableNotExistException
tableName
- The name of the table.TableNotExistException
- thrown if the table does not exist in the catalog.List<String> listTables()
ExternalCatalog getSubCatalog(String dbName) throws CatalogNotExistException
dbName
- (undocumented)CatalogNotExistException
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.