searchusermenu
  • 发布文章
  • 消息中心
点赞
收藏
评论
分享
原创

Clickhouse数据库创建分布式表方法

2024-11-28 09:53:13
0
0

创建本地表

CREATE TABLE my_city_local ON CLUSTER ck_cluster_name ( `fdate` Int64, `city_code` Int32, `city_name` String, `total_cnt` Int64 ) ENGINE = ReplicatedMergeTree('/clickhouse/tables/{shard}/my_city_local ', '{replica}') PARTITION BY fdate ORDER BY (fdate, city_code, city_name) SETTINGS index_granularity = 8192;

在这个示例中:

  • ON CLUSTER ck_cluster_name 表示在名为ck_cluster_name的集群上创建表。
  • ReplicatedMergeTree 是存储引擎,它接受两个参数:ZooKeeper中表的路径和副本名称。
  • {shard}{replica} 是宏替换占位符,它们会被替换为配置文件中的实际值。

创建分布式表

CREATE TABLE IF NOT EXISTS my_city_all ON CLUSTER ck_cluster_name AS my_city_local
ENGINE = Distributed(ck_cluster_name, test_db, my_city_local, fdate);

通过以上步骤,您可以在ClickHouse中创建分布式表,并利用其强大的分布式查询能力来处理大规模数据。

0条评论
0 / 1000
张****民
4文章数
0粉丝数
张****民
4 文章 | 0 粉丝
张****民
4文章数
0粉丝数
张****民
4 文章 | 0 粉丝
原创

Clickhouse数据库创建分布式表方法

2024-11-28 09:53:13
0
0

创建本地表

CREATE TABLE my_city_local ON CLUSTER ck_cluster_name ( `fdate` Int64, `city_code` Int32, `city_name` String, `total_cnt` Int64 ) ENGINE = ReplicatedMergeTree('/clickhouse/tables/{shard}/my_city_local ', '{replica}') PARTITION BY fdate ORDER BY (fdate, city_code, city_name) SETTINGS index_granularity = 8192;

在这个示例中:

  • ON CLUSTER ck_cluster_name 表示在名为ck_cluster_name的集群上创建表。
  • ReplicatedMergeTree 是存储引擎,它接受两个参数:ZooKeeper中表的路径和副本名称。
  • {shard}{replica} 是宏替换占位符,它们会被替换为配置文件中的实际值。

创建分布式表

CREATE TABLE IF NOT EXISTS my_city_all ON CLUSTER ck_cluster_name AS my_city_local
ENGINE = Distributed(ck_cluster_name, test_db, my_city_local, fdate);

通过以上步骤,您可以在ClickHouse中创建分布式表,并利用其强大的分布式查询能力来处理大规模数据。

文章来自个人专栏
小张的数据库
1 文章 | 1 订阅
0条评论
0 / 1000
请输入你的评论
0
0