课程章节 返回课程首页

• Ch01 Flink架构与集群搭建
  • Flink简介
  • Flink单机安装及作业执行方法
  • Flink集群安装和配置
• Ch02 Flink开发准备
  • 开发并运行第一个Flink应用程序
  • Flink相关的概念
• Ch03 开发Flink实时处理程序
  • Flink流处理程序编程模型
  • 创建和使用Flink自定义流数据源
  • Flink常用算子
  • Flink数据分区和自定义分区器
  • Flink数据接收器
  • Flink中的时间和水印
  • 理解Flink中的窗口概念
  • 理解和应用Flink窗口
  • Flink窗口函数ReduceFunction
  • Flink窗口函数AggreageFunction
  • Flink窗口函数ProcessWindowFunction
  • Flink中处理迟到的流数据
  • Flink流连接
  • Flink低级操作函数ProcessFunction
  • Flink流程序的状态运算
  • Flink状态运算示例_流数据去重
  • Flink状态运算示例_窗口计数
  • Flink状态运算示例_服务器监控告警程序 VIP
  • Flink侧输出流应用
  • Flink集成Kafka_读写Kafka
  • Flink分层API介绍
  • Flink批处理程序开发
  • 使用Flink表API进行批处理和流处理
• Ch04 Flink流处理案例
  • Flink案例_处理IOT事件流 VIP
  • Flink案例_信用卡欺诈实时检测 VIP
  • Flink批处理示例_分析豆瓣电影数据集
  • Flink综合案例_实时端到端流分析案例 VIP
• ch05 状态和容错