rename

Author: jiemotongxue

core/src/main/java/com/dtstack/flink/sql/classloader/ClassLoaderManager.java

@@ -26,7 +26,6 @@
 import java.net.URL;
 import java.util.ArrayList;
 import java.util.Arrays;
-import java.util.Collections;
 import java.util.Comparator;
 import java.util.List;
 import java.util.Map;
@@ -43,14 +42,14 @@ public class ClassLoaderManager {
 
     private static Map<String, DtClassLoader> pluginClassLoader = new ConcurrentHashMap<>();
 
-    public static <R> R newInstance(String pluginJarPath, DtSupplier<R> supplier) throws Exception {
+    public static <R> R newInstance(String pluginJarPath, ClassLoaderSupplier<R> supplier) throws Exception {
         ClassLoader classLoader = retrieveClassLoad(pluginJarPath);
-        return ClassLoaderCallBackMethod.callbackAndReset(supplier, classLoader);
+        return ClassLoaderSupplierCallBack.callbackAndReset(supplier, classLoader);
     }
 
-    public static <R> R newInstance(List<URL> jarUrls, DtSupplier<R> supplier) throws Exception {
+    public static <R> R newInstance(List<URL> jarUrls, ClassLoaderSupplier<R> supplier) throws Exception {
         ClassLoader classLoader = retrieveClassLoad(jarUrls);
-        return ClassLoaderCallBackMethod.callbackAndReset(supplier, classLoader);
+        return ClassLoaderSupplierCallBack.callbackAndReset(supplier, classLoader);
     }
 
     private static DtClassLoader retrieveClassLoad(String pluginJarPath) {

…ck/flink/sql/classloader/DtSupplier.java …sql/classloader/ClassLoaderSupplier.javacore/src/main/java/com/dtstack/flink/sql/classloader/DtSupplier.java renamed to core/src/main/java/com/dtstack/flink/sql/classloader/ClassLoaderSupplier.java core/src/main/java/com/dtstack/flink/sql/classloader/DtSupplier.java renamed to core/src/main/java/com/dtstack/flink/sql/classloader/ClassLoaderSupplier.java

@@ -33,7 +33,7 @@
  * @since 1.8
  */
 @FunctionalInterface
-public interface DtSupplier<T> {
+public interface ClassLoaderSupplier<T> {
 
     /**
      * Gets a result.

…assloader/ClassLoaderCallBackMethod.java …sloader/ClassLoaderSupplierCallBack.javacore/src/main/java/com/dtstack/flink/sql/classloader/ClassLoaderCallBackMethod.java renamed to core/src/main/java/com/dtstack/flink/sql/classloader/ClassLoaderSupplierCallBack.java core/src/main/java/com/dtstack/flink/sql/classloader/ClassLoaderCallBackMethod.java renamed to core/src/main/java/com/dtstack/flink/sql/classloader/ClassLoaderSupplierCallBack.java

@@ -24,9 +24,9 @@
  * author: toutian
  * create: 2019/10/14
  */
-public class ClassLoaderCallBackMethod {
+public class ClassLoaderSupplierCallBack {
 
-    public static <R> R callbackAndReset(DtSupplier<R> supplier, ClassLoader toSetClassLoader) throws Exception {
+    public static <R> R callbackAndReset(ClassLoaderSupplier<R> supplier, ClassLoader toSetClassLoader) throws Exception {
         ClassLoader oldClassLoader = Thread.currentThread().getContextClassLoader();
         Thread.currentThread().setContextClassLoader(toSetClassLoader);
         try {