#stream-processing

無界輸入表 t1 一批 t2 一批 t3 新到 …持續 append 表一直長高 同一個查詢groupBy/agg… 結果表(持續更新) aggregate result

Structured Streaming 入門:把串流當成一張無界的表

· tech · 約 6 分鐘 · 📚 Spark 學習筆記 #5

前四篇都在講批次的 Spark —— 是什麼、DataFrame 實戰、shuffle 調校、怎麼跑起來。但資料不會等你湊成一批才來:訂單、點擊、日誌是持續流進來的。這篇講 Spark 處理串流的方式…

#spark#data-engineering#stream-processing

Kafka topics / log MySQL / API 來源系統 DW / ES / S3 下游系統 Connect source Connect sink Schema Registry Kafka Streams 讀 → 運算 → 寫回

Kafka 生態系:Connect、Schema Registry 與 Streams

· tech · 約 8 分鐘 · 📚 Kafka 學習筆記 #4

前三篇都在講 Kafka broker 本身 —— 可重播的 log、核心模型、投遞保證。但真實世界裡你幾乎不會「只用 broker」:資料要從別的系統搬進來、事件的長相要有人管、流上還得做轉換與聚合…

#kafka#data-engineering#stream-processing