clickhouse集群部署以及分布式表引擎使用

-- 假设我们已经有了一个ClickHouse集群，并且知道集群中的一些节点信息。
-- 首先，我们需要创建一个分布式表，它将关联到集群中的本地表。
 
-- 在所有节点上创建本地表
CREATE TABLE IF NOT EXISTS ontime_local ON CLUSTER cluster_name (
  `FlightDate` Date,
  `UniqueCarrier` String,
  ... -- 其他字段
) ENGINE = MergeTree()
PARTITION BY toYYYYMM(FlightDate)
ORDER BY (UniqueCarrier, FlightDate);
 
-- 创建分布式表，它将关联到上面创建的本地表
CREATE TABLE IF NOT EXISTS ontime_distributed ON CLUSTER cluster_name (
  `FlightDate` Date,
  `UniqueCarrier` String,
  ... -- 其他字段
) ENGINE = Distributed(cluster_name, default, ontime_local, rand());
 
-- 现在，你可以通过分布式表来执行查询，ClickHouse将负责在整个集群中分发和执行这些查询。
SELECT count(*) FROM ontime_distributed;

这个例子展示了如何在ClickHouse集群中创建分布式表。首先，我们在集群的每个节点上创建了本地表，然后我们创建了一个分布式表，它关联到了这些本地表。最后，我们通过分布式表执行了一个查询，这个查询会在整个集群中并行执行。这种方式可以有效提升查询性能，特别是处理大数据集时。