介绍
ClickHouse 数据目的表支持将数据写入到 ClickHouse。
注意
ClickHouse 数据目的表的表引擎必须使用 CollapsingMergeTree。
常见数据类型映射
Flink 数据类型 | ClickHouse 对应数据类型 |
VARCHAR | String/FixedString(N) |
STRING | String/FixedString(N) |
BOOLEAN | 没有单独类型存储，可以使用 UInt8 来存储布尔类型，将取值限制为0或1；或者使用字符串存储 true/false 来表示 |
DECIMAL | Decimal32(S)/Decimal64(S)/Decimal128(S) |
TINYINT | Int8 |
SMALLINT | Int16 |
INTEGER | Int32 |
BIGINT | Int64 |
FLOAT | Float32 |
DOUBLE | Float64 |
DATE | Date |
TIMESTAMP | DateTime |
TIMESTAMP WITH LOCAL TIME ZONE | DateTime，示例 DateTime64(3, 'Asia/Shanghai') |
注意事项
主键说明
使用 ClickHouse 数据目的表时，需要按照建表语句正确的定义主键，否则有可能无法正确同步修改与删除操作。
折叠字段
ClickHouse 的 CollapsingMergeTree 引擎在合并算法中添加了折叠行的逻辑。折叠字段在使用 CollapsingMergeTree 引擎建表时所指定：
ENGINE = CollapsingMergeTree(Sign) 。对 ClickHouse 折叠详细说明可参考 ClickHouse 官方文档。