@↓分别使用DataFrame API和SQL语句,完成指定的数据统计分析↓ 3.公司要发妇女节礼物,请列出发放对象的员工号、员工姓名、性别;
时间: 2024-03-20 07:42:12 浏览: 55
pyspark.sql.DataFrame与pandas.DataFrame之间的相互转换实例
5星 · 资源好评率100%
使用DataFrame API:
```python
from pyspark.sql.functions import col
# 假设员工信息存储在employee_df数据框中,包括员工号、员工姓名、性别等信息
# 假设员工性别用1表示男性,2表示女性,需要进行转换
employee_df = employee_df.withColumn("gender", when(col("sex") == 1, "Male").otherwise("Female"))
# 发放妇女节礼物的对象是女性员工,因此筛选出女性员工
female_employee_df = employee_df.filter(col("gender") == "Female")
# 列出发放对象的员工号、员工姓名、性别
female_employee_df.select("employee_id", "employee_name", "gender").show()
```
使用SQL:
```sql
-- 假设员工信息存储在employee表中,包括员工号、员工姓名、性别等信息
-- 假设员工性别用1表示男性,2表示女性,需要进行转换
SELECT employee_id, employee_name, CASE sex WHEN 1 THEN 'Male' ELSE 'Female' END AS gender
FROM employee
WHERE sex = 2;
```
阅读全文