如何从上一行中减去值并更新PySpark中的数据框?

如何从上一行中减去值并更新PySpark中的数据框?

我有一张表,我想减去上一行的值并更新新行。

在这种情况下

  

第1行-ExpectedFCF应该是13.02 ExpectedFCF

     

第2行-ExpectedFCF应该为13.02-(-6.34)= 19.36 ExpectedFCF(上一行)-TotalPaid(上一行)

     

第3行-预期的FCF应该为19.36-(-345.52)= 364.88

     

第4行-预期的FCF应为364.88-(-161.34)= 526.22

我正在使用这个:

df = df.withColumn('ExpectedFCF',(F.when((F.col('Calculation') > 1),(F.lag(F.col('ExpectedFCF')).over(window) - F.col('TotalPaid'))).otherwise(F.col('ExpectedFCF_x'))))

但是我没有得到正确的解决方案。这是另一个示例,其中ColC是我要达到的目标。

如何从上一行中减去值并更新PySpark中的数据框?

lzdfkwdz 回答:如何从上一行中减去值并更新PySpark中的数据框?

暂时没有好的解决方案,如果你有好的解决方案,请发邮件至:iooj@foxmail.com
本文链接:https://www.f2er.com/3142013.html

大家都在问