| 语法 | ENGINE = Distributed(cluster, database, local_table[, sharding_key]) |
|---|---|
| 写入 | 直接 INSERT 到分布式表时按分片键路由，不带分片键则随机/轮询分布 |
| 查询 | SELECT 会扇出到所有分片，聚合在协调节点二次汇总 |
示例
示例
CREATE TABLE events_all ON CLUSTER prod AS events_local
ENGINE = Distributed('prod', 'analytics', 'events_local', rand());
-- 按 user_id 哈希分片
-- ENGINE = Distributed('prod', 'analytics', 'events_local', cityHash64(user_id));
SELECT count() FROM events_all;生产上通常查询分布式表做跨分片统计，对单分片明细/后台任务则直接查本地表更省资源。