我的想法是设置一个参数,根据每个窗口的数据调整它的值,并使用这个值来调整下一个窗口的大小。我该如何实现这个功能
Flink 无法动态改变窗口大小,我目前不知道
Flink 支持使用自定义的 WindowAssigner 和 Trigger 创建窗口,您可以在运行时动态决定 StreamRecord 属于哪个窗口。您可以检查 DataStream API 中与这些类相关的公共方法以了解其用法。