hackergin commented on code in PR #23036:
URL: https://github.com/apache/flink/pull/23036#discussion_r1270225796
##########
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/factories/TableFactoryUtil.java:
##########
@@ -196,4 +204,92 @@ public ClassLoader getUserClassLoader() {
}))
.collect(Collectors.toList());
}
+
+ /**
+ * Finds and creates a {@link CatalogStore} using the provided {@link
Configuration} and user
+ * classloader.
+ *
+ * <p>The configuration format should be as follows:
+ *
+ * <pre>{@code
+ * table.catalog-store.kind: {identifier}
+ * table.catalog-store.{identifier}.{param1}: xxx
+ * table.catalog-store.{identifier}.{param2}: xxx
+ * }</pre>
+ */
+ public static CatalogStore findAndCreateCatalogStore(
Review Comment:
The flink-table-api-scala-bridge module does not have a dependency on
flink-table-common, so I added it here.
--
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.
To unsubscribe, e-mail: issues-unsubscr...@flink.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
