xuefuz commented on a change in pull request #8404: [FLINK-11476][table] Create
CatalogManager to manage multiple catalogs
URL: https://github.com/apache/flink/pull/8404#discussion_r282893011
##########
File path:
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/TableEnvironment.java
##########
@@ -280,6 +316,55 @@
*/
void sqlUpdate(String stmt, QueryConfig config);
+ /**
+ * Gets the current default catalog name of the current session.
+ *
+ * @return the current default catalog that is used for path resolution
+ * @see TableEnvironment#setCurrentCatalog(String)
+ */
+ String getCurrentCatalogName();
Review comment:
Nit: I wonder if we just name it getCurrentCatalog(), which returns the name
of the current catalog. (Same for get current database name. I understand that
the given name is more explicit, but getCurrentCatalog() is a mirror of the set
method below and is more consistent with catalog APIs in which, every get
(table, database) is named getXxx() instead of getXxxName().
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
With regards,
Apache Git Services
