Flink API
Flink API,思维导图
Flink API:
Source:
Collection
File
Kafka
自定义 implements SourceFunction<T>
Transform:
Map
FlatMap
Filter
KeyBy
滚动聚合算子
Reduce
Split 和 Select
Connect 和 CoMap
Union
UDF extends RichMapFunction
Sink:
Kafka
Redis
Es
JDBC
Window:
时间窗口
滚动时间窗口
滑动时间窗口
会话窗口
计数窗口
滚动计数窗口
滑动计数窗口
窗口函数
增量聚合函数
全窗口函数
时间
watermark
状态:
算子状态
键控状态
状态后端