Pypark中的循环

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

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

  1. df:
  2. df[order_date] = 1/2/2020
  3. df[st_yr] = 2020
  4. df[ed_yr] = df[st_yr] + 1
  5. do i = 1 to 5
  6. if df.withColumn("order_date", split(col("order_date"), "/").getItem(2)) = df[ed_yr]
  7. df[st_yr] = i;
  8. df[ed_yr] = df[ed_yr] + 1
  9. end

暂无答案!

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

相关问题