你好， 请问想用reduce 里面需要存储状态，可以用 aggregate() 吗？ 看了一下代码，窗口的话，是把数据存储在窗口里面的状态。reduce 会生成 reduce 对应的状态存储放入窗口。任务窗口函数是不是自定义的，里面的状态也不能自定义。有聚合的情况下，只是把聚合函数作用在了窗口的状态上，里面的状态是要保存聚合结果的状态。 可以任务 窗口加聚合是一个算子。
likai [email protected] > 在 2021年1月29日，下午12:49，赵一旦 <[email protected]> 写道： > > windowFunc
