flink 根据已完成的窗口动态调整窗口

问题描述 投票:0回答:1

我的想法是设置一个参数,根据每个窗口的数据调整它的值,并使用这个值来调整下一个窗口的大小。我该如何实现这个功能

Flink 无法动态改变窗口大小,我目前不知道

apache-flink
1个回答
0
投票

Flink 支持使用自定义的 WindowAssigner 和 Trigger 创建窗口,您可以在运行时动态决定 StreamRecord 属于哪个窗口。您可以检查 DataStream API 中与这些类相关的公共方法以了解其用法。

© www.soinside.com 2019 - 2024. All rights reserved.