This is an automated email from the ASF dual-hosted git repository.
diwu pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris-flink-connector.git
The following commit(s) were added to refs/heads/master by this push:
new 093b755 [Improve]Optimize method for constructing builder object
based on Builder pattern
093b755 is described below
commit 093b755f81ae91f7db3511a4c4330ea59d0cc9ca
Author: huangkai66 <[email protected]>
AuthorDate: Wed Jul 19 13:56:20 2023 +0800
[Improve]Optimize method for constructing builder object based on Builder
pattern
---
.../java/org/apache/doris/flink/cfg/DorisExecutionOptions.java | 7 +++++++
1 file changed, 7 insertions(+)
diff --git
a/flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisExecutionOptions.java
b/flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisExecutionOptions.java
index 722f6ef..03adf19 100644
---
a/flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisExecutionOptions.java
+++
b/flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisExecutionOptions.java
@@ -70,6 +70,13 @@ public class DorisExecutionOptions implements Serializable {
return new Builder();
}
+ public static Builder builderDefaults() {
+ Properties properties = new Properties();
+ properties.setProperty("format", "json");
+ properties.setProperty("read_json_by_line", "true");
+ return new Builder().setStreamLoadProp(properties);
+ }
+
public static DorisExecutionOptions defaults() {
Properties properties = new Properties();
properties.setProperty("format", "json");
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
