ashulin commented on code in PR #3353:
URL:
https://github.com/apache/incubator-seatunnel/pull/3353#discussion_r1032252746
##########
seatunnel-api/src/main/java/org/apache/seatunnel/api/table/factory/FactoryUtil.java:
##########
@@ -155,4 +159,36 @@ private static List<Factory> discoverFactories(ClassLoader
classLoader) {
throw new FactoryException("Could not load service provider for
factories.", e);
}
}
+
+ /**
+ * This method is called by SeaTunnel Web to get the full option rule of a
source.
+ * Please don't overwrite this method.
Review Comment:
```suggestion
```
##########
seatunnel-api/src/main/java/org/apache/seatunnel/api/table/factory/FactoryUtil.java:
##########
@@ -155,4 +159,36 @@ private static List<Factory> discoverFactories(ClassLoader
classLoader) {
throw new FactoryException("Could not load service provider for
factories.", e);
}
}
+
+ /**
+ * This method is called by SeaTunnel Web to get the full option rule of a
source.
+ * Please don't overwrite this method.
+ * @return
+ */
+ public static OptionRule sourceFullOptionRule(@NonNull OptionRule
sourceOptionRule) {
+ if (sourceOptionRule == null) {
+ throw new FactoryException("sourceOptionRule can not be null");
+ }
+
+ OptionRule sourceCommonOptionRule =
+
OptionRule.builder().optional(SourceCommonOptions.RESULT_TABLE_NAME,
SourceCommonOptions.PARALLELISM).build();
+
sourceOptionRule.getOptionalOptions().addAll(sourceCommonOptionRule.getOptionalOptions());
+ return sourceOptionRule;
+ }
+
+ /**
+ * This method is called by SeaTunnel Web to get the full option rule of a
sink.
+ * Please don't overwrite this method.
Review Comment:
```suggestion
```
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
