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

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