SparkSQL Case When详解|极客教程

SparkSQL Case When详解

在SparkSQL中，CASE WHEN语句是一种条件表达式，用于根据不同的条件返回不同的值。类似于SQL中的CASE WHEN语句，它可以在SparkSQL的查询中进行条件判断并返回不同的结果。

语法格式

在SparkSQL中，CASE WHEN语句的基本语法格式如下所示：

SELECT
  (CASE WHEN condition1 THEN result1
        WHEN condition2 THEN result2
        ELSE result3
   END) AS new_column_name
FROM
  table_name;

在上面的语法中，CASE WHEN语句首先判断condition1，如果满足条件则返回result1，如果不满足则继续判断下一个条件condition2，依此类推。最后，如果所有条件都不满足，则返回ELSE后面的result3。

示例

假设我们有一个名为employee的表，字段包括employee_id、employee_name和salary。我们可以使用CASE WHEN语句将员工按照不同的薪水水平进行分类。

首先，创建一个employee表并插入一些数据：

CREATE TABLE employee (
  employee_id INT,
  employee_name STRING,
  salary FLOAT
);

INSERT INTO employee VALUES
(1, 'Alice', 3000),
(2, 'Bob', 5000),
(3, 'Charlie', 7000),
(4, 'David', 9000),
(5, 'Eve', 11000);

然后，使用CASE WHEN语句查询员工的薪水水平：

SELECT
  employee_id,
  employee_name,
  salary,
  (CASE WHEN salary < 5000 THEN 'Low'
        WHEN salary >= 5000 AND salary < 10000 THEN 'Medium'
        ELSE 'High'
   END) AS salary_level
FROM
  employee;

运行以上查询，将得到如下结果：

+-----------+-------------+------+-------------+
|employee_id|employee_name|salary|salary_level |
+-----------+-------------+------+-------------+
|1          |Alice        |3000  |Low          |
|2          |Bob          |5000  |Medium       |
|3          |Charlie      |7000  |Medium       |
|4          |David        |9000  |Medium       |
|5          |Eve          |11000 |High         |
+-----------+-------------+------+-------------+

从以上结果可看出，根据员工的薪水水平分类，我们使用了CASE WHEN语句进行条件判断，并为每个员工分配了对应的薪水水平。

总结

CASE WHEN语句是在SparkSQL中进行条件判断并返回不同值的一种重要方式。通过灵活运用CASE WHEN语句，我们可以根据不同的条件对数据进行分类和处理，使数据分析和报告更加灵活和实用。在实际应用中，我们可以根据具体的业务需求，结合CASE WHEN语句灵活处理数据，为数据分析和决策提供更多的可能性和支持。