Artykuły według tagu: streaming

Materializowane widoki ClickHouse: wyzwalacze na INSERT

Jak działają MV w ClickHouse: agregacja inkrementalna, łańcuchy minuta→godzina→dzień, wzorzec Null+Kafka, POPULATE i jego zagrożenia. Przykłady z SummingMergeTree i AggregatingMergeTree.

Flink real-time JOIN: tabele 4+2 TB

Implementacja stateful JOIN na Apache Flink do aktualizacji wyniku w czasie rzeczywistym między tabelami terabajtowymi. Table API, KeyedCoProcessFunction, MapState. Kod i architektura dla middle/senior.