Apache Flink源码解析之stream-transformation

以前咱们聊了Flink程序的source、sink就差transformation了。今天咱们就来解读一下Flink的transformation。它们三者的关系以下图：web 固然这仍是从Flink编程API的角度来看的（编程视角）。所谓的transformation，用于转换一个或多个DataStream从而造成一个新的DataStream对象。Flink提供编程接口，容许你组合这些trans

>>阅读原文<<