Pyspark在最后N个数据点上的结构化流媒体窗口(移动平均)我使用Pyspark Structured Streaming 2.4.4阅读了卡夫卡主题中的几个数据帧。我想在数据帧中添加一些新的列,这些列主要基于过去N个数据点的窗口计算(例如:过去20个数据点的 ...2024-10-01 已阅读: n次