Apache Flink 入門 (第二篇)(流式處理及FLINK具有的優勢)

「有狀態的流式處理」概念解析 1. 傳統批處理 傳統批處理方法是持續收取數據，以時間作爲劃分多個批次的依據，再週期性地執行批次運算。 但假設需要計算每小時出現事件轉換的次數，如果事件轉換跨越了所定義的時間劃分，傳統批處理會將中間運算結果帶到下一個批次進行計算；除此之外，當出現接收到的事件順序顛倒情況下，傳統批處理仍會將中間狀態帶到下一批次的運算結果中，這種處理方式也不盡如人意。 2. 理想方法 第

>>阅读原文<<