diff --git a/core/src/main/java/com/alibaba/datax/core/job/JobContainer.java b/core/src/main/java/com/alibaba/datax/core/job/JobContainer.java index 03830100..49f5a0a1 100755 --- a/core/src/main/java/com/alibaba/datax/core/job/JobContainer.java +++ b/core/src/main/java/com/alibaba/datax/core/job/JobContainer.java @@ -653,7 +653,6 @@ public class JobContainer extends AbstractContainer { */ private Reader.Job initJobReader( JobPluginCollector jobPluginCollector) { - //TODO loadUtil加载或者是 pluginUtil加载 this.readerPluginName = this.configuration.getString( CoreConstant.DATAX_JOB_CONTENT_READER_NAME); classLoaderSwapper.setCurrentThreadClassLoader(LoadUtil.getJarLoader( diff --git a/core/src/main/java/com/alibaba/datax/core/util/container/JarLoader.java b/core/src/main/java/com/alibaba/datax/core/util/container/JarLoader.java index 513a090d..ddf22bae 100755 --- a/core/src/main/java/com/alibaba/datax/core/util/container/JarLoader.java +++ b/core/src/main/java/com/alibaba/datax/core/util/container/JarLoader.java @@ -15,7 +15,7 @@ import java.util.List; /** * 提供Jar隔离的加载机制,会把传入的路径、及其子路径、以及路径中的jar文件加入到class path。 */ -public class JarLoader extends URLClassLoader implements PluginLoader{ +public class JarLoader extends URLClassLoader{ public JarLoader(String[] paths) { this(paths, JarLoader.class.getClassLoader()); } diff --git a/core/src/main/java/com/alibaba/datax/core/util/container/PluginClassLoader.java b/core/src/main/java/com/alibaba/datax/core/util/container/PluginClassLoader.java index 38ba952c..a45c2b83 100644 --- a/core/src/main/java/com/alibaba/datax/core/util/container/PluginClassLoader.java +++ b/core/src/main/java/com/alibaba/datax/core/util/container/PluginClassLoader.java @@ -1,10 +1,9 @@ package com.alibaba.datax.core.util.container; -/** - * {@code Author} FuYouJ - * {@code Date} 2023/7/23 16:52 - * @author fuyouj - */ -public class PluginClassLoader extends ClassLoader implements PluginLoader{ +/** + * @author fuyouj + * ClassLoader 抽象类的具体实现类,用于在运行时反射加载插件 + */ +public class PluginClassLoader extends ClassLoader{ } diff --git a/core/src/main/java/com/alibaba/datax/core/util/container/PluginLoader.java b/core/src/main/java/com/alibaba/datax/core/util/container/PluginLoader.java deleted file mode 100644 index 5e79a548..00000000 --- a/core/src/main/java/com/alibaba/datax/core/util/container/PluginLoader.java +++ /dev/null @@ -1,16 +0,0 @@ -package com.alibaba.datax.core.util.container; - - -/** - * @author fuyouj - */ -public interface PluginLoader { - /** - * 加载插件对象 - * - * @param name 类全限定名 - * @return class对象 - * @throws ClassNotFoundException - */ - Class loadClass(String name) throws ClassNotFoundException; -}