项目1 Flink开发环境搭建 1
任务 搭建Flink开发环境 2
【任务描述】 2
【知识链接】 2
【任务实施】 8
项目小结 18
思考与练习 18

项目2 Flink集群搭建 20
任务1 Flink集群搭建 21
【任务描述】 21
【知识链接】 21
【任务实施】 23
任务2 基于Flink实现单词统计 26
【任务描述】 26
【任务实施】 26
任务3 Flink项目打包部署 34
【任务描述】 34
【任务实施】 34
项目小结 37
思考与练习 37

项目3 Flink流式API应用 38
任务1 创建Flink程序执行环境 39
【任务描述】 39
【知识链接】 39
【任务实施】 40
任务2 创建Flink数据源 40
【任务描述】 40
【知识链接】 41
【任务实施】 41
任务3 Flink转换算子的应用 44
【任务描述】 44
【知识链接】 45
【任务实施】 45
任务4 数据输出 55
【任务描述】 55
【知识链接】 56
【任务实施】 56
项目小结 63
项目拓展 63
思考与练习 64

项目4 Flink时间和窗口API应用 65
任务1 Flink时间语义和水位线 66
【任务描述】 66
【知识链接】 66
【任务实施】 68
任务2 Flink窗口操作 73
【任务描述】 73
【知识链接】 73
【任务实施】 75
任务3 Flink迟到数据处理 80
【任务描述】 80
【知识链接】 80
【任务实施】 81
项目小结 84
思考与练习 85

项目5 Flink高级应用 87
任务1 Flink多数据流处理 88
【任务描述】 88
【知识链接】 88
【任务实施】 88
任务2 Flink状态编程 95
【任务描述】 95
【知识链接】 95
【任务实施】 98
任务3 Flink容错机制 101
【任务描述】 101
【知识链接】 101
【任务实施】 103
项目小结 104
思考与练习 105

项目6 Flink Table和SQL应用 106
任务1 快速入门 107
【任务描述】 107
【知识链接】 107
【任务实施】 107
任务2 Flink Table和SQL基本API应用 109
【任务描述】 109
【知识链接】 109
【任务实施】 113
任务3 Flink SQL函数的应用 114
【任务描述】 114
【知识链接】 114
【任务实施】 115
任务4 Flink SQL高级应用 119
【任务描述】 119
【知识链接】 119
【任务实施】 120
项目小结 122
思考与练习 123

项目7 Flink CEP应用 124
任务1 Flink CEP入门 125
【任务描述】 125
【知识链接】 125
【任务实施】 127
任务2 Flink CEP综合应用 131
【任务描述】 131
【知识链接】 131
【任务实施】 136
项目小结 143
思考与练习 143

项目8 Flink集成Kafka应用 145
任务1 Kafka集群安装及常用操作 146
【任务描述】 146
【知识链接】 146
【任务实施】 148
任务2 Flink和Kafka集成 151
【任务描述】 151
【知识链接】 151
【任务实施】 152
任务3 综合应用案例 155
【任务描述】 155
【任务实施】 156
项目小结 161
思考与练习 162

项目9 网站日志实时分析系统 164
任务1 网站日志收集 165
【任务描述】 165
【知识链接】 165
【任务实施】 168
任务2 Flume与Kafka集成 169
【任务描述】 169
【知识链接】 169
【任务实施】 170
任务3 日志分析实现 172
【任务描述】 172
【任务实施】 172
项目小结 180
项目拓展 181
思考与练习 181
参考文献 183