保定設(shè)計網(wǎng)站建設(shè)網(wǎng)站設(shè)計公司排名
窗口函數(shù)中的 case when
今天我們看一下窗口函數(shù)和case when 的各種花活,最近的需求各種窗口,一個需求中十幾個窗口,加上各種條件邊界,所以寫了大量的窗口函數(shù)和case when的組合,今天我們來看一下。
我們的數(shù)據(jù)如下
%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