項目1 Flink開發(fā)環(huán)境搭建 1
任務 搭建Flink開發(fā)環(huán)境 2
【任務描述】 2
【知識鏈接】 2
【任務實施】 8
項目小結(jié) 18
思考與練習 18

項目2 Flink集群搭建 20
任務1 Flink集群搭建 21
【任務描述】 21
【知識鏈接】 21
【任務實施】 23
任務2 基于Flink實現(xiàn)單詞統(tǒng)計 26
【任務描述】 26
【任務實施】 26
任務3 Flink項目打包部署 34
【任務描述】 34
【任務實施】 34
項目小結(jié) 37
思考與練習 37

項目3 Flink流式API應用 38
任務1 創(chuàng)建Flink程序執(zhí)行環(huán)境 39
【任務描述】 39
【知識鏈接】 39
【任務實施】 40
任務2 創(chuàng)建Flink數(shù)據(jù)源 40
【任務描述】 40
【知識鏈接】 41
【任務實施】 41
任務3 Flink轉(zhuǎn)換算子的應用 44
【任務描述】 44
【知識鏈接】 45
【任務實施】 45
任務4 數(shù)據(jù)輸出 55
【任務描述】 55
【知識鏈接】 56
【任務實施】 56
項目小結(jié) 63
項目拓展 63
思考與練習 64

項目4 Flink時間和窗口API應用 65
任務1 Flink時間語義和水位線 66
【任務描述】 66
【知識鏈接】 66
【任務實施】 68
任務2 Flink窗口操作 73
【任務描述】 73
【知識鏈接】 73
【任務實施】 75
任務3 Flink遲到數(shù)據(jù)處理 80
【任務描述】 80
【知識鏈接】 80
【任務實施】 81
項目小結(jié) 84
思考與練習 85

項目5 Flink高級應用 87
任務1 Flink多數(shù)據(jù)流處理 88
【任務描述】 88
【知識鏈接】 88
【任務實施】 88
任務2 Flink狀態(tài)編程 95
【任務描述】 95
【知識鏈接】 95
【任務實施】 98
任務3 Flink容錯機制 101
【任務描述】 101
【知識鏈接】 101
【任務實施】 103
項目小結(jié) 104
思考與練習 105

項目6 Flink Table和SQL應用 106
任務1 快速入門 107
【任務描述】 107
【知識鏈接】 107
【任務實施】 107
任務2 Flink Table和SQL基本API應用 109
【任務描述】 109
【知識鏈接】 109
【任務實施】 113
任務3 Flink SQL函數(shù)的應用 114
【任務描述】 114
【知識鏈接】 114
【任務實施】 115
任務4 Flink SQL高級應用 119
【任務描述】 119
【知識鏈接】 119
【任務實施】 120
項目小結(jié) 122
思考與練習 123

項目7 Flink CEP應用 124
任務1 Flink CEP入門 125
【任務描述】 125
【知識鏈接】 125
【任務實施】 127
任務2 Flink CEP綜合應用 131
【任務描述】 131
【知識鏈接】 131
【任務實施】 136
項目小結(jié) 143
思考與練習 143

項目8 Flink集成Kafka應用 145
任務1 Kafka集群安裝及常用操作 146
【任務描述】 146
【知識鏈接】 146
【任務實施】 148
任務2 Flink和Kafka集成 151
【任務描述】 151
【知識鏈接】 151
【任務實施】 152
任務3 綜合應用案例 155
【任務描述】 155
【任務實施】 156
項目小結(jié) 161
思考與練習 162

項目9 網(wǎng)站日志實時分析系統(tǒng) 164
任務1 網(wǎng)站日志收集 165
【任務描述】 165
【知識鏈接】 165
【任務實施】 168
任務2 Flume與Kafka集成 169
【任務描述】 169
【知識鏈接】 169
【任務實施】 170
任務3 日志分析實現(xiàn) 172
【任務描述】 172
【任務實施】 172
項目小結(jié) 180
項目拓展 181
思考與練習 181
參考文獻 183