[improve] update Druid connector config option (#8594)

Co-authored-by: asishupadhyay <[email protected]>
apache · Feb 7, 2025 · 07a2288 · 07a2288
1 parent 227a11f
commit 07a2288
Show file tree

Hide file tree

Showing 4 changed files with 6 additions and 7 deletions.
diff --git a/seatunnel-ci-tools/src/test/java/org/apache/seatunnel/api/ConnectorOptionCheckTest.java b/seatunnel-ci-tools/src/test/java/org/apache/seatunnel/api/ConnectorOptionCheckTest.java
@@ -187,7 +187,6 @@ private Set<String> buildWhiteList() {
         whiteList.add("TDengineSourceOptions");
         whiteList.add("PulsarSourceOptions");
         whiteList.add("RedisSinkOptions");
-        whiteList.add("DruidSinkOptions");
         whiteList.add("FakeSourceOptions");
         whiteList.add("HbaseSinkOptions");
         whiteList.add("MongodbSinkOptions");

diff --git a/.../connectors/druid/config/DruidConfig.java → ...ectors/druid/config/DruidSinkOptions.java b/.../connectors/druid/config/DruidConfig.java → ...ectors/druid/config/DruidSinkOptions.java
@@ -21,7 +21,7 @@
 import org.apache.seatunnel.api.configuration.Option;
 import org.apache.seatunnel.api.configuration.Options;
 
-public class DruidConfig {
+public class DruidSinkOptions {
     public static final Integer BATCH_SIZE_DEFAULT = 10000;
 
     public static Option<String> COORDINATOR_URL =

diff --git a/...2/connector-druid/src/main/java/org/apache/seatunnel/connectors/druid/sink/DruidSink.java b/...2/connector-druid/src/main/java/org/apache/seatunnel/connectors/druid/sink/DruidSink.java
@@ -29,9 +29,9 @@
 import java.io.IOException;
 import java.util.Optional;
 
-import static org.apache.seatunnel.connectors.druid.config.DruidConfig.BATCH_SIZE;
-import static org.apache.seatunnel.connectors.druid.config.DruidConfig.COORDINATOR_URL;
-import static org.apache.seatunnel.connectors.druid.config.DruidConfig.DATASOURCE;
+import static org.apache.seatunnel.connectors.druid.config.DruidSinkOptions.BATCH_SIZE;
+import static org.apache.seatunnel.connectors.druid.config.DruidSinkOptions.COORDINATOR_URL;
+import static org.apache.seatunnel.connectors.druid.config.DruidSinkOptions.DATASOURCE;
 
 public class DruidSink extends AbstractSimpleSink<SeaTunnelRow, Void>
         implements SupportMultiTableSink {

diff --git a/...ctor-druid/src/main/java/org/apache/seatunnel/connectors/druid/sink/DruidSinkFactory.java b/...ctor-druid/src/main/java/org/apache/seatunnel/connectors/druid/sink/DruidSinkFactory.java
@@ -29,8 +29,8 @@
 
 import com.google.auto.service.AutoService;
 
-import static org.apache.seatunnel.connectors.druid.config.DruidConfig.COORDINATOR_URL;
-import static org.apache.seatunnel.connectors.druid.config.DruidConfig.DATASOURCE;
+import static org.apache.seatunnel.connectors.druid.config.DruidSinkOptions.COORDINATOR_URL;
+import static org.apache.seatunnel.connectors.druid.config.DruidSinkOptions.DATASOURCE;
 
 @AutoService(Factory.class)
 public class DruidSinkFactory implements TableSinkFactory {