Spark分组函数嵌套与子查询应用

Spark分组函数嵌套与子查询应用示例

本节将演示如何在Spark SQL中进行分组函数嵌套和子查询操作。

1. 嵌套分组函数

• 查询各部门平均工资的最大值： sql SELECT MAX(AVG(sal)) FROM emp GROUP BY deptno;

2. 分组统计与条件筛选

• 计算各部门工资高于500的员工的平均工资：

  sql

  SELECT deptno, AVG(sal) AS avg_salary

  FROM emp

  WHERE sal > 500

  GROUP BY deptno;

• 查询平均工资大于500的部门信息：

  sql

  SELECT deptno, AVG(sal) AS avg_salary

  FROM emp

  GROUP BY deptno

  HAVING avg_salary > 500;

3. 子查询应用

• 查询部门30中获得最高奖金的员工的奖金金额：

  sql

  SELECT MAX(comm) FROM emp WHERE deptno = 30;

• 查询部门30中获得最高奖金的员工姓名：

  sql

  SELECT ename

  FROM emp

  WHERE comm = (SELECT MAX(comm) FROM emp WHERE deptno = 30);

4. 分组统计与聚合函数结合

• 查询每个职位的员工数量和最低工资： sql SELECT job, COUNT(*) AS employee_count, MIN(sal) AS min_salary FROM emp GROUP BY job;