Articles by tag: streaming

ClickHouse Materialized Views: triggers on INSERT

How MV work in ClickHouse: incremental aggregation, chains minute→hour→day, Null+Kafka pattern, POPULATE and its dangers. Examples with SummingMergeTree and AggregatingMergeTree.

Flink real-time JOIN: tables 4+2 TB

Implementation of stateful JOIN on Apache Flink for real-time result updates between terabyte tables. Table API, KeyedCoProcessFunction, MapState. Code and architecture for middle/senior.