flink的异步Io实现原理

AsyncDataStream.(un)orderedWait 的主要工作就是创建了一个 AsyncWaitOperator。AsyncWaitOperator 是支持异步 IO 访问的算子实现,该算子会运行 AsyncFunction 并处理异步返回的结果,其内部原理如下图所示。 如图所示,AsyncWaitOperator 主要由两部分组成:StreamElementQueue 和 Emitt
相关文章
相关标签/搜索