(seatunnel) branch dev updated: [improve] update Druid connector config option (#8594)

[fanjia]

This is an automated email from the ASF dual-hosted git repository.

fanjia pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/seatunnel.git


The following commit(s) were added to refs/heads/dev by this push:
     new 07a2288a2e [improve] update Druid connector config option (#8594)
07a2288a2e is described below

commit 07a2288a2e43729be005697cdf12db051bba6b55
Author: Asish <labsa...@gmail.com>
AuthorDate: Fri Feb 7 06:42:47 2025 +0530

    [improve] update Druid connector config option (#8594)
    
    Co-authored-by: asishupadhyay <akula...@gmail.com>
---
 .../java/org/apache/seatunnel/api/ConnectorOptionCheckTest.java     | 1 -
 .../druid/config/{DruidConfig.java => DruidSinkOptions.java}        | 2 +-
 .../java/org/apache/seatunnel/connectors/druid/sink/DruidSink.java  | 6 +++---
 .../apache/seatunnel/connectors/druid/sink/DruidSinkFactory.java    | 4 ++--
 4 files changed, 6 insertions(+), 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
index 5c473ab7b2..7c77d95e2b 100644
--- 
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 @@ public class ConnectorOptionCheckTest {
         whiteList.add("TDengineSourceOptions");
         whiteList.add("PulsarSourceOptions");
         whiteList.add("RedisSinkOptions");
-        whiteList.add("DruidSinkOptions");
         whiteList.add("FakeSourceOptions");
         whiteList.add("HbaseSinkOptions");
         whiteList.add("MongodbSinkOptions");
diff --git 
a/seatunnel-connectors-v2/connector-druid/src/main/java/org/apache/seatunnel/connectors/druid/config/DruidConfig.java
 
b/seatunnel-connectors-v2/connector-druid/src/main/java/org/apache/seatunnel/connectors/druid/config/DruidSinkOptions.java
similarity index 98%
rename from 
seatunnel-connectors-v2/connector-druid/src/main/java/org/apache/seatunnel/connectors/druid/config/DruidConfig.java
rename to 
seatunnel-connectors-v2/connector-druid/src/main/java/org/apache/seatunnel/connectors/druid/config/DruidSinkOptions.java
index a2883143a3..f9e2ff3900 100644
--- 
a/seatunnel-connectors-v2/connector-druid/src/main/java/org/apache/seatunnel/connectors/druid/config/DruidConfig.java
+++ 
b/seatunnel-connectors-v2/connector-druid/src/main/java/org/apache/seatunnel/connectors/druid/config/DruidSinkOptions.java
@@ -21,7 +21,7 @@ package org.apache.seatunnel.connectors.druid.config;
 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/seatunnel-connectors-v2/connector-druid/src/main/java/org/apache/seatunnel/connectors/druid/sink/DruidSink.java
 
b/seatunnel-connectors-v2/connector-druid/src/main/java/org/apache/seatunnel/connectors/druid/sink/DruidSink.java
index 786ab56e2c..a22ea59fc9 100644
--- 
a/seatunnel-connectors-v2/connector-druid/src/main/java/org/apache/seatunnel/connectors/druid/sink/DruidSink.java
+++ 
b/seatunnel-connectors-v2/connector-druid/src/main/java/org/apache/seatunnel/connectors/druid/sink/DruidSink.java
@@ -29,9 +29,9 @@ import 
org.apache.seatunnel.connectors.seatunnel.common.sink.AbstractSimpleSink;
 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/seatunnel-connectors-v2/connector-druid/src/main/java/org/apache/seatunnel/connectors/druid/sink/DruidSinkFactory.java
 
b/seatunnel-connectors-v2/connector-druid/src/main/java/org/apache/seatunnel/connectors/druid/sink/DruidSinkFactory.java
index 3199d3d66f..4627cf4d5f 100644
--- 
a/seatunnel-connectors-v2/connector-druid/src/main/java/org/apache/seatunnel/connectors/druid/sink/DruidSinkFactory.java
+++ 
b/seatunnel-connectors-v2/connector-druid/src/main/java/org/apache/seatunnel/connectors/druid/sink/DruidSinkFactory.java
@@ -29,8 +29,8 @@ import 
org.apache.seatunnel.api.table.factory.TableSinkFactoryContext;
 
 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 {