Flink1.4 用於外部數據訪問的異步IO

原文來源:Flink1.4 用於外部數據訪問的異步IOhtml 1. 異步IO操做的必要性 當與外部系統交互時(例如,使用存儲在數據庫中數據豐富流事件),須要注意與外部系統的通訊延遲並不決定流應用程序的總體工做。訪問外部數據庫中的數據(例如在 MapFunction 中)一般意味着同步交互:將請求發送到數據庫,MapFunction 會等待直到收到響應。在許多狀況下,這個等待時間佔了該函數絕大部分
相關文章
相關標籤/搜索