Apache Flink v1.8（概念-数据流编程模型）

抽象层次 Flink提供了不同级别的抽象来开发流/批处理应用程序。 最低级抽象只提供有状态流。它通过Process Function嵌入到DataStream API中。它允许用户自由处理来自一个或多个流的事件，并使用一致的容错状态。此外，用户可以注册事件时间和处理时间回调，允许程序实现复杂的计算。 在实践中，大多数应用程序不需要上述低级抽象，而是针对Core API编程， 如DataStream

>>阅读原文<<