Flink编程模型

4.1 抽象的层级 有状态的数据流处理层。最底层的抽象仅仅提供有状态的数据流，它通过处理函数（Process Function）嵌入到数据流api(DataStream API). 用户可以通过它自由的处理单流或者多流，并保持一致性和容错。同时用户可以注册事件时间和处理时间的回调处理，以实现复杂的计算逻辑。 核心API层，DataSet 处理有界的数据集，DataStream 处理有界或者无界的数

>>阅读原文<<