Artikel nach Tag: Streaming

ClickHouse Materialized Views: Trigger bei INSERT

Wie MV in ClickHouse funktionieren: inkrementelle Aggregation, Ketten Minute→Stunde→Tag, Null+Kafka-Muster, POPULATE und seine Gefahren. Beispiele mit SummingMergeTree und AggregatingMergeTree.

Flink Echtzeit-JOIN: Tabellen 4+2 TB

Implementierung eines zustandsbehafteten JOIN auf Apache Flink für Echtzeit-Ergebnisupdates zwischen Terabyte-Tabellen. Table API, KeyedCoProcessFunction, MapState. Code und Architektur für Middle/Senior.