spec = Window. \
partitionBy("material_id"). \
orderBy("date"). \
rowsBetween( Window.currentRow, 3)
rop.withColumn("lt_demand", f.sum("expected_demand").over(spec)).show()
这将得到当前行和3
下一行的预期需求之和,我的问题是,我想使用avg_lt
列的值而不是3
。
所以如果avg_lt
是8
,那么我将得到lt_demand
=下一个8
行的预期需求之和。
1条答案
按热度按时间gmxoilav1#
工作得很完美