(flink) 01/02: [FLINK-36634][table] Move the PlannerModule to the flink-table-api-java module so that the planner code can be accessed by the runtime.

[zhuzh]

This is an automated email from the ASF dual-hosted git repository.

zhuzh pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git

commit acf39139a8a362eeff9ec0430a1780e207d9d4d4
Author: sunxia <xingbe...@gmail.com>
AuthorDate: Thu Oct 31 11:53:49 2024 +0800

    [FLINK-36634][table] Move the PlannerModule to the flink-table-api-java 
module so that the planner code can be accessed by the runtime.
---
 .../java/org/apache/flink/table/planner/loader/PlannerModule.java | 8 +++++++-
 1 file changed, 7 insertions(+), 1 deletion(-)

diff --git 
a/flink-table/flink-table-planner-loader/src/main/java/org/apache/flink/table/planner/loader/PlannerModule.java
 
b/flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/planner/loader/PlannerModule.java
similarity index 97%
rename from 
flink-table/flink-table-planner-loader/src/main/java/org/apache/flink/table/planner/loader/PlannerModule.java
rename to 
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/planner/loader/PlannerModule.java
index 76f0ad0e9e3..bc3b004bc0c 100644
--- 
a/flink-table/flink-table-planner-loader/src/main/java/org/apache/flink/table/planner/loader/PlannerModule.java
+++ 
b/flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/planner/loader/PlannerModule.java
@@ -18,6 +18,7 @@
 
 package org.apache.flink.table.planner.loader;
 
+import org.apache.flink.annotation.Internal;
 import org.apache.flink.configuration.Configuration;
 import org.apache.flink.configuration.ConfigurationUtils;
 import org.apache.flink.configuration.CoreOptions;
@@ -49,7 +50,8 @@ import java.util.stream.Stream;
  * ClassLoader#getResource(String)}. It will extract the jar into a temporary 
directory and create a
  * new {@link SubmoduleClassLoader} to load the various planner factories from 
that jar.
  */
-class PlannerModule {
+@Internal
+public class PlannerModule {
 
     /**
      * The name of the table planner dependency jar, bundled with 
flink-table-planner-loader module
@@ -132,6 +134,10 @@ class PlannerModule {
         }
     }
 
+    public ClassLoader getSubmoduleClassLoader() {
+        return this.submoduleClassLoader;
+    }
+
     public void addUrlToClassLoader(URL url) {
         // add the url to component url
         this.submoduleClassLoader.addURL(url);