申请试用
HOT
登录
注册
 
Bootstrapping State In Apache Flink

Bootstrapping State In Apache Flink

青色的海牛
/
发布于
/
4406
人观看
Apache Flink是一个非常受欢迎的实时流式数据处理引擎。很多流处理算法需要计算在拖尾的时间窗口内的结果,比如,计算最近7天的用户登陆数量,难点于我们程序往往都还没有运行到7天时间,一个解决办法是先让程序把历史数据撸一遍,然后再接上实时数据流,今天我们就来讨论Flink中实时流接入前的初始状态问题,这个问题的解决办法有很多,Lyft公司采用优化Flink源数据处理的方式,我们今天将重点讨论这个方案以及未来优化思路。
18 点赞
3 收藏
2下载
相关文档
确认
3秒后跳转登录页面
去登陆