From 74ce00e3f30d7144f08089c07967833f1a00f0ec Mon Sep 17 00:00:00 2001
From: PengFei Li <lpengfei2016@gmail.com>
Date: Sun, 29 Oct 2023 13:17:27 +0800
Subject: [PATCH] [hotfix] Add enableUpsertDelete back to
 StreamLoadTableProperties (#299)

Signed-off-by: PengFei Li <lpengfei2016@gmail.com>
---
 .../stream/properties/StreamLoadTableProperties.java | 12 ++++++++++++
 1 file changed, 12 insertions(+)

diff --git a/starrocks-stream-load-sdk/src/main/java/com/starrocks/data/load/stream/properties/StreamLoadTableProperties.java b/starrocks-stream-load-sdk/src/main/java/com/starrocks/data/load/stream/properties/StreamLoadTableProperties.java
index bffd4fa8..4425e37b 100644
--- a/starrocks-stream-load-sdk/src/main/java/com/starrocks/data/load/stream/properties/StreamLoadTableProperties.java
+++ b/starrocks-stream-load-sdk/src/main/java/com/starrocks/data/load/stream/properties/StreamLoadTableProperties.java
@@ -34,6 +34,7 @@ public class StreamLoadTableProperties implements Serializable {
     private final String table;
     private final StreamLoadDataFormat dataFormat;
     private final Map<String, String> properties;
+    private final boolean enableUpsertDelete;
     private final long chunkLimit;
     private final int maxBufferRows;
     private final String columns;
@@ -50,6 +51,7 @@ private StreamLoadTableProperties(Builder builder) {
                 ? StreamLoadDataFormat.JSON
                 : builder.dataFormat;
 
+        this.enableUpsertDelete = builder.enableUpsertDelete;
         if (dataFormat instanceof StreamLoadDataFormat.JSONFormat) {
             chunkLimit = Math.min(3221225472L, builder.chunkLimit);
         } else {
@@ -74,6 +76,10 @@ public String getTable() {
         return table;
     }
 
+    public boolean isEnableUpsertDelete() {
+        return enableUpsertDelete;
+    }
+
     public StreamLoadDataFormat getDataFormat() {
         return dataFormat;
     }
@@ -99,6 +105,7 @@ public static class Builder {
         private String database;
         private String table;
         private String columns;
+        private boolean enableUpsertDelete;
         private StreamLoadDataFormat dataFormat;
         private long chunkLimit;
         private int maxBufferRows = Integer.MAX_VALUE;
@@ -148,6 +155,11 @@ public Builder columns(String columns) {
             return this;
         }
 
+        public Builder enableUpsertDelete(boolean enableUpsertDelete) {
+            this.enableUpsertDelete = enableUpsertDelete;
+            return this;
+        }
+
         public Builder streamLoadDataFormat(StreamLoadDataFormat dataFormat) {
             this.dataFormat = dataFormat;
             return this;