(四)Apache Flink 基本概念 — 编程模型

Flink 数据流编程模型 1. 抽象级别 Flink 提供了不同级别的抽象,以开发流或批处理作业。 最底层级的抽象仅仅提供了有状态流,它将通过过程函数(Process Function)被嵌入到 DataStream API 中。它允许用户可以自由地处理来自一个或多个数据流的事件,并使用一致的容错的状态,除此之外,用户可以注册事件事件并处理时间回调,从而使程序可以处理复杂的计算。 实际上,大多数
相关文章
相关标签/搜索