一、认识flink
1.1 flink是什么
1.2 flink用来做什么
1.3 flink基本框架
二、flink基本语言
2.1 flink sql
2.2 table api
2.3 datastream dataset
2.4 stream process api(各种算子)
2.5 flink支持数据类型
2.6 写flink代码分几步走
三、重点介绍flink datastream
3.1 数据源 resources
3.2 算子-单(single)
map(1转1)
flatmap(1转多)
filter
keyby
reduce
aggregations
3.3 算子-多(multi)
union
connect comap coflatmap
split
select
iterate
3.4 分区操作
随机 random partitioning
全局 roundrobin partitioning
上下游算子 rescaling partitioning
广播 broadcasting
自定义
3.5 输出 datasinks



