按标签查看文章: streaming

ClickHouse 物化视图：INSERT 触发器

ClickHouse 中 MV 的工作原理：增量聚合、分钟→小时→天链、Null+Kafka 模式、POPULATE 及其风险。包含 SummingMergeTree 和 AggregatingMergeTree 的示例。

Flink 实时 JOIN：表 4+2 TB

在 Apache Flink 上实现有状态 JOIN，用于 TB 级表之间实时结果更新。Table API、KeyedCoProcessFunction、MapState。中高级代码和架构。