flink中如何使用set实时计算当天网站uv


flink中如何使用set实时计算当天网站uv,针 香港云主机对这个问题,这篇文章详细介绍了相对应的分析和解答,希望可以帮助更多想解决这个问题的小伙伴找到更简单易行的方法。背景对于web网站,我们一般会有这样的需求,实时的计算出来当天网站的uv,尽可能快的展示出来。今天我们就讲一下基于java的set集合做一下实时uv的统计。简易需求:首先我们模拟生成一下最简单的数据,生成一个flink的二元组Tuple2.分别表示分类和用户id接下来我们定义一个周期是一天的滑动窗口,因为我们要每秒钟输出窗口的数据,所以我们紧接着窗口定义了一个1秒的触发器。接下来我们自定义一个聚合算子来实现该功能。对于聚合算子的理解可以参考这个文章:https://mp.weixin.qq.com/s/ZCWexNGzhSchRpxipa1x-g我们这里将结果输出到控制台,实际的生产中我们可以将数据写入redis或者hbase等。关于flink中如何使用set实时计算当天网站uv问题的解答就分享到这里了,希望以上内容可以对大家有一定的帮助,如果你还有很多疑惑没有解开,可以关注开发云行业资讯频道了解更多相关知识。

相关推荐: 以个性化为需求如何选择ITSM系统?

为了保证最终落地的 ITSM有用、 能用、好用,除了所选ITSM符合标准方法论,还需要满足个性化需求。那么个性化需求的风险有哪些?如何根据个性化选择ITSM系统呢?这都是值得深究的问题。 一、个性化需求 的 风险? 对于与其他系统接口、保密安全要求、行业监管要…

免责声明:本站发布的图片视频文字,以转载和分享为主,文章观点不代表本站立场,本站不承担相关法律责任;如果涉及侵权请联系邮箱:360163164@qq.com举报,并提供相关证据,经查实将立刻删除涉嫌侵权内容。

(0)
打赏 微信扫一扫 微信扫一扫
上一篇 08/14 12:57
下一篇 08/14 12:58

相关推荐