Flink

簡單介紹 Flink時apache的頂級項目,使用java語言編寫!(在這個scala氾濫的時代還真是使人感動呢)java 支持流處理,也支持批處理。Flink最大的原則就是,以流處理爲根本。Flink認爲批處理應該在流處理上實現。經過插入barrier事件來標記微批,收到該事件後,進行checkpoint快照。發現處理失敗,就根據快照恢復而後進行流重放。node flink的checkpoint
相關文章
相關標籤/搜索