有多少窗口类型目前或将来会支持结构化流媒体



当前,当我阅读flink的文档时,我发现flink中有很多窗口语义支持,比如实现的翻滚窗口、滑动窗口、会话窗口和自定义窗口

有人能告诉我,目前或未来,在spark结构化流媒体或spark流媒体中内置或定义了多少窗口语义吗?有可能在spark结构化流中的会话窗口上实现应用程序吗?

感谢您的任何想法或建议~

这是与jira-10816相关的spark会话窗口,在未来的发布版本中将支持spark中的会话窗口。

最新更新