clickhouse创建分布式表

查询cluster

select * from `system`.clusters

创建分布式数据库

create database test on cluster clickhouse_cluster

创建本地表

/* 创建本地表 */
CREATE TABLE test.user_local on cluster clickhouse_cluster
(
    /* 客户标识信息 */
    `userId` UInt32 COMMENT '用户id',
    `userName` String COMMENT '用户名',
    `create_date` DateTime COMMENT '创建时间'
)
ENGINE = ReplicatedMergeTree('/clickhouse/test/user_local/{shard}','{replica}')
ORDER BY userId
SETTINGS index_granularity = 8192;

创建分布式表

CREATE TABLE test.user on cluster clickhouse_cluster 
as test.t_customer_local
ENGINE = Distributed('clickhouse_cluster', 'test', 'user_local', rand());