使用flink sql写一个pv,uv统计
时间: 2023-03-11 15:08:22 浏览: 322
flink-learning:flink学习博客。 http://www.54tianzhisheng.cn含Flink入门,概念,原理,实战,性能调优,子程序解析等内容。涉及Flink连接器,指标,库,DataStream API,表API和SQL等内容的学习案例,还有Flink落地应用的大型项目案例(PVUV,日志存储,百亿数据实时去重,监控细分)分享。欢迎大家支持我的专栏《大数据实时计算引擎Flink实战与性能优化》
我可以给你一个示例代码:// 创建一个TableEnvironment
TableEnvironment tableEnv = TableEnvironment.create(env);// 注册一个表
tableEnv.registerTableSource("myTable", new MyTableSource());// 创建一个Table
Table myTable = tableEnv.scan("myTable");// 计算PV
Table pv = myTable
.groupBy("pageID")
.select("pageID, count(*) as pvCount");// 计算UV
Table uv = myTable
.groupBy("userID")
.select("userID, count(*) as uvCount");// 打印结果
Table result = pv.join(uv).select("pageID, pvCount, uvCount");
result.printSchema();
阅读全文