spark udaf on range-based window-如何在正在计算聚合的udaf initialize/update调用中获取原始行的列值。spark中的窗框尺寸为固定长度。但在我的例子中，我希望通过使用固定的窗口大小来动态/逻辑地调整窗口大小，但是跳过某些行的更新调用，这些行与基于原始行的列值的条件不匹配。