背景:
目前公司业务需要统计超过7天以上的特征统计,但是kafka只存7天的数据,如果只想通过flink sql去计算30天的用户特征要求当天生效,这是完不成的,但是看到下面的分享,感觉未来的方向有了。
一、2021 Apache Flink Meetup - Hosted by Netflix 的youtobe视频分享
目前这是Netflix的分享,目前还未将backfilling 的功能贡献回 iceberg 社区
https://www.youtube.com/watch?v=rtz3p_iijP8&feature=youtu.be(第45分钟开始)
二、简单的截图分享(重点看第四点)
1、标题
![](https://img.haomeiwen.com/i18207108/24d5aaf039bf38ac.png)
2、提高流利用数据的存活时间
[图片上传失败...(image-6db56a-1612260384535)]
3、对比kafka和第三方存储的价格优势
![](https://img.haomeiwen.com/i18207108/c91b403c8521ebe6.png)
4、Backfilling在Iceberg的使用,这个是重点,能够替代kafka存更多之前的数据,同时又能
![](https://img.haomeiwen.com/i18207108/9b80dc97b6a3bbb5.png)
5、Iceberg的流表结构
![](https://img.haomeiwen.com/i18207108/8501da99b78c8a89.png)
网友评论