使用scala编写flink消费kafka实时计算pv,uv

时间 2021-01-20

原文原文链接

实时统计pv、uv是再常见不过的大数据统计需求了，前面出过一篇SparkStreaming实时统计pv,uv的案例，这里用flink实时计算pv,uv。我们需要统计不同数据类型每天的pv，uv情况,并且有如下要求. 每秒钟要输出最新的统计结果程序永远跑着不会停,所以要定期清理内存里的过时数据收到的消息里的时间字段并不是按照顺序严格递增的,所以要有一定的容错机制访问uv并不一定每秒钟都会变化

>>阅读原文<<

1. kafka链接flink流计算,实现flink消费kafka的数据
2. Flink 实战：统计网站PV，UV
3. Flink统计当日的UV、PV
4. 统计PV、UV
5. 统计pv、uv
6. 17-Flink消费Kafka写入Mysql
7. Flink+kafka实现Wordcount实时计算
8. Flink消费Kafka数据，写入HDFS - 使用 StreamingFileSink
9. go pv uv 统计
10. flink消费kafka的数据
更多相关文章...
• Scala 运算符 - Scala教程
• Kotlin 使用命令行编译 - Kotlin 教程
• 使用Rxjava计算圆周率
• Java Agent入门实战（一）-Instrumentation介绍与使用