From 4611a7ea6bce6b2ce9a6cac052df31ff2ce7058c Mon Sep 17 00:00:00 2001 From: densonyu Date: Tue, 5 Jul 2022 21:33:31 +0800 Subject: [PATCH] The query is consistent with the saved configuration. --- .../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 5ecfc820ebd..f5118e37f75 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); }