use merge_condition

StarRocks · Nov 14, 2022 · c34e417 · c34e417
1 parent c6ffc09
commit c34e417
Showing 1 changed file with 3 additions and 4 deletions.
diff --git a/fe/fe-core/src/main/java/com/starrocks/analysis/BrokerDesc.java b/fe/fe-core/src/main/java/com/starrocks/analysis/BrokerDesc.java
@@ -21,6 +21,7 @@
 import com.starrocks.common.io.Text;
 import com.starrocks.common.io.Writable;
 import com.starrocks.common.util.PrintableMap;
+import com.starrocks.sql.ast.LoadStmt;
 
 import java.io.DataInput;
 import java.io.DataOutput;
@@ -40,8 +41,6 @@ public class BrokerDesc implements Writable {
     private Map<String, String> properties;
     private boolean hasBroker;
 
-    public static final String MERGE_CONDITION_KEY = "mergeCondition";
-
     // Only used for recovery
     private BrokerDesc() {
     }
@@ -77,8 +76,8 @@ public Map<String, String> getProperties() {
     }
 
     public String getMergeConditionStr() {
-        if (properties.containsKey(MERGE_CONDITION_KEY)) {
-            return properties.get(MERGE_CONDITION_KEY);
+        if (properties.containsKey(LoadStmt.MERGE_CONDITION)) {
+            return properties.get(LoadStmt.MERGE_CONDITION);
         }
         return "";
     }