#Flink

主要内容:

  • 介绍项目:基于Flink的UAC实时流量异常监控告警模型

主要内容:

  • 介绍实时计算PVUV项目

主要内容:

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

主要内容:

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

主要内容:

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

主要内容:

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

主要内容:

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

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

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