1. What is Apache Flink?

Apache Flink 是一款用來進(jìn)行分布式流數(shù)據(jù)和批數(shù)據(jù)處理的開源平臺(tái)。Apache Flink 是一個(gè)對(duì)有界數(shù)據(jù)流和無界數(shù)據(jù)流進(jìn)行有狀態(tài)計(jì)算的框架和分布式處理引擎。Flink 被設(shè)計(jì)用于在所有常見的集群環(huán)境中運(yùn)行，以內(nèi)存中的速度和任意規(guī)模進(jìn)行計(jì)算。

重要的概念：

進(jìn)行有界和無界數(shù)據(jù)的處理

所有類型的數(shù)據(jù)都作為一個(gè)事件流被生產(chǎn)出來。信用卡流水，監(jiān)測(cè)器數(shù)據(jù)，日志文件，或者是用戶與網(wǎng)站或者是手機(jī) App 的交互，所有的這些數(shù)據(jù)都是以流的形式產(chǎn)生。

無界流：有一個(gè)起始點(diǎn)，但不知何時(shí)結(jié)束。

概念

數(shù)據(jù)流編程模型（Dataflow Programming Model）

Levels of Abstraction (抽象等級(jí))

Flink 為流/批應(yīng)用開發(fā)提供了不同的抽象等級(jí)。

最低級(jí)別的抽象提供了簡單的有狀態(tài)流，它通過過程函數(shù)被嵌入到 DataStream API 中。它允許用戶自由地處理一個(gè)或多個(gè)流中的事件，并且使用一致的容錯(cuò)狀態(tài)。此外，用戶可以注冊(cè)事件時(shí)間，和處理時(shí)間回調(diào)，允許程序?qū)崿F(xiàn)復(fù)雜的計(jì)算。

Programs and Dataflows

總結(jié)

以上是生活随笔為你收集整理的Flink官网自学笔记的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。