95-136-043-源碼-Operator-CoProcessOperator

Window Join 可以友善地對兩個資料流進行關聯操作。但有些使用場景中，我們需要的并非關聯操作，

ConnectedStreams

提供了更為通用的雙流操作。

​

ConnectedStreams

配合

CoProcessFunction

或

KeyedCoProcessFunction

使用，

KeyedCoProcessFunction

要求連接配接的兩個 stream 都是

KeyedStream

，并且 key 的類型一緻。

​

ConnectedStreams

配合

CoProcessFunction

生成

CoProcessOperator

，在運作時被排程為

TwoInputStreamTask

，從名字也可以看書來，這個 Task 處理的是兩個輸入。

TwoInputStreamTask

在前面關于 Task 的生命周期的文章中已經進行了介紹。我們簡單看一下

CoProcessOperator

的實作：