You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@inlong.apache.org by do...@apache.org on 2022/07/06 02:24:30 UTC

[inlong] branch master updated: [INLONG-4880][Manger] Modify the ClickHouse configuration to make the saved info consistent with the query (#4881)

This is an automated email from the ASF dual-hosted git repository.

dockerzhang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/inlong.git


The following commit(s) were added to refs/heads/master by this push:
     new 21643af02 [INLONG-4880][Manger] Modify the ClickHouse configuration to make the saved info consistent with the query (#4881)
21643af02 is described below

commit 21643af02284ac31dfba274c1dce042cb4935003
Author: Greedyu <de...@tencent.com>
AuthorDate: Wed Jul 6 10:24:23 2022 +0800

    [INLONG-4880][Manger] Modify the ClickHouse configuration to make the saved info consistent with the query (#4881)
---
 .../inlong/manager/common/pojo/sink/ck/ClickHouseSink.java       | 9 +++++++++
 1 file changed, 9 insertions(+)

diff --git a/inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/pojo/sink/ck/ClickHouseSink.java b/inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/pojo/sink/ck/ClickHouseSink.java
index 5ecfc820e..f5118e37f 100644
--- a/inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/pojo/sink/ck/ClickHouseSink.java
+++ b/inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/pojo/sink/ck/ClickHouseSink.java
@@ -82,6 +82,15 @@ public class ClickHouseSink extends StreamSink {
     @ApiModelProperty("ClickHouse table engine")
     private String engine;
 
+    @ApiModelProperty("Table partition information")
+    private String partitionBy;
+
+    @ApiModelProperty("Table order information")
+    private String orderBy;
+
+    @ApiModelProperty("Table primary key")
+    private String primaryKey;
+
     public ClickHouseSink() {
         this.setSinkType(SinkType.SINK_CLICKHOUSE);
     }