Flink1.4 用于外部数据访问的异步IO

原文来源:Flink1.4 用于外部数据访问的异步IOhtml 1. 异步IO操做的必要性 当与外部系统交互时(例如,使用存储在数据库中数据丰富流事件),须要注意与外部系统的通讯延迟并不决定流应用程序的总体工做。访问外部数据库中的数据(例如在 MapFunction 中)一般意味着同步交互:将请求发送到数据库,MapFunction 会等待直到收到响应。在许多状况下,这个等待时间占了该函数绝大部分
相关文章
相关标签/搜索