...
There are a few DDLs following that is already supported in SQL client. We want them should be migrated using the Flink Sql Parser approach properly.
Catalog DDL:
We propose to add the following DDLs related to catalog operations.
showCatalogsStatement
SHOW CATALOGS |
Return all catalogs in the current catalog.
note: already support in sql client but need support in TableEnvironment.
describeCatalogStatement
DESCRIBE CATALOG catalogName |
Return the default database name and expalnCatalog(newly added method in the catalog) content of an existing catalogName
Newly added method in Catalog.java:
/** |
use eg:
Flink SQL> describe catalog hiveCatalog; |
useCatalogStatement
USE CATALOG catalogName |
Set the current catalog.
note: already support in sql client but need support in tEnv.sqlUpdate();
Database DDL:
We propose to add the following DDLs related to database operations.
...