进来闲来无事，总结一下数仓面试吧！希望对小白有点用！有50W个某东网站店铺，每个顾客访客访问任何一个店铺的任何一个商品时都会产生一条访问日志，访问日志存储的表名为Visit，访客的用户id为user_id，被访问的店铺名称为shop，请统计：1）每个店铺的UV（访客数）2）每个店铺访问次数top3的访客信息。输出店铺名称、访客id、访问次数1首先，先明白什么是uv？即（独立的访客）...

redis中的数据：需要实现SourceFunction接口，指定泛型<>,也就是获取redis里的数据，处理完后的数据输入的数据类型 这里我们需要的是（我们需要返回kv对的，就要考虑HashMap）Java代码：package ryx.source;import org.apache.flink.streaming.api.functions.source.Source...

java代码实现案例自己定义一个单并行度的source，需要自己实现一个SourceFunction接口！import org.apache.flink.streaming.api.functions.source.SourceFunction;/*** 自己定义一个单并行度的source* 需要自己实现一个SourceFunction接口**/publi...

union的巧妙用法，使用union也可以横向合并sql查询结果我们都知道union是纵向连接查询结果，join是横向，但是用union all连接大家试过吗？恢复菜鸟代码如下：select ep.productid,productname,count(st.tduserid),count(distinct sl.tduserid),count(distinct sn.tduserid),a...

磁盘IOiostat命令命令详解Linux系统中的iostat是I/O statistics（输入/输出统计）的缩写，iostat工具将对系统的磁盘操作活动进行监视。它的特点是汇报磁盘活动统计情况，同时也会汇报出CPU使用情况。同vmstat一样，iostat也有一个弱点，就是它不能对某个进程进行深入分析，仅对系统的整体情况进行分析。命令参数-c 显示CPU使用情况-d 显...