Flink中的API层级划分

Flink 中的 API Flink 为流式/批式处理应用程序的开发提供了不同级别的抽象。 Flink API 最底层的抽象为有状态实时流处理。其抽象实现是 Process Function，并且 Process Function被 Flink 框架集成到了 DataStream API中来为我们使用。它允许用户在应用程序中自由地处理来自单流或多流的事件（数据），并提供具有全局一致性和容错保障的状

>>阅读原文<<