在 SQL 中的 id 值上旋转 2 聚合值

Question

我的数据是这样的：

Employee_ID Created_Date 状态 Time_in_Seconds
1 2019-11-02 1 50
1 2019-11-02 2 10
1 2019-11-01 1 110
1 2019-11-01 2 80
2 2019-11-02 1 280
2 2019-11-02 2 95
2 2019-11-01 1 300
2 2019-11-01 2 130

我想对过去 7 天每个 driver 状态值的 Time_in_Seconds 值求和：

结果应如下所示：
Employee_ID 状态 1 状态 2
1 160 90
2 580 225

我试过合并所有查询，但这不起作用。这必须是某种支点，但我不确定如何。

Answer 1

这是数据框

df = spark.createDataFrame([('1','2019-11-02','1',50),('1','2019-11-02','2',10),('1','2019-11-01','1',110),('1','2019-11-01','2',80),('2','2019-11-02','1',280),('2','2019-11-02','2',95),('2','2019-11-01','1',3000),('2','2019-11-01','2',130)],['Employee_ID','Created_Date','status','Time_in_Seconds']) 

df.groupBy('Employee_ID').pivot('status').agg({'Time_in_Seconds':'sum'}).show()

在 SQL 中的 id 值上旋转 2 聚合值

Pivoting 2 aggregate value on id value in SQL

sql

pyspark-sql