Pypark中的循环

dw1jzc5e  于 2021-05-27  发布在  Spark
关注(0)|答案(0)|浏览(240)

我有一个Dataframe。其中,我们有订单\日期,我需要扫描日期列中的年份(使用拆分),如果匹配,则将其与结束年份进行比较,然后将其分配给@i,然后增加结束年份我添加了一个df以显示预期的putput
测向

df:

    df[order_date] = 1/2/2020
    df[st_yr] = 2020
    df[ed_yr] = df[st_yr] + 1

    do i = 1 to 5
    if df.withColumn("order_date", split(col("order_date"), "/").getItem(2)) = df[ed_yr]
        df[st_yr] = i;
        df[ed_yr] = df[ed_yr] + 1
    end

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题