==作者：YB-Chi==

1. 通过cluster在每个节点创建本地表

CREATE TABLE st_order_mt ON CLUSTER cyb_cluster
(
    `id` UInt32,
    `sku_id` String,
    `total_amount` Decimal(16, 2),
    `create_time` Datetime
)
ENGINE = ReplicatedMergeTree('/clickhouse/tables/{shard}/st_order_mt', '{replica}')
PARTITION BY toYYYYMMDD(create_time)
PRIMARY KEY id
ORDER BY (id, sku_id)

2. 创建Distribute分布式表

CREATE TABLE st_order_mt_ALL ON CLUSTER cyb_cluster
(
    `id` UInt32,
    `sku_id` String,
    `total_amount` Decimal(16, 2),
    `create_time` Datetime
)
ENGINE = Distributed(cyb_cluster, cyb, st_order_mt, hiveHash(sku_id))