flink的異步Io實現原理

AsyncDataStream.(un)orderedWait 的主要工作就是創建了一個 AsyncWaitOperator。AsyncWaitOperator 是支持異步 IO 訪問的算子實現，該算子會運行 AsyncFunction 並處理異步返回的結果，其內部原理如下圖所示。 如圖所示，AsyncWaitOperator 主要由兩部分組成：StreamElementQueue 和 Emitt

>>阅读原文<<