中圖網小程序
一鍵登錄
更方便
本類五星書更多>
-
>
闖進數學世界――探秘歷史名題
-
>
中醫基礎理論
-
>
當代中國政府與政治(新編21世紀公共管理系列教材)
-
>
高校軍事課教程
-
>
思想道德與法治(2021年版)
-
>
毛澤東思想和中國特色社會主義理論體系概論(2021年版)
-
>
中醫內科學·全國中醫藥行業高等教育“十四五”規劃教材
FLINK基礎入門 版權信息
- ISBN：9787302661733
- 條形碼：9787302661733 ; 978-7-302-66173-3
- 裝幀：平裝-膠訂
- 冊數：暫無
- 重量：暫無
- 所屬分類：>>
FLINK基礎入門 本書特色
本書從Flink的概念入手，進而講解Flink相關架構和原理，幫助讀者從搭建Flink集群到使用DataStream API、DataSet API和Table API&SQL實現Flink應用程序的過程進行詳細講解，并在本書的*后一章通過一個項目案例對Flink的綜合運用進行講解。本書共分為9個章節。第1章主要介紹了Flink的理論性知識，包括數據處理架構的演變、Flink關鍵特性、Flink應用場景、Flink批流模型、Flink集群運行架構等。第2章主要講解了Flink的部署，包括虛擬機的安裝、Linux操作系統的配置、JDK部署、集群部署之Flink on YARN、集群部署之Standalone、本地模式部署，以及介紹了如何了Flink命令行界面和SQL Client的使用。第3章主要講解了如何使用DataStream API實現Flink應用程序，包括DataStream程序結構、DataStream數據類型、創建執行環境、創建數據源、創建接收器、轉換操作以及涵蓋本章整體知識體系的案例。第4章主要講解了如何使用DataSet API實現Flink應用程序，包括DataSet程序結構、創建執行環境、創建數據源、創建接收器、轉換操作以及涵蓋本章整體知識體系的案例。第5章主要講解了Flink的時間和窗口，包括時間概念、窗口分配器、Watermark、窗口函數、窗口觸發器等。第6章主要講解了Flink的狀態和容錯機制，包括狀態概述、Checkpoint、State Backend、狀態編程等。第7章主要講解了如何使用Table API&SQL實現Flink應用程序，包括Table程序結構、數據類型、Catalog操作、數據庫管理、表操作以及查詢操作等。第8章內容對使用Table API&SQL實現Flink應用程序的內容進行深入講解，包括內置函數和自定義函數的使用、DataStream與表的轉換、時間屬性以及窗口操作等。第9章通過綜合項目-電商用戶行為分析對Flink的綜合運用進行操作和講解，包括項目概述、需求分析、項目架構、以及實時統計不同需求等。
本書附有配套視頻、教學PPT、教學設計、測試題等資源，同時，為了幫助初學者更好地學習本書中的內容，還提供了在線答疑，歡迎讀者關注。
FLINK基礎入門 內容簡介
本書以Flink 1.16.0為主線，全面介紹了Flink的核心概念和常用功能。全書共9章，分別講解了Flink概述，Flink部署與應用，DataStream API，DataSet API，時間與窗口，狀態和容錯機制，Table API&SQL和Flink CEP。 本書附有配套視頻、教學課件、教學設計、測試題等資源，同時，為了幫助初學者更好地學習本書內容，還提供了在線答疑，歡迎讀者關注。 本書可作為高等教育本、？圃盒祿茖W與大數據技術及相關專業的教材，還適合大數據開發初學者、大數據運維人員以及大數據分析與挖掘的從業者閱讀。
FLINK基礎入門 目錄
第1章Flink概述1
1.1數據處理架構的演變1
1.1.1傳統數據處理架構1
1.1.2有狀態流處理架構3
1.1.3Lambda架構3
1.1.4新一代流處理架構4
1.2初識Flink5
1.3Flink的關鍵特性6
1.4Flink的應用場景7
1.5Flink運行時架構8
1.5.1整體架構8
1.5.2作業管理器9
1.5.3任務管理器10
1.6Flink分層API11
1.7Flink程序結構12
1.8本章小結12
1.9課后習題12
第2章Flink部署與應用14
2.1基礎環境搭建14
2.2Flink部署模式15
2.3Standalone模式之偽分布式17
2.4Standalone模式之完全分
布式18
2.5Standalone模式之高可用
完全分布式20
2.6Flink On YARN模式27
2.7啟動Flink33
2.7.1Session模式33
2.7.2Application模式37
2.8flink命令39
2.8.1flink命令的使用39
2.8.2提交作業39
2.8.3查看作業44
2.8.4停止和取消作業50
2.9Flink Web UI54
2.9.1Flink Web UI的訪問 … 54
2.9.2使用Flink Web UI
操作作業57
2.10本章小結61
2.11課后習題61
目錄Flink基礎入門第3章DataStream API63
3.1DataStream程序的開發流程 … 63
3.2DataStream的數據類型64
3.3執行環境65
3.4數據輸入67
3.4.1從集合讀取數據67
3.4.2從文件讀取數據70
3.4.3從Socket讀取數據72
3.4.4從Kafka讀取數據73
3.4.5自定義Source78
3.5數據轉換80
3.5.1map80
3.5.2flatMap82
3.5.3filter83
3.5.4keyBy85
3.5.5reduce88
3.5.6union90
3.6數據輸出92
3.6.1輸出到文件92
3.6.2輸出到Socket96
3.6.3輸出到Kafka97
3.7應用案例——詞頻統計99
3.8本章小結100
3.9課后習題100
第4章DataSet API 102
4.1DataSet程序的開發流程102
4.2執行環境103
4.3數據輸入105
4.3.1從文件讀取數據105
4.3.2從集合讀取數據109
4.3.3從MySQL讀取數據 … 111
4.4數據轉換118
4.4.1去重118
4.4.2連接119
4.4.3聚合124
4.4.4分組125
4.4.5分區128
4.5數據輸出130
4.5.1輸出到文件130
4.5.2輸出到MySQL132
4.6應用案例——統計熱門
品牌Top10134
4.7本章小結134
4.8課后習題134
第5章時間與窗口136
5.1時間概念136
5.2窗口分類138
5.3鍵控和非鍵控窗口142
5.4窗口分配器144
5.5窗口函數146
5.5.1ReduceFunction146
5.5.2AggregateFunction147
5.5.3ProcessFunction152
5.5.4窗口函數結合使用154
5.6水位線157
5.6.1什么是水位線157
5.6.2使用水位線159
5.6.3應用案例——統計電商
網站交易數據162
5.7窗口觸發器162
5.8窗口驅逐器166
5.8.1內置驅逐器166
5.8.2自定義驅逐器168
5.9處理延遲數據171
5.9.1通過Allowed Lateness
處理延遲數據171
5.9.2通過Side Outputs處理
延遲數據173
5.10本章小結175
5.11課后習題176
第6章狀態和容錯機制177
6.1狀態概述177
6.2狀態管理179
6.2.1聲明狀態179
6.2.2定義狀態描述器180
6.2.3操作狀態182
6.3使用狀態183
6.3.1使用鍵控狀態183
6.3.2使用算子狀態188
6.4Checkpoint190
6.4.1Checkpoint概述190
6.4.2配置Checkpoint192
6.5State Backend196
6.6故障恢復198
6.7本章小結200
6.8課后習題200
第7章Table API & SQL（一）202
7.1Table程序結構202
7.2數據類型203
7.3執行環境205
7.4Catalog操作206
7.4.1注冊Catalog206
7.4.2查看Catalog210
7.4.3使用Catalog212
7.5數據庫操作213
7.5.1創建數據庫213
7.5.2查看數據庫215
7.5.3使用數據庫217
7.5.4修改數據庫218
7.5.5刪除數據庫219
7.6表操作220
7.6.1創建表220
7.6.2創建Table對象227
7.6.3查看表228
7.6.4修改表230
7.6.5修改Table對象232
7.6.6刪除表234
7.6.7輸出表236
7.7查詢操作239
7.7.1基本查詢239
7.7.2條件查詢241
7.7.3去重查詢243
7.7.4連接查詢244
7.7.5集合查詢251
7.7.6排序查詢259
7.7.7分組查詢262
7.8本章小結265
7.9課后習題265
第8章Table API & SQL（二）266
8.1函數266
8.1.1內置函數266
8.1.2自定義函數273
8.1.3注冊自定義函數276
8.1.4使用自定義函數278
8.2DataStream與Table對象的
轉換282
8.3時間屬性285
8.4窗口操作287
8.4.1Group Window287
8.4.2Over Window293
8.5本章小結298
8.6課后習題298
第9章Flink CEP300
9.1Flink CEP基本概述300
9.2模式301
9.2.1個體模式301
9.2.2組合模式303
9.3模式的定義305
9.3.1定義個體模式305
9.3.2定義個體模式的條件 … 309
9.3.3定義組合模式313
9.3.4模式組314
9.3.5匹配后跳過策略315
9.4使用模式檢測數據流317
9.5處理超時事件328
9.6處理延遲事件332
9.7應用案例——直播平臺檢測
刷屏用戶333
9.8本章小結333
9.9課后習題334
1.1數據處理架構的演變1
1.1.1傳統數據處理架構1
1.1.2有狀態流處理架構3
1.1.3Lambda架構3
1.1.4新一代流處理架構4
1.2初識Flink5
1.3Flink的關鍵特性6
1.4Flink的應用場景7
1.5Flink運行時架構8
1.5.1整體架構8
1.5.2作業管理器9
1.5.3任務管理器10
1.6Flink分層API11
1.7Flink程序結構12
1.8本章小結12
1.9課后習題12
第2章Flink部署與應用14
2.1基礎環境搭建14
2.2Flink部署模式15
2.3Standalone模式之偽分布式17
2.4Standalone模式之完全分
布式18
2.5Standalone模式之高可用
完全分布式20
2.6Flink On YARN模式27
2.7啟動Flink33
2.7.1Session模式33
2.7.2Application模式37
2.8flink命令39
2.8.1flink命令的使用39
2.8.2提交作業39
2.8.3查看作業44
2.8.4停止和取消作業50
2.9Flink Web UI54
2.9.1Flink Web UI的訪問 … 54
2.9.2使用Flink Web UI
操作作業57
2.10本章小結61
2.11課后習題61
目錄Flink基礎入門第3章DataStream API63
3.1DataStream程序的開發流程 … 63
3.2DataStream的數據類型64
3.3執行環境65
3.4數據輸入67
3.4.1從集合讀取數據67
3.4.2從文件讀取數據70
3.4.3從Socket讀取數據72
3.4.4從Kafka讀取數據73
3.4.5自定義Source78
3.5數據轉換80
3.5.1map80
3.5.2flatMap82
3.5.3filter83
3.5.4keyBy85
3.5.5reduce88
3.5.6union90
3.6數據輸出92
3.6.1輸出到文件92
3.6.2輸出到Socket96
3.6.3輸出到Kafka97
3.7應用案例——詞頻統計99
3.8本章小結100
3.9課后習題100
第4章DataSet API 102
4.1DataSet程序的開發流程102
4.2執行環境103
4.3數據輸入105
4.3.1從文件讀取數據105
4.3.2從集合讀取數據109
4.3.3從MySQL讀取數據 … 111
4.4數據轉換118
4.4.1去重118
4.4.2連接119
4.4.3聚合124
4.4.4分組125
4.4.5分區128
4.5數據輸出130
4.5.1輸出到文件130
4.5.2輸出到MySQL132
4.6應用案例——統計熱門
品牌Top10134
4.7本章小結134
4.8課后習題134
第5章時間與窗口136
5.1時間概念136
5.2窗口分類138
5.3鍵控和非鍵控窗口142
5.4窗口分配器144
5.5窗口函數146
5.5.1ReduceFunction146
5.5.2AggregateFunction147
5.5.3ProcessFunction152
5.5.4窗口函數結合使用154
5.6水位線157
5.6.1什么是水位線157
5.6.2使用水位線159
5.6.3應用案例——統計電商
網站交易數據162
5.7窗口觸發器162
5.8窗口驅逐器166
5.8.1內置驅逐器166
5.8.2自定義驅逐器168
5.9處理延遲數據171
5.9.1通過Allowed Lateness
處理延遲數據171
5.9.2通過Side Outputs處理
延遲數據173
5.10本章小結175
5.11課后習題176
第6章狀態和容錯機制177
6.1狀態概述177
6.2狀態管理179
6.2.1聲明狀態179
6.2.2定義狀態描述器180
6.2.3操作狀態182
6.3使用狀態183
6.3.1使用鍵控狀態183
6.3.2使用算子狀態188
6.4Checkpoint190
6.4.1Checkpoint概述190
6.4.2配置Checkpoint192
6.5State Backend196
6.6故障恢復198
6.7本章小結200
6.8課后習題200
第7章Table API & SQL（一）202
7.1Table程序結構202
7.2數據類型203
7.3執行環境205
7.4Catalog操作206
7.4.1注冊Catalog206
7.4.2查看Catalog210
7.4.3使用Catalog212
7.5數據庫操作213
7.5.1創建數據庫213
7.5.2查看數據庫215
7.5.3使用數據庫217
7.5.4修改數據庫218
7.5.5刪除數據庫219
7.6表操作220
7.6.1創建表220
7.6.2創建Table對象227
7.6.3查看表228
7.6.4修改表230
7.6.5修改Table對象232
7.6.6刪除表234
7.6.7輸出表236
7.7查詢操作239
7.7.1基本查詢239
7.7.2條件查詢241
7.7.3去重查詢243
7.7.4連接查詢244
7.7.5集合查詢251
7.7.6排序查詢259
7.7.7分組查詢262
7.8本章小結265
7.9課后習題265
第8章Table API & SQL（二）266
8.1函數266
8.1.1內置函數266
8.1.2自定義函數273
8.1.3注冊自定義函數276
8.1.4使用自定義函數278
8.2DataStream與Table對象的
轉換282
8.3時間屬性285
8.4窗口操作287
8.4.1Group Window287
8.4.2Over Window293
8.5本章小結298
8.6課后習題298
第9章Flink CEP300
9.1Flink CEP基本概述300
9.2模式301
9.2.1個體模式301
9.2.2組合模式303
9.3模式的定義305
9.3.1定義個體模式305
9.3.2定義個體模式的條件 … 309
9.3.3定義組合模式313
9.3.4模式組314
9.3.5匹配后跳過策略315
9.4使用模式檢測數據流317
9.5處理超時事件328
9.6處理延遲事件332
9.7應用案例——直播平臺檢測
刷屏用戶333
9.8本章小結333
9.9課后習題334
展開全部
FLINK基礎入門 作者簡介
黑馬程序員，傳智播客旗下 教育品牌，成立于2006年，它是由中國Java培訓先行者張孝祥老師發起，聯合中文IT社區CSDN、中關村軟件園共同創辦的一家專業教育機構。辦學至今，我們一直堅守著“為千萬人少走彎路而著書，為中華軟件之崛起而講課”的辦學理念，堅持培養 軟件應用工程師的宏偉目標，在累計培養的十萬余名學員中。
書友推薦
- >
中國歷史的瞬間
- >
回憶愛瑪儂
- >
煙與鏡
- >
企鵝口袋書系列·偉大的思想20:論自然選擇(英漢雙語)
- >
姑媽的寶刀
- >
隨園食單
- >
山海經
- >
二體千字文
本類暢銷
