3.4.4　理解操作符鏈

在1.3.3節中，曾經介紹過操作符鏈，這是Flink采用的一種稱為Operator chain的優化技術，可以在特定條件下減小本地通信的開銷。為了滿足操作符鏈的要求，必須將兩個及以上的操作符（算子）設為相同的并行度，并通過本地轉發（Local Forward）的方式進行連接。

將操作符（算子）合并為運算符鏈有以下兩個必需條件：

（1）操作符（算子）的并行度相同。

（2）合并操作符鏈的運算符（算子）都是one-to-one分發模式。

將操作符（算子）合并為操作符鏈之后，原來的操作符（算子）成為里面的子任務，如圖3-19所示。

圖3-19　操作符鏈合并

如果要為流操作符禁用操作符鏈，則可以使用的方法如下：