Flink大数据实时计算系列- Flink的聚合函数练习
目录
- Flink Transformations关系
- Flink聚合函数案例实战
-
- 文件数据源
-
- FileCountryDictSourceFuntion
- kakfa数据源
-
- FlinkniuKafkaRecord
- FlinkniuKafkaRecordSchema
- CountryCodeConnectKeyByCountryCount
- 启动zk
- 启动kakfa
- kakfa发送数据
- min函数实现
- reduce函数实现
- process函数实现
- Flink系列博客
