[Refactor][SPI] Refactor spi module

datavines-connector/datavines-connector-api/src/main/java/io/datavines/connector/api/ConnectorFactory.java

@@ -16,11 +16,17 @@
  */
 package io.datavines.connector.api;
 
-import io.datavines.spi.SPI;;
+import java.util.Collection;
+import java.util.Collections;
 
-@SPI
 public interface ConnectorFactory {
 
+    String getPluginName();
+
+    default Collection<String> getPluginNames() {
+        return Collections.singletonList(getPluginName());
+    }
+
     String getCategory();
 
     Connector getConnector();

datavines-connector/datavines-connector-plugins/datavines-connector-clickhouse/src/main/java/io/datavines/connector/plugin/ClickHouseConnectorFactory.java

@@ -54,4 +54,9 @@ public ConfigBuilder getConfigBuilder() {
     public TypeConverter getTypeConverter() {
         return new ClickHouseTypeConverter();
     }
+
+    @Override
+    public String getPluginName() {
+        return "clickhouse";
+    }
 }

datavines-connector/datavines-connector-plugins/datavines-connector-clickhouse/src/main/resources/META-INF/services/io.datavines.connector.api.ConnectorFactory

@@ -0,0 +1 @@
+io.datavines.connector.plugin.ClickHouseConnectorFactory

datavines-connector/datavines-connector-plugins/datavines-connector-databend/src/main/java/io/datavines/connector/plugin/DatabendConnectorFactory.java

@@ -44,4 +44,9 @@ public Executor getExecutor() {
     public ConfigBuilder getConfigBuilder() {
         return new DatabendConfigBuilder();
     }
+
+    @Override
+    public String getPluginName() {
+        return "databend";
+    }
 }

datavines-connector/datavines-connector-plugins/datavines-connector-databend/src/main/resources/META-INF/services/io.datavines.connector.api.ConnectorFactory

@@ -0,0 +1 @@
+io.datavines.connector.plugin.DatabendConnectorFactory

datavines-connector/datavines-connector-plugins/datavines-connector-dm/src/main/java/io/datavines/connector/plugin/DmConnectorFactory.java

@@ -44,4 +44,9 @@ public Executor getExecutor() {
     public ConfigBuilder getConfigBuilder() {
         return new DmConfigBuilder();
     }
+
+    @Override
+    public String getPluginName() {
+        return "dm";
+    }
 }

datavines-connector/datavines-connector-plugins/datavines-connector-dm/src/main/resources/META-INF/services/io.datavines.connector.api.ConnectorFactory

@@ -0,0 +1 @@
+io.datavines.connector.plugin.DmConnectorFactory

datavines-connector/datavines-connector-plugins/datavines-connector-doris/src/main/java/io/datavines/connector/plugin/DorisConnectorFactory.java

@@ -44,4 +44,9 @@ public Executor getExecutor() {
     public ConfigBuilder getConfigBuilder() {
         return new DorisConfigBuilder();
     }
+
+    @Override
+    public String getPluginName() {
+        return "doris";
+    }
 }

datavines-connector/datavines-connector-plugins/datavines-connector-doris/src/main/resources/META-INF/services/io.datavines.connector.api.ConnectorFactory

@@ -0,0 +1 @@
+io.datavines.connector.plugin.DorisConnectorFactory

datavines-connector/datavines-connector-plugins/datavines-connector-file/src/main/java/io/datavines/connector/plugin/FileConnectorFactory.java

@@ -84,4 +84,9 @@ public MetricScript getMetricScript() {
     public Boolean showInFrontend() {
         return false;
     }
+
+    @Override
+    public String getPluginName() {
+        return "file";
+    }
 }

datavines-connector/datavines-connector-plugins/datavines-connector-file/src/main/resources/META-INF/services/io.datavines.connector.api.ConnectorFactory

@@ -0,0 +1 @@
+io.datavines.connector.plugin.FileConnectorFactory

datavines-connector/datavines-connector-plugins/datavines-connector-flink/src/main/java/io/datavines/connector/plugin/FlinkConnectorFactory.java

@@ -49,4 +49,9 @@ public MetricScript getMetricScript() {
     public Boolean showInFrontend() {
         return false;
     }
+
+    @Override
+    public String getPluginName() {
+        return "flink";
+    }
 }

datavines-connector/datavines-connector-plugins/datavines-connector-flink/src/main/resources/META-INF/services/io.datavines.connector.api.ConnectorFactory

@@ -0,0 +1 @@
+io.datavines.connector.plugin.FlinkConnectorFactory

datavines-connector/datavines-connector-plugins/datavines-connector-hive/src/main/java/io/datavines/connector/plugin/HiveConnectorFactory.java

@@ -54,4 +54,9 @@ public MetricScript getMetricScript() {
     public DataSourceClient getDataSourceClient() {
         return new HiveDataSourceClient();
     }
+
+    @Override
+    public String getPluginName() {
+        return "hive";
+    }
 }

datavines-connector/datavines-connector-plugins/datavines-connector-hive/src/main/resources/META-INF/services/io.datavines.connector.api.ConnectorFactory

@@ -0,0 +1 @@
+io.datavines.connector.plugin.HiveConnectorFactory

datavines-connector/datavines-connector-plugins/datavines-connector-impala/src/main/java/io/datavines/connector/plugin/ImpalaConnectorFactory.java

@@ -42,4 +42,9 @@ public Connector getConnector() {
     public Executor getExecutor() {
         return new ImpalaExecutor(getDataSourceClient());
     }
+
+    @Override
+    public String getPluginName() {
+        return "impala";
+    }
 }

datavines-connector/datavines-connector-plugins/datavines-connector-impala/src/main/resources/META-INF/services/io.datavines.connector.api.ConnectorFactory

@@ -0,0 +1 @@
+io.datavines.connector.plugin.ImpalaConnectorFactory

datavines-connector/datavines-connector-plugins/datavines-connector-maxcompute/src/main/java/io/datavines/connector/plugin/MaxComputeConnectorFactory.java

@@ -54,4 +54,9 @@ public ConfigBuilder getConfigBuilder() {
     public MetricScript getMetricScript() {
         return new MaxComputeMetricScript();
     }
+
+    @Override
+    public String getPluginName() {
+        return "maxcompute";
+    }
 }

datavines-connector/datavines-connector-plugins/datavines-connector-maxcompute/src/main/resources/META-INF/services/io.datavines.connector.api.ConnectorFactory

@@ -0,0 +1 @@
+io.datavines.connector.plugin.MaxComputeConnectorFactory

datavines-connector/datavines-connector-plugins/datavines-connector-mongodb/src/main/java/io/datavines/connector/plugin/MongodbConnectorFactory.java

@@ -49,4 +49,9 @@ public Executor getExecutor() {
     public ConfigBuilder getConfigBuilder() {
         return new MongodbConfigBuilder();
     }
+
+    @Override
+    public String getPluginName() {
+        return "mongodb";
+    }
 }

datavines-connector/datavines-connector-plugins/datavines-connector-mongodb/src/main/resources/META-INF/services/io.datavines.connector.api.ConnectorFactory

@@ -0,0 +1 @@
+io.datavines.connector.plugin.MongodbConnectorFactory

datavines-connector/datavines-connector-plugins/datavines-connector-mysql/src/main/java/io/datavines/connector/plugin/MysqlConnectorFactory.java

@@ -49,4 +49,9 @@ public ConfigBuilder getConfigBuilder() {
     public MetricScript getMetricScript() {
         return new MysqlMetricScript();
     }
+
+    @Override
+    public String getPluginName() {
+        return "mysql";
+    }
 }

datavines-connector/datavines-connector-plugins/datavines-connector-mysql/src/main/resources/META-INF/services/io.datavines.connector.api.ConnectorFactory

@@ -0,0 +1 @@
+io.datavines.connector.plugin.MysqlConnectorFactory

datavines-connector/datavines-connector-plugins/datavines-connector-oracle/src/main/java/io/datavines/connector/plugin/OracleConnectorFactory.java

@@ -54,4 +54,9 @@ public TypeConverter getTypeConverter() {
     public MetricScript getMetricScript() {
         return new OracleMetricScript();
     }
+
+    @Override
+    public String getPluginName() {
+        return "oracle";
+    }
 }

datavines-connector/datavines-connector-plugins/datavines-connector-oracle/src/main/resources/META-INF/services/io.datavines.connector.api.ConnectorFactory

@@ -0,0 +1 @@
+io.datavines.connector.plugin.OracleConnectorFactory

datavines-connector/datavines-connector-plugins/datavines-connector-postgresql/src/main/java/io/datavines/connector/plugin/PostgreSqlConnectorFactory.java

@@ -54,4 +54,9 @@ public TypeConverter getTypeConverter() {
     public MetricScript getMetricScript() {
         return new PostgreSqlMetricScript();
     }
+
+    @Override
+    public String getPluginName() {
+        return "postgresql";
+    }
 }

datavines-connector/datavines-connector-plugins/datavines-connector-postgresql/src/main/resources/META-INF/services/io.datavines.connector.api.ConnectorFactory

@@ -0,0 +1 @@
+io.datavines.connector.plugin.PostgreSqlConnectorFactory

datavines-connector/datavines-connector-plugins/datavines-connector-presto/src/main/java/io/datavines/connector/plugin/PrestoConnectorFactory.java

@@ -49,4 +49,9 @@ public ConfigBuilder getConfigBuilder() {
     public DataSourceClient getDataSourceClient() {
         return new PrestoDataSourceClient();
     }
+
+    @Override
+    public String getPluginName() {
+        return "presto";
+    }
 }

datavines-connector/datavines-connector-plugins/datavines-connector-presto/src/main/resources/META-INF/services/io.datavines.connector.api.ConnectorFactory

@@ -0,0 +1 @@
+io.datavines.connector.plugin.PrestoConnectorFactory

datavines-connector/datavines-connector-plugins/datavines-connector-spark/src/main/java/io/datavines/connector/plugin/SparkConnectorFactory.java

@@ -49,4 +49,9 @@ public MetricScript getMetricScript() {
     public Boolean showInFrontend() {
         return false;
     }
+
+    @Override
+    public String getPluginName() {
+        return "spark";
+    }
 }

datavines-connector/datavines-connector-plugins/datavines-connector-spark/src/main/resources/META-INF/services/io.datavines.connector.api.ConnectorFactory

@@ -0,0 +1 @@
+io.datavines.connector.plugin.SparkConnectorFactory

datavines-connector/datavines-connector-plugins/datavines-connector-sqlserver/src/main/java/io/datavines/connector/plugin/SqlServerConnectorFactory.java

@@ -49,4 +49,9 @@ public ConfigBuilder getConfigBuilder() {
     public MetricScript getMetricScript() {
         return new SqlServerMetricScript();
     }
+
+    @Override
+    public String getPluginName() {
+        return "sqlserver";
+    }
 }

datavines-connector/datavines-connector-plugins/datavines-connector-sqlserver/src/main/resources/META-INF/services/io.datavines.connector.api.ConnectorFactory

@@ -0,0 +1 @@
+io.datavines.connector.plugin.SqlServerConnectorFactory

datavines-connector/datavines-connector-plugins/datavines-connector-starrocks/src/main/java/io/datavines/connector/plugin/StarRocksConnectorFactory.java

@@ -44,4 +44,9 @@ public Executor getExecutor() {
     public ConfigBuilder getConfigBuilder() {
         return new StarRocksConfigBuilder();
     }
+
+    @Override
+    public String getPluginName() {
+        return "starrocks";
+    }
 }

datavines-connector/datavines-connector-plugins/datavines-connector-starrocks/src/main/resources/META-INF/services/io.datavines.connector.api.ConnectorFactory

@@ -0,0 +1 @@
+io.datavines.connector.plugin.StarRocksConnectorFactory

datavines-connector/datavines-connector-plugins/datavines-connector-trino/src/main/java/io/datavines/connector/plugin/TrinoConnectorFactory.java

@@ -49,4 +49,9 @@ public ConfigBuilder getConfigBuilder() {
     public DataSourceClient getDataSourceClient() {
         return new TrinoDataSourceClient();
     }
+
+    @Override
+    public String getPluginName() {
+        return "trino";
+    }
 }

datavines-connector/datavines-connector-plugins/datavines-connector-trino/src/main/resources/META-INF/services/io.datavines.connector.api.ConnectorFactory

@@ -0,0 +1 @@
+io.datavines.connector.plugin.TrinoConnectorFactory

datavines-engine/datavines-engine-api/src/main/java/io/datavines/engine/api/component/Component.java

@@ -16,11 +16,13 @@
  */
 package io.datavines.engine.api.component;
 
-import io.datavines.spi.SPI;;
 import io.datavines.engine.api.env.RuntimeEnvironment;
 import io.datavines.engine.api.plugin.Plugin;
 
-@SPI
+import java.util.Collection;
+
 public interface Component extends Plugin {
+
+    Collection<String> getPluginNames();
     void prepare(RuntimeEnvironment env) throws Exception;
 }

datavines-engine/datavines-engine-api/src/main/java/io/datavines/engine/api/engine/EngineExecutor.java

@@ -21,11 +21,18 @@
 
 import io.datavines.common.config.Configurations;
 import io.datavines.common.entity.ProcessResult;
-import io.datavines.spi.SPI;
 
-@SPI
+import java.util.Collection;
+import java.util.Collections;
+
 public interface EngineExecutor {
 
+    String getPluginName();
+
+    default Collection<String> getPluginNames() {
+        return Collections.singletonList(getPluginName());
+    }
+
     void init(JobExecutionRequest jobExecutionRequest, Logger logger, Configurations configurations) throws Exception;
 
     void execute() throws Exception;

datavines-engine/datavines-engine-api/src/main/java/io/datavines/engine/api/env/RuntimeEnvironment.java

@@ -16,12 +16,14 @@
  */
 package io.datavines.engine.api.env;
 
-import io.datavines.spi.SPI;;
 import io.datavines.engine.api.plugin.Plugin;
 
-@SPI
+import java.util.Collection;
+
 public interface RuntimeEnvironment extends Plugin {
 
+    Collection<String> getPluginNames();
+
     void prepare();
 
     Execution getExecution();