我有一个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
暂无答案!
目前还没有任何答案,快来回答吧!