· 数据清洗(同步、异步IO)
· 基于窗口的新老用户指标统计
   (操作系统、省份、窗口维度)
· 热门分组TopN指标统计
· Flink整合CH完成明细数据并进行
   多维度统计分析
· 基于CEP完成风控告警
· 基于Canal的实时数据同步
· 基于Flink的双流JOIN方案

· 基于Flink+CH通用实时解决方案
· Flink保证Exactly-once语义
· 自定义Source、Transformation、
   Sink算子
· 彻底理解基于Flink的自定义状态
   管理
· 窗口&水印&窗口函数综合使用
· 引入CH，解决实时多维度分析的
   痛点
· 基于Flink的CEP编程· 实时数仓
   架构及选型
· 实时数仓的分层模型

· 布隆过滤器整合State编程解决
   state过大的问题
· 使用Flink异步IO提升数据处理的
   性能
· Flink并行度调整