From c02f6566bf09f4f6d406c33fab5c297084ccf72e Mon Sep 17 00:00:00 2001 From: FuYouJ <1247908487@qq.com> Date: Sat, 29 Jul 2023 21:46:44 +0800 Subject: [PATCH] =?UTF-8?q?=E5=88=A0=E9=99=A4=E5=A4=9A=E4=BD=99=E7=9A=84Pl?= =?UTF-8?q?uginLoader=E6=8E=A5=E5=8F=A3=E5=AE=9A=E4=B9=89?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit 删除多余的PluginLoader接口定义 --- .../com/alibaba/datax/core/job/JobContainer.java | 1 - .../datax/core/util/container/JarLoader.java | 2 +- .../core/util/container/PluginClassLoader.java | 11 +++++------ .../datax/core/util/container/PluginLoader.java | 16 ---------------- 4 files changed, 6 insertions(+), 24 deletions(-) delete mode 100644 core/src/main/java/com/alibaba/datax/core/util/container/PluginLoader.java 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; -}