Merge #29 into master from pingkang

列更新

* pingkang: (1 commits)
  列更新

Signed-off-by: 1129979389@qq.com <accounts_6361eaad7b63b44dd7833e63@mail.teambition.com>
Merged-by: 1129979389@qq.com <accounts_6361eaad7b63b44dd7833e63@mail.teambition.com>

CR-link: https://codeup.aliyun.com/60c06368dbbed34fe0f0c263/job/hr_job-kuaishou/change/29

job-kuaishou/src/main/java/cn/com/ctop/job/kuaishou/utils/doris/sink/DorisMultiTableStreamLoadManager.java

@@ -28,7 +28,7 @@ public class DorisMultiTableStreamLoadManager {
     }
 
     public void add(String database, String table, Object obj) {
-        TableKey key = new TableKey(database, table);
+        TableKey key = new TableKey(database, table,"");
         if (obj instanceof Collection) {
             Collection<?> collection = (Collection<?>) obj;
             for (Object o : collection) {
@@ -42,7 +42,7 @@ public class DorisMultiTableStreamLoadManager {
     }
 
     public void add(String database, String table, Object obj, String updateColumns) {
-        TableKey key = new TableKey(database, table);
+        TableKey key = new TableKey(database, table,updateColumns);
         if (obj instanceof Collection) {
             Collection<?> collection = (Collection<?>) obj;
             for (Object o : collection) {

job-kuaishou/src/main/java/cn/com/ctop/job/kuaishou/utils/doris/sink/TableKey.java

@@ -10,10 +10,11 @@ import java.util.Objects;
 public class TableKey {
     private String database;
     private String table;
+    private String updateColumns;
 
     @Override
     public int hashCode() {
-        return Objects.hash(database, table);
+        return Objects.hash(database, table, updateColumns);
     }
 
     @Override
@@ -21,6 +22,6 @@ public class TableKey {
         if (this == obj) return true;
         if (!(obj instanceof TableKey)) return false;
         TableKey other = (TableKey) obj;
-        return Objects.equals(database, other.database) && Objects.equals(table, other.table);
+        return Objects.equals(database, other.database) && Objects.equals(table, other.table) && Objects.equals(updateColumns, other.updateColumns);
     }
 }