This is an automated email from the ASF dual-hosted git repository.
wuchunfu 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 f8c47fb5f4 [improve] fake source options (#8950)
f8c47fb5f4 is described below
commit f8c47fb5f43095a7b1da9916563f99cb97269500
Author: Jarvis <jar...@apache.org>
AuthorDate: Tue Mar 11 09:39:28 2025 +0800
[improve] fake source options (#8950)
---
.../seatunnel/api/ConnectorOptionCheckTest.java | 1 -
.../seatunnel/fake/config/FakeConfig.java | 107 +++++++++++----------
.../{FakeOption.java => FakeSourceOptions.java} | 2 +-
.../seatunnel/fake/source/FakeSourceFactory.java | 93 +++++++++---------
4 files changed, 104 insertions(+), 99 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 0df7f57c1e..9630775651 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
@@ -182,7 +182,6 @@ public class ConnectorOptionCheckTest {
whiteList.add("PaimonSinkOptions");
whiteList.add("TDengineSourceOptions");
whiteList.add("PulsarSourceOptions");
- whiteList.add("FakeSourceOptions");
whiteList.add("MongodbSinkOptions");
whiteList.add("IoTDBSinkOptions");
whiteList.add("EasysearchSourceOptions");
diff --git
a/seatunnel-connectors-v2/connector-fake/src/main/java/org/apache/seatunnel/connectors/seatunnel/fake/config/FakeConfig.java
b/seatunnel-connectors-v2/connector-fake/src/main/java/org/apache/seatunnel/connectors/seatunnel/fake/config/FakeConfig.java
index 96cd3fc464..619cedeeba 100644
---
a/seatunnel-connectors-v2/connector-fake/src/main/java/org/apache/seatunnel/connectors/seatunnel/fake/config/FakeConfig.java
+++
b/seatunnel-connectors-v2/connector-fake/src/main/java/org/apache/seatunnel/connectors/seatunnel/fake/config/FakeConfig.java
@@ -34,50 +34,50 @@ import java.util.ArrayList;
import java.util.List;
import java.util.Map;
-import static
org.apache.seatunnel.connectors.seatunnel.fake.config.FakeOption.ARRAY_SIZE;
-import static
org.apache.seatunnel.connectors.seatunnel.fake.config.FakeOption.BIGINT_FAKE_MODE;
-import static
org.apache.seatunnel.connectors.seatunnel.fake.config.FakeOption.BIGINT_MAX;
-import static
org.apache.seatunnel.connectors.seatunnel.fake.config.FakeOption.BIGINT_MIN;
-import static
org.apache.seatunnel.connectors.seatunnel.fake.config.FakeOption.BIGINT_TEMPLATE;
-import static
org.apache.seatunnel.connectors.seatunnel.fake.config.FakeOption.BINARY_VECTOR_DIMENSION;
-import static
org.apache.seatunnel.connectors.seatunnel.fake.config.FakeOption.BYTES_LENGTH;
-import static
org.apache.seatunnel.connectors.seatunnel.fake.config.FakeOption.DATE_DAY_TEMPLATE;
-import static
org.apache.seatunnel.connectors.seatunnel.fake.config.FakeOption.DATE_MONTH_TEMPLATE;
-import static
org.apache.seatunnel.connectors.seatunnel.fake.config.FakeOption.DATE_YEAR_TEMPLATE;
-import static
org.apache.seatunnel.connectors.seatunnel.fake.config.FakeOption.DOUBLE_FAKE_MODE;
-import static
org.apache.seatunnel.connectors.seatunnel.fake.config.FakeOption.DOUBLE_MAX;
-import static
org.apache.seatunnel.connectors.seatunnel.fake.config.FakeOption.DOUBLE_MIN;
-import static
org.apache.seatunnel.connectors.seatunnel.fake.config.FakeOption.DOUBLE_TEMPLATE;
-import static
org.apache.seatunnel.connectors.seatunnel.fake.config.FakeOption.FLOAT_FAKE_MODE;
-import static
org.apache.seatunnel.connectors.seatunnel.fake.config.FakeOption.FLOAT_MAX;
-import static
org.apache.seatunnel.connectors.seatunnel.fake.config.FakeOption.FLOAT_MIN;
-import static
org.apache.seatunnel.connectors.seatunnel.fake.config.FakeOption.FLOAT_TEMPLATE;
-import static
org.apache.seatunnel.connectors.seatunnel.fake.config.FakeOption.INT_FAKE_MODE;
-import static
org.apache.seatunnel.connectors.seatunnel.fake.config.FakeOption.INT_MAX;
-import static
org.apache.seatunnel.connectors.seatunnel.fake.config.FakeOption.INT_MIN;
-import static
org.apache.seatunnel.connectors.seatunnel.fake.config.FakeOption.INT_TEMPLATE;
-import static
org.apache.seatunnel.connectors.seatunnel.fake.config.FakeOption.MAP_SIZE;
-import static
org.apache.seatunnel.connectors.seatunnel.fake.config.FakeOption.ROWS;
-import static
org.apache.seatunnel.connectors.seatunnel.fake.config.FakeOption.ROW_NUM;
-import static
org.apache.seatunnel.connectors.seatunnel.fake.config.FakeOption.SMALLINT_FAKE_MODE;
-import static
org.apache.seatunnel.connectors.seatunnel.fake.config.FakeOption.SMALLINT_MAX;
-import static
org.apache.seatunnel.connectors.seatunnel.fake.config.FakeOption.SMALLINT_MIN;
-import static
org.apache.seatunnel.connectors.seatunnel.fake.config.FakeOption.SMALLINT_TEMPLATE;
-import static
org.apache.seatunnel.connectors.seatunnel.fake.config.FakeOption.SPLIT_NUM;
-import static
org.apache.seatunnel.connectors.seatunnel.fake.config.FakeOption.SPLIT_READ_INTERVAL;
-import static
org.apache.seatunnel.connectors.seatunnel.fake.config.FakeOption.STRING_FAKE_MODE;
-import static
org.apache.seatunnel.connectors.seatunnel.fake.config.FakeOption.STRING_LENGTH;
-import static
org.apache.seatunnel.connectors.seatunnel.fake.config.FakeOption.STRING_TEMPLATE;
-import static
org.apache.seatunnel.connectors.seatunnel.fake.config.FakeOption.TIME_HOUR_TEMPLATE;
-import static
org.apache.seatunnel.connectors.seatunnel.fake.config.FakeOption.TIME_MINUTE_TEMPLATE;
-import static
org.apache.seatunnel.connectors.seatunnel.fake.config.FakeOption.TIME_SECOND_TEMPLATE;
-import static
org.apache.seatunnel.connectors.seatunnel.fake.config.FakeOption.TINYINT_FAKE_MODE;
-import static
org.apache.seatunnel.connectors.seatunnel.fake.config.FakeOption.TINYINT_MAX;
-import static
org.apache.seatunnel.connectors.seatunnel.fake.config.FakeOption.TINYINT_MIN;
-import static
org.apache.seatunnel.connectors.seatunnel.fake.config.FakeOption.TINYINT_TEMPLATE;
-import static
org.apache.seatunnel.connectors.seatunnel.fake.config.FakeOption.VECTOR_DIMENSION;
-import static
org.apache.seatunnel.connectors.seatunnel.fake.config.FakeOption.VECTOR_FLOAT_MAX;
-import static
org.apache.seatunnel.connectors.seatunnel.fake.config.FakeOption.VECTOR_FLOAT_MIN;
+import static
org.apache.seatunnel.connectors.seatunnel.fake.config.FakeSourceOptions.ARRAY_SIZE;
+import static
org.apache.seatunnel.connectors.seatunnel.fake.config.FakeSourceOptions.BIGINT_FAKE_MODE;
+import static
org.apache.seatunnel.connectors.seatunnel.fake.config.FakeSourceOptions.BIGINT_MAX;
+import static
org.apache.seatunnel.connectors.seatunnel.fake.config.FakeSourceOptions.BIGINT_MIN;
+import static
org.apache.seatunnel.connectors.seatunnel.fake.config.FakeSourceOptions.BIGINT_TEMPLATE;
+import static
org.apache.seatunnel.connectors.seatunnel.fake.config.FakeSourceOptions.BINARY_VECTOR_DIMENSION;
+import static
org.apache.seatunnel.connectors.seatunnel.fake.config.FakeSourceOptions.BYTES_LENGTH;
+import static
org.apache.seatunnel.connectors.seatunnel.fake.config.FakeSourceOptions.DATE_DAY_TEMPLATE;
+import static
org.apache.seatunnel.connectors.seatunnel.fake.config.FakeSourceOptions.DATE_MONTH_TEMPLATE;
+import static
org.apache.seatunnel.connectors.seatunnel.fake.config.FakeSourceOptions.DATE_YEAR_TEMPLATE;
+import static
org.apache.seatunnel.connectors.seatunnel.fake.config.FakeSourceOptions.DOUBLE_FAKE_MODE;
+import static
org.apache.seatunnel.connectors.seatunnel.fake.config.FakeSourceOptions.DOUBLE_MAX;
+import static
org.apache.seatunnel.connectors.seatunnel.fake.config.FakeSourceOptions.DOUBLE_MIN;
+import static
org.apache.seatunnel.connectors.seatunnel.fake.config.FakeSourceOptions.DOUBLE_TEMPLATE;
+import static
org.apache.seatunnel.connectors.seatunnel.fake.config.FakeSourceOptions.FLOAT_FAKE_MODE;
+import static
org.apache.seatunnel.connectors.seatunnel.fake.config.FakeSourceOptions.FLOAT_MAX;
+import static
org.apache.seatunnel.connectors.seatunnel.fake.config.FakeSourceOptions.FLOAT_MIN;
+import static
org.apache.seatunnel.connectors.seatunnel.fake.config.FakeSourceOptions.FLOAT_TEMPLATE;
+import static
org.apache.seatunnel.connectors.seatunnel.fake.config.FakeSourceOptions.INT_FAKE_MODE;
+import static
org.apache.seatunnel.connectors.seatunnel.fake.config.FakeSourceOptions.INT_MAX;
+import static
org.apache.seatunnel.connectors.seatunnel.fake.config.FakeSourceOptions.INT_MIN;
+import static
org.apache.seatunnel.connectors.seatunnel.fake.config.FakeSourceOptions.INT_TEMPLATE;
+import static
org.apache.seatunnel.connectors.seatunnel.fake.config.FakeSourceOptions.MAP_SIZE;
+import static
org.apache.seatunnel.connectors.seatunnel.fake.config.FakeSourceOptions.ROWS;
+import static
org.apache.seatunnel.connectors.seatunnel.fake.config.FakeSourceOptions.ROW_NUM;
+import static
org.apache.seatunnel.connectors.seatunnel.fake.config.FakeSourceOptions.SMALLINT_FAKE_MODE;
+import static
org.apache.seatunnel.connectors.seatunnel.fake.config.FakeSourceOptions.SMALLINT_MAX;
+import static
org.apache.seatunnel.connectors.seatunnel.fake.config.FakeSourceOptions.SMALLINT_MIN;
+import static
org.apache.seatunnel.connectors.seatunnel.fake.config.FakeSourceOptions.SMALLINT_TEMPLATE;
+import static
org.apache.seatunnel.connectors.seatunnel.fake.config.FakeSourceOptions.SPLIT_NUM;
+import static
org.apache.seatunnel.connectors.seatunnel.fake.config.FakeSourceOptions.SPLIT_READ_INTERVAL;
+import static
org.apache.seatunnel.connectors.seatunnel.fake.config.FakeSourceOptions.STRING_FAKE_MODE;
+import static
org.apache.seatunnel.connectors.seatunnel.fake.config.FakeSourceOptions.STRING_LENGTH;
+import static
org.apache.seatunnel.connectors.seatunnel.fake.config.FakeSourceOptions.STRING_TEMPLATE;
+import static
org.apache.seatunnel.connectors.seatunnel.fake.config.FakeSourceOptions.TIME_HOUR_TEMPLATE;
+import static
org.apache.seatunnel.connectors.seatunnel.fake.config.FakeSourceOptions.TIME_MINUTE_TEMPLATE;
+import static
org.apache.seatunnel.connectors.seatunnel.fake.config.FakeSourceOptions.TIME_SECOND_TEMPLATE;
+import static
org.apache.seatunnel.connectors.seatunnel.fake.config.FakeSourceOptions.TINYINT_FAKE_MODE;
+import static
org.apache.seatunnel.connectors.seatunnel.fake.config.FakeSourceOptions.TINYINT_MAX;
+import static
org.apache.seatunnel.connectors.seatunnel.fake.config.FakeSourceOptions.TINYINT_MIN;
+import static
org.apache.seatunnel.connectors.seatunnel.fake.config.FakeSourceOptions.TINYINT_TEMPLATE;
+import static
org.apache.seatunnel.connectors.seatunnel.fake.config.FakeSourceOptions.VECTOR_DIMENSION;
+import static
org.apache.seatunnel.connectors.seatunnel.fake.config.FakeSourceOptions.VECTOR_FLOAT_MAX;
+import static
org.apache.seatunnel.connectors.seatunnel.fake.config.FakeSourceOptions.VECTOR_FLOAT_MIN;
@Builder
@Getter
@@ -128,20 +128,25 @@ public class FakeConfig implements Serializable {
@Builder.Default private int binaryVectorDimension =
BINARY_VECTOR_DIMENSION.defaultValue();
- @Builder.Default private FakeOption.FakeMode stringFakeMode =
STRING_FAKE_MODE.defaultValue();
+ @Builder.Default
+ private FakeSourceOptions.FakeMode stringFakeMode =
STRING_FAKE_MODE.defaultValue();
- @Builder.Default private FakeOption.FakeMode tinyintFakeMode =
TINYINT_FAKE_MODE.defaultValue();
+ @Builder.Default
+ private FakeSourceOptions.FakeMode tinyintFakeMode =
TINYINT_FAKE_MODE.defaultValue();
@Builder.Default
- private FakeOption.FakeMode smallintFakeMode =
SMALLINT_FAKE_MODE.defaultValue();
+ private FakeSourceOptions.FakeMode smallintFakeMode =
SMALLINT_FAKE_MODE.defaultValue();
- @Builder.Default private FakeOption.FakeMode intFakeMode =
INT_FAKE_MODE.defaultValue();
+ @Builder.Default private FakeSourceOptions.FakeMode intFakeMode =
INT_FAKE_MODE.defaultValue();
- @Builder.Default private FakeOption.FakeMode bigintFakeMode =
BIGINT_FAKE_MODE.defaultValue();
+ @Builder.Default
+ private FakeSourceOptions.FakeMode bigintFakeMode =
BIGINT_FAKE_MODE.defaultValue();
- @Builder.Default private FakeOption.FakeMode floatFakeMode =
FLOAT_FAKE_MODE.defaultValue();
+ @Builder.Default
+ private FakeSourceOptions.FakeMode floatFakeMode =
FLOAT_FAKE_MODE.defaultValue();
- @Builder.Default private FakeOption.FakeMode doubleFakeMode =
DOUBLE_FAKE_MODE.defaultValue();
+ @Builder.Default
+ private FakeSourceOptions.FakeMode doubleFakeMode =
DOUBLE_FAKE_MODE.defaultValue();
private List<String> stringTemplate;
private List<Integer> tinyintTemplate;
diff --git
a/seatunnel-connectors-v2/connector-fake/src/main/java/org/apache/seatunnel/connectors/seatunnel/fake/config/FakeOption.java
b/seatunnel-connectors-v2/connector-fake/src/main/java/org/apache/seatunnel/connectors/seatunnel/fake/config/FakeSourceOptions.java
similarity index 99%
rename from
seatunnel-connectors-v2/connector-fake/src/main/java/org/apache/seatunnel/connectors/seatunnel/fake/config/FakeOption.java
rename to
seatunnel-connectors-v2/connector-fake/src/main/java/org/apache/seatunnel/connectors/seatunnel/fake/config/FakeSourceOptions.java
index 9c05c86bb6..8b6c514b95 100644
---
a/seatunnel-connectors-v2/connector-fake/src/main/java/org/apache/seatunnel/connectors/seatunnel/fake/config/FakeOption.java
+++
b/seatunnel-connectors-v2/connector-fake/src/main/java/org/apache/seatunnel/connectors/seatunnel/fake/config/FakeSourceOptions.java
@@ -25,7 +25,7 @@ import org.apache.seatunnel.api.configuration.Options;
import java.util.List;
import java.util.Map;
-public class FakeOption {
+public class FakeSourceOptions {
public static final Option<List<Map<String, Object>>> ROWS =
Options.key("rows")
diff --git
a/seatunnel-connectors-v2/connector-fake/src/main/java/org/apache/seatunnel/connectors/seatunnel/fake/source/FakeSourceFactory.java
b/seatunnel-connectors-v2/connector-fake/src/main/java/org/apache/seatunnel/connectors/seatunnel/fake/source/FakeSourceFactory.java
index 8decb6237e..50dbe95953 100644
---
a/seatunnel-connectors-v2/connector-fake/src/main/java/org/apache/seatunnel/connectors/seatunnel/fake/source/FakeSourceFactory.java
+++
b/seatunnel-connectors-v2/connector-fake/src/main/java/org/apache/seatunnel/connectors/seatunnel/fake/source/FakeSourceFactory.java
@@ -25,41 +25,41 @@ import org.apache.seatunnel.api.table.connector.TableSource;
import org.apache.seatunnel.api.table.factory.Factory;
import org.apache.seatunnel.api.table.factory.TableSourceFactory;
import org.apache.seatunnel.api.table.factory.TableSourceFactoryContext;
-import org.apache.seatunnel.connectors.seatunnel.fake.config.FakeOption;
+import org.apache.seatunnel.connectors.seatunnel.fake.config.FakeSourceOptions;
import com.google.auto.service.AutoService;
import java.io.Serializable;
-import static
org.apache.seatunnel.connectors.seatunnel.fake.config.FakeOption.ARRAY_SIZE;
-import static
org.apache.seatunnel.connectors.seatunnel.fake.config.FakeOption.BIGINT_FAKE_MODE;
-import static
org.apache.seatunnel.connectors.seatunnel.fake.config.FakeOption.BIGINT_TEMPLATE;
-import static
org.apache.seatunnel.connectors.seatunnel.fake.config.FakeOption.BINARY_VECTOR_DIMENSION;
-import static
org.apache.seatunnel.connectors.seatunnel.fake.config.FakeOption.BYTES_LENGTH;
-import static
org.apache.seatunnel.connectors.seatunnel.fake.config.FakeOption.DATE_DAY_TEMPLATE;
-import static
org.apache.seatunnel.connectors.seatunnel.fake.config.FakeOption.DATE_MONTH_TEMPLATE;
-import static
org.apache.seatunnel.connectors.seatunnel.fake.config.FakeOption.DATE_YEAR_TEMPLATE;
-import static
org.apache.seatunnel.connectors.seatunnel.fake.config.FakeOption.DOUBLE_FAKE_MODE;
-import static
org.apache.seatunnel.connectors.seatunnel.fake.config.FakeOption.DOUBLE_TEMPLATE;
-import static
org.apache.seatunnel.connectors.seatunnel.fake.config.FakeOption.FLOAT_FAKE_MODE;
-import static
org.apache.seatunnel.connectors.seatunnel.fake.config.FakeOption.FLOAT_TEMPLATE;
-import static
org.apache.seatunnel.connectors.seatunnel.fake.config.FakeOption.INT_FAKE_MODE;
-import static
org.apache.seatunnel.connectors.seatunnel.fake.config.FakeOption.INT_TEMPLATE;
-import static
org.apache.seatunnel.connectors.seatunnel.fake.config.FakeOption.MAP_SIZE;
-import static
org.apache.seatunnel.connectors.seatunnel.fake.config.FakeOption.ROWS;
-import static
org.apache.seatunnel.connectors.seatunnel.fake.config.FakeOption.ROW_NUM;
-import static
org.apache.seatunnel.connectors.seatunnel.fake.config.FakeOption.SMALLINT_FAKE_MODE;
-import static
org.apache.seatunnel.connectors.seatunnel.fake.config.FakeOption.SMALLINT_TEMPLATE;
-import static
org.apache.seatunnel.connectors.seatunnel.fake.config.FakeOption.SPLIT_NUM;
-import static
org.apache.seatunnel.connectors.seatunnel.fake.config.FakeOption.SPLIT_READ_INTERVAL;
-import static
org.apache.seatunnel.connectors.seatunnel.fake.config.FakeOption.STRING_FAKE_MODE;
-import static
org.apache.seatunnel.connectors.seatunnel.fake.config.FakeOption.STRING_TEMPLATE;
-import static
org.apache.seatunnel.connectors.seatunnel.fake.config.FakeOption.TIME_HOUR_TEMPLATE;
-import static
org.apache.seatunnel.connectors.seatunnel.fake.config.FakeOption.TIME_MINUTE_TEMPLATE;
-import static
org.apache.seatunnel.connectors.seatunnel.fake.config.FakeOption.TIME_SECOND_TEMPLATE;
-import static
org.apache.seatunnel.connectors.seatunnel.fake.config.FakeOption.TINYINT_FAKE_MODE;
-import static
org.apache.seatunnel.connectors.seatunnel.fake.config.FakeOption.TINYINT_TEMPLATE;
-import static
org.apache.seatunnel.connectors.seatunnel.fake.config.FakeOption.VECTOR_DIMENSION;
+import static
org.apache.seatunnel.connectors.seatunnel.fake.config.FakeSourceOptions.ARRAY_SIZE;
+import static
org.apache.seatunnel.connectors.seatunnel.fake.config.FakeSourceOptions.BIGINT_FAKE_MODE;
+import static
org.apache.seatunnel.connectors.seatunnel.fake.config.FakeSourceOptions.BIGINT_TEMPLATE;
+import static
org.apache.seatunnel.connectors.seatunnel.fake.config.FakeSourceOptions.BINARY_VECTOR_DIMENSION;
+import static
org.apache.seatunnel.connectors.seatunnel.fake.config.FakeSourceOptions.BYTES_LENGTH;
+import static
org.apache.seatunnel.connectors.seatunnel.fake.config.FakeSourceOptions.DATE_DAY_TEMPLATE;
+import static
org.apache.seatunnel.connectors.seatunnel.fake.config.FakeSourceOptions.DATE_MONTH_TEMPLATE;
+import static
org.apache.seatunnel.connectors.seatunnel.fake.config.FakeSourceOptions.DATE_YEAR_TEMPLATE;
+import static
org.apache.seatunnel.connectors.seatunnel.fake.config.FakeSourceOptions.DOUBLE_FAKE_MODE;
+import static
org.apache.seatunnel.connectors.seatunnel.fake.config.FakeSourceOptions.DOUBLE_TEMPLATE;
+import static
org.apache.seatunnel.connectors.seatunnel.fake.config.FakeSourceOptions.FLOAT_FAKE_MODE;
+import static
org.apache.seatunnel.connectors.seatunnel.fake.config.FakeSourceOptions.FLOAT_TEMPLATE;
+import static
org.apache.seatunnel.connectors.seatunnel.fake.config.FakeSourceOptions.INT_FAKE_MODE;
+import static
org.apache.seatunnel.connectors.seatunnel.fake.config.FakeSourceOptions.INT_TEMPLATE;
+import static
org.apache.seatunnel.connectors.seatunnel.fake.config.FakeSourceOptions.MAP_SIZE;
+import static
org.apache.seatunnel.connectors.seatunnel.fake.config.FakeSourceOptions.ROWS;
+import static
org.apache.seatunnel.connectors.seatunnel.fake.config.FakeSourceOptions.ROW_NUM;
+import static
org.apache.seatunnel.connectors.seatunnel.fake.config.FakeSourceOptions.SMALLINT_FAKE_MODE;
+import static
org.apache.seatunnel.connectors.seatunnel.fake.config.FakeSourceOptions.SMALLINT_TEMPLATE;
+import static
org.apache.seatunnel.connectors.seatunnel.fake.config.FakeSourceOptions.SPLIT_NUM;
+import static
org.apache.seatunnel.connectors.seatunnel.fake.config.FakeSourceOptions.SPLIT_READ_INTERVAL;
+import static
org.apache.seatunnel.connectors.seatunnel.fake.config.FakeSourceOptions.STRING_FAKE_MODE;
+import static
org.apache.seatunnel.connectors.seatunnel.fake.config.FakeSourceOptions.STRING_TEMPLATE;
+import static
org.apache.seatunnel.connectors.seatunnel.fake.config.FakeSourceOptions.TIME_HOUR_TEMPLATE;
+import static
org.apache.seatunnel.connectors.seatunnel.fake.config.FakeSourceOptions.TIME_MINUTE_TEMPLATE;
+import static
org.apache.seatunnel.connectors.seatunnel.fake.config.FakeSourceOptions.TIME_SECOND_TEMPLATE;
+import static
org.apache.seatunnel.connectors.seatunnel.fake.config.FakeSourceOptions.TINYINT_FAKE_MODE;
+import static
org.apache.seatunnel.connectors.seatunnel.fake.config.FakeSourceOptions.TINYINT_TEMPLATE;
+import static
org.apache.seatunnel.connectors.seatunnel.fake.config.FakeSourceOptions.VECTOR_DIMENSION;
@AutoService(Factory.class)
public class FakeSourceFactory implements TableSourceFactory {
@@ -71,23 +71,15 @@ public class FakeSourceFactory implements
TableSourceFactory {
@Override
public OptionRule optionRule() {
return OptionRule.builder()
- .optional(ConnectorCommonOptions.TABLE_CONFIGS)
- .optional(ConnectorCommonOptions.SCHEMA)
- .optional(STRING_FAKE_MODE)
- .conditional(STRING_FAKE_MODE, FakeOption.FakeMode.TEMPLATE,
STRING_TEMPLATE)
- .optional(TINYINT_FAKE_MODE)
- .conditional(TINYINT_FAKE_MODE, FakeOption.FakeMode.TEMPLATE,
TINYINT_TEMPLATE)
- .optional(SMALLINT_FAKE_MODE)
- .conditional(SMALLINT_FAKE_MODE, FakeOption.FakeMode.TEMPLATE,
SMALLINT_TEMPLATE)
- .optional(INT_FAKE_MODE)
- .conditional(INT_FAKE_MODE, FakeOption.FakeMode.TEMPLATE,
INT_TEMPLATE)
- .optional(BIGINT_FAKE_MODE)
- .conditional(BIGINT_FAKE_MODE, FakeOption.FakeMode.TEMPLATE,
BIGINT_TEMPLATE)
- .optional(FLOAT_FAKE_MODE)
- .conditional(FLOAT_FAKE_MODE, FakeOption.FakeMode.TEMPLATE,
FLOAT_TEMPLATE)
- .optional(DOUBLE_FAKE_MODE)
- .conditional(DOUBLE_FAKE_MODE, FakeOption.FakeMode.TEMPLATE,
DOUBLE_TEMPLATE)
+ .exclusive(ConnectorCommonOptions.TABLE_CONFIGS,
ConnectorCommonOptions.SCHEMA)
.optional(
+ STRING_FAKE_MODE,
+ TINYINT_FAKE_MODE,
+ SMALLINT_FAKE_MODE,
+ INT_FAKE_MODE,
+ BIGINT_FAKE_MODE,
+ FLOAT_FAKE_MODE,
+ DOUBLE_FAKE_MODE,
ROWS,
ROW_NUM,
SPLIT_NUM,
@@ -103,6 +95,15 @@ public class FakeSourceFactory implements
TableSourceFactory {
TIME_HOUR_TEMPLATE,
TIME_MINUTE_TEMPLATE,
TIME_SECOND_TEMPLATE)
+ .conditional(STRING_FAKE_MODE,
FakeSourceOptions.FakeMode.TEMPLATE, STRING_TEMPLATE)
+ .conditional(
+ TINYINT_FAKE_MODE,
FakeSourceOptions.FakeMode.TEMPLATE, TINYINT_TEMPLATE)
+ .conditional(
+ SMALLINT_FAKE_MODE,
FakeSourceOptions.FakeMode.TEMPLATE, SMALLINT_TEMPLATE)
+ .conditional(INT_FAKE_MODE,
FakeSourceOptions.FakeMode.TEMPLATE, INT_TEMPLATE)
+ .conditional(BIGINT_FAKE_MODE,
FakeSourceOptions.FakeMode.TEMPLATE, BIGINT_TEMPLATE)
+ .conditional(FLOAT_FAKE_MODE,
FakeSourceOptions.FakeMode.TEMPLATE, FLOAT_TEMPLATE)
+ .conditional(DOUBLE_FAKE_MODE,
FakeSourceOptions.FakeMode.TEMPLATE, DOUBLE_TEMPLATE)
.build();
}
