数据大致格式如下,需求:求当前公司等于P的角色(JSON中的R字段) company_namecase_role江苏XXXX集团有限公司[{"P":"张三","R":"申请执...
数据大致格式如下,需求:求当前公司等于P的角色(JSON中的R字段) company_namecase_role江苏XXXX集团有限公司[{"P":"张三","R":"申请执...
一、练习网址 无需安装Docker直接通过网址进行Docker的学习,访问以下网址直接点击以docker登录https://labs.play-with-docker.com...
原始数据,放置在IDEA的data文件夹下的log1.txt 通过SparkSQL读取文件,注册成一张零食表 log1TODO 统计每日日活用户(只要当天有一条访问记录的用户...
对于Spark来说有3中Join的实现,每种Join对应着不同的应用场景: BroadcastHashJoin : 适合一张较小的表和一张大表进行join Shuffle...
检查hive/hbase/spark/kafka依赖是报错,找不到对应的lib Mac不支持printf '%p,需要改成awk所以find-hive-dependency....
首先写一个样例类Demo 运行后,使用反编译打开,会发现一个样例类 Dollar会生成Dollar$.class和Dollar.class文件 首先来看Dollar$.cla...
有score表,字段分别为年份,课程,学生,成绩 需求1:求每年每门课程排名第一的学生成绩 方式1:常规方式group by 注:结果含义,2020年英语最高成绩是为B的学生...
现有数据如下 需求:求连续出现三次的数字number 方法一:根据肉眼可以看出连续出现三次的number是1和3,那么用SQL如何实现呢?第一种SQL实现如下 得到结果: 这...
People表明细如下: 需求:按照性别分组,求分组后年龄最大的两个年龄的人员信息 学生技能表如下 需求:按照技能分组,求分组后年龄最大的两个学生信息 先将skills炸开 ...
explode称之为Hive爆炸函数,意思就是将一行数据炸开。Usage:explode(array/map) explode函数传递的参数必须是一个array或者是ma...
@codeBugCoder 可以,只要能读到
scalikejdbc框架操作MySQL一、构建一个Maven的Scala项目,然后在项目中添加以下依赖 然后在src下一级目录创建resource文件夹,并指定为Resources文件 在resource文件下创...
先查看数据库连接池实现MySQL连接池 MySQL表student的实体采用case class定义 实现RichSourceFunction来自定义MySQLSource ...
main/resources/druid.properties 代码:
IDEA整体结构 pom WC.txt log4j.properties不想看无关日志就设置只打印error日志 BatchJob
1、快速定位ERROR信息方式1 cat hadoop-hadoop-namenode-JD.log | grep -A 5 ERROE cat hadoop-hadoop-...
一、现象说明pom有以下依赖 IDEA常用打包方式,只会包含我们自己编写的主类,不会包含依赖jar包。点击package打包后 使用WinRAR打开dw-1.0.jar,发现...