我最近在 BigQuery 中对日期进行分组时遇到了类似的查询DATE_ADD 或 DATE_DIFF 错误，但我想知道如何在 PySpark 中执行此操作，因为我是新手
day bitcoin_total dash_total
2009-01-03 1 0
2009-01-09 14 0
2009-01-10 61 0
理想的结果是一周开始的日期（可能是星期一或星期日，以哪个为准）
day bitcoin_total dash_total
2008-12-28 1 0
2009-01-04 75 0
下面的代码按数字返回周数，总数似乎不对。我似乎无法复制 .agg(sum()) 返回的总数，我什至无法添加第二个总数 (dash_total)。我试过了.col("dash_total")有没有办法将几天分成几个星期？
from pyspark.sql.functions import weekofyear, sum
(df
.groupBy(weekofyear("day").alias("date_by_week"))
.agg(sum("bitcoin_total"))
.orderBy("date_by_week")
.show())
我在 Databricks 上运行 Spark。