本文使用Reactor來實現(xiàn)Flink的window功能來舉例,其他操作符理論上相同。文中涉及的代碼:github 二、實現(xiàn)過程 Flink對流式處理做的很好的封裝,使用Flink的時候幾乎不用關(guān)心線程池、積壓、數(shù)據(jù)丟失等問題,但是使用Reactor實現(xiàn)類似的功能就必須對Reactor運行原理比較了解,并且經(jīng)過不同場景下測試,否則很容易出問題。
www.dbjr.com.cn/article/2065...htm 2025-6-5