设计建设网站哪家好,网站做程序员,花店网站设计,360建筑网挂行情1. What is Apache Flink?
Apache Flink 是一款用来进行分布式流数据和批数据处理的开源平台。Apache Flink 是一个对有界数据流和无界数据流进行有状态计算的框架和分布式处理引擎。Flink 被设计用于在所有常见的集群环境中运行#xff0c;以内存中的速度和任意规模进行计算…1. What is Apache Flink?
Apache Flink 是一款用来进行分布式流数据和批数据处理的开源平台。Apache Flink 是一个对有界数据流和无界数据流进行有状态计算的框架和分布式处理引擎。Flink 被设计用于在所有常见的集群环境中运行以内存中的速度和任意规模进行计算。
重要的概念
进行有界和无界数据的处理
所有类型的数据都作为一个事件流被生产出来。信用卡流水监测器数据日志文件或者是用户与网站或者是手机 App 的交互所有的这些数据都是以流的形式产生。
无界流有一个起始点但不知何时结束。
概念
数据流编程模型Dataflow Programming Model
Levels of Abstraction (抽象等级)
Flink 为流/批应用开发提供了不同的抽象等级。 最低级别的抽象提供了简单的有状态流它通过过程函数被嵌入到 DataStream API 中。它允许用户自由地处理一个或多个流中的事件并且使用一致的容错状态。此外用户可以注册事件时间和处理时间回调允许程序实现复杂的计算。
Programs and Dataflows
