异构转换规则

-- 使用 CDC 同步 MySQL 库表 sbtest.sbtest1 到 LibraSQL 分析引擎，自定义分区键为 t
-- MySQL 表定义
CREATE TABLE `sbtest1` (
`id` int(11) NOT NULL AUTO_INCREMENT,
`k` int(11) NOT NULL DEFAULT '0',
`c` char(120) NOT NULL DEFAULT '',
`pad` char(60) NOT NULL DEFAULT '',
`t` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP,
PRIMARY KEY (`id`),
KEY `k_1` (`k`)
) ENGINE=InnoDB AUTO_INCREMENT=10001 DEFAULT CHARSET=utf8

-- 转换到 LibraSQL 分析引擎的本地表
CREATE TABLE sbtest.sbtest1_local (
`id` Int32, 
`k` Int32, 
`c` String, 
`pad` String, 
`t` DateTime, 
`_sign` Int8, 
`_version` UInt64
) ENGINE = ReplicatedReplacingMergeTree('/clickhouse/sbtest/tables/sbtest1_local/{shard}', '{replica}', _version) 
PARTITION BY toYYYYMM(t) 
ORDER BY id 
SETTINGS index_granularity = 8192

-- 转换到 LibraSQL 分析引擎的分布式表
CREATE TABLE sbtest.sbtest1 (
`id` Int32, 
`k` Int32, 
`c` String, 
`pad` String, 
`t` DateTime, 
`_sign` Int8, 
`_version` UInt64
) ENGINE = Distributed('default_cluster', 'sbtest', 'sbtest1_local', cityHash64(id))