主要内容：

• 介绍有状态计算及状态后端

主要内容：

• 结合应用场景，介绍Flink侧输出流的使用流程和原理

主要内容：

• 从SocketSource接收数据，时间语义采用EventTime，统计用户在T分钟内的总消费金额。

主要内容：

• 对Kafka的日志（Log）、日志段（LogSegment）以及索引（Index）源码进行尝试性分析。

主要内容：

• 介绍AggregateFunction
• 案例：从SocketSource接收数据，通过Flink 时间窗口以及AggregateFunction方法统计用户在24小时内的平均消费金额

主要内容：

• 介绍Time、Window、Watermark的基本概念
• 介绍几个实现案例

主要内容：分析RedisSink源码，并结合具体案例实现Flink将数据写入Redis。

主要内容：介绍Flink中的RichFunction函数。

主要内容：实现Flink写数据到MySQL，即MySQL Sink。

主要内容：实现Flink写数据到Redis，即Redis Sink。