保定设计网站建设网站建设深圳公司

窗口函数中的 case when

今天我们看一下窗口函数和case when 的各种花活，最近的需求各种窗口，一个需求中十几个窗口，加上各种条件边界，所以写了大量的窗口函数和case when的组合，今天我们来看一下。

我们的数据如下

%spark.pyspark
df2 = spark.createDataFrame([("2024-10-12", 50, "西南第2店"),("2024-10-13", 60, "西南第2店"),("2024-10-14",100 , "西南第2店"),("2024-10-15", 180, "西南第2店"),("2024-10-16", None, "西南第2店"),("2024-10-17", 90, "西南第2店"),("2024-10-18", 95, "西南第2店"),("2024-10-19", None, "西南第2店")]).toDF("date", "income", "shop")
df2=df2.withColumn("date",df2.date.cast('date'))
df2.cre