[doris-flink-connector] branch master updated: [Improve]Optimize method for constructing builder object based on Builder pattern

[diwu]

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 <87286391+huangka...@users.noreply.github.com>
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: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org