Flink基础概念&编程模型

Flink基础概念&编程模型 Flink程序的基础构建模块是流（Streams）与转换（transformations) 每一个数据流起始于一个或者多个source，并终止于一个或者多个sink 下面是一个由Flink程序映射为Streaming Dataflow的示意图 并行数据流示意图 时间窗口： 流上的聚合需要由窗口来划定范围，比如，计算过去的5分钟，或者最后100个元素的和 窗口通常被区分

>>阅读原文<<