你所需要的大部分已经存在了；缺少的是一个窗口赋值器，它知道如何构造具有适当（和可变）持续时间的窗口。假设您希望在事件时间中操作，那么可以基于tumblingeventtimewindows，修改assignwindows方法以执行正确的操作。