这个暂时应该是没有办法做到这一点。或者你可以用两个query来实现这个?
比如一个query是统计first_value;第二个是真正的session window。

gang.gou <[email protected]> 于2020年5月11日周一 下午3:07写道:

> Hi,
>
>     我想使用Flink的Session Window
> 去统计一个用户的在线访问时长,和统计当前活跃的用户数量,目前只能在window结束的时候才输出一条包含窗口开始和结束时间的记录,怎么在窗口创建的时候就先输出一条记录,结束的时候再去更新这条记录呢,谢谢!
>
>

-- 

Benchao Li
School of Electronics Engineering and Computer Science, Peking University
Tel:+86-15650713730
Email: [email protected]; [email protected]

回复