Apache Flink源碼解析之stream-operator

前面咱們談論了Flink stream中的transformation。你能夠將transformation當作編寫Flink程序並構建流式處理程序的必要組成部分（靜態表現形式）；而本篇咱們將探討transformation在Flink運行時對應的動態表現形式——operator。他們之間的映射關係見下圖：javascript 具體的探討能夠查看前文：Flink中的一些核心概念java Strea

>>阅读原文<<