Preface
前言

為什么要寫這本書

相比于國內很多用戶來說，我接觸Flink的時間不算長，我是從2019年開始學習和使用Flink解決工作中遇到的問題的，那么是什么原因促使我寫這本書？

第一，我想把我對Flink特性的理解進行系統的總結。我在初期學習Flink時，在窗口、有狀態計算等特性的學習上投入的成本是比較高的。隨著使用Flink越來越多，對Flink的各種特性越來越熟悉，我將自己對于Flink的理解和使用經驗整理成文章，并且發布在公眾號“大數據羊說”上。隨著公眾號的讀者越來越多，我也收到了越來越多的反饋。總結下來，我的文章能夠吸引讀者的亮點在于，我是從背景知識、要解決的問題以及Flink中的實現方案這3個角度解釋Flink的技術特性，而這一點恰好是很多想要深入學習Flink但是找不到好的學習資料的讀者急需的。很多讀者的反饋給了我持續寫文章的動力，也讓我產生了寫一本書來幫助更多讀者的想法。

第二，我算得上是Flink SQL API的早期用戶，Flink SQL API由于具有易用的特性，用戶越來越多，發展勢頭越來越猛、而市面上關于Flink SQL API的中文資料比較少，因此我想將自己對于Flink SQL API的理解梳理出來，在推廣Flink SQL API的同時也能夠幫助讀者學習Flink SQL API。

讀者對象

本書適合以下讀者閱讀。

?開設Flink相關課程的院校師生。

?實時計算開發工程師。

?大數據開發工程師。

如何閱讀本書

本書詳細剖析了Flink中的時間、窗口、有狀態計算和檢查點這4項核心難點，盡可能降低讀者的學習成本，并且相對全面地介紹了Flink SQL API的內容。本書分為11章，各章內容層層遞進。

第1～3章是Flink初學者必讀內容，主要介紹Flink的由來、特性、API的使用方法和運行時的架構。

如果讀者想使用Java開發一個Flink流處理作業，推薦仔細閱讀第4～7章。第4章介紹Flink DataStream API中的基礎接口。第5章和第6章介紹Flink中的時間、窗口、有狀態計算和檢查點的相關知識。第7章介紹Flink有狀態流處理API。

如果讀者想使用SQL開發一個Flink流處理作業，推薦仔細閱讀第8～11章。第8章介紹Flink Table API和SQL API中的基礎概念，第9章介紹Flink SQL API中的語法及其執行過程，第10章介紹Flink SQL API中的函數，第11章介紹Flink SQL API中的參數及SQL優化方法。

勘誤和支持

由于水平有限，書中難免會出現一些錯誤或者不準確的地方，懇請讀者批評指正，并將寶貴的意見反饋到公眾號“大數據羊說”的后臺中。

由于Flink技術的參考資料較少，因此書中的部分內容參考了Flink官方文檔，讀者可以結合Flink官網來學習。此外，書中的代碼源文件可以從GitHub網站下載，地址為https://github.com/yangyichao-mango/flink-study.git。

致謝

在寫作過程中，我得到了很多朋友的支持。感謝公眾號的讀者，因為有他們的支持，我才能堅持將本書寫完。感謝我的父母將我培養成人，并時時刻刻為我傳遞信心和力量！

謹以此書獻給我最親愛的家人，以及眾多熱愛Flink的朋友！