twalthr 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_r283705599
##########
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();
+
+ /**
+ * Sets the current catalog to the given value. It also sets the default
+ * database to the catalog's default one. To assign both catalog and
database explicitly
+ * see {@link TableEnvironment#setCurrentDatabase(String, String)}.
+ *
+ * <p>This is used during resolution of object paths. The default path
is constructed as
+ * {@code [current-catalog].[current.database]}. During the resolution,
first we try to look for
+ * {@code [default-path].[object-path]} if no object is found we assume
the object path is a fully
+ * qualified one and we look for {@code [object-path]}.
Review comment:
Can we add examples to both this method and database method?
----------------------------------------------------------------
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
