Flink大数据实时计算系列-Flink的Keyed state的使用
目录
Flink 的Keyed state的使用
CountryCodeConnectKeyByKeyedState
- Flink 的Keyed state的使用
-
- CountryCodeConnectKeyByKeyedState
- FileCountryDictSourceFuntion
- 测试运行
-
- 启动zk
- 启动kafka
- kafka生产数据
- 设置Keyed state过期时间
- 设置ReturnExpiredIfNotCleanedUp
- 设置ListCheckpointed状态
- Flink参考链接
- Flink系列博客