Flink在运行时更改流窗口大小
我有一个流是消费的Flink Kafka消费者将加入另一个流为定义的窗口大小，如Time.milliseconds（10000）。
如何在运行时将窗口大小更改为Time.milliseconds（20000）？
Stream1.join(Stream2)
.where(new SingleValueSensorKeySelector())
.equalTo(new GPSKeySelector())
.window(TumblingEventTimeWindows.of(Time.milliseconds(10000)))
.apply(joinStreamFunc).addSink(kafkaProducer);
共有1个答案
运行时不能更改窗口大小。
你可以做一些事情，尽管两者都不是很有吸引力。您可以在某种 ProcessFunction 之上实现自己的窗口。或者，您可以复制所涉及的流，并行进行两种窗口，然后动态控制哪个窗口的结果进入接收器。
实现您自己的窗口将是一项不平凡的工作，在计算这两组窗口上花费资源听起来很昂贵。
-
的结果是一个元素流-因此，我希望从这个流中获得一个“具有最高计数的key”的更新流。 然后我通过一个常量(-因为这是一个全局操作）进行键控，并使用-这几乎可以实现：我得到一个最高计数流，但当前的最高计数是针对每个元素发出的。 我想我要找的是某种带有前一个值的过滤器，它只会在新值与前一个值不同时才会发出元素。 目前在Flink有可能吗？
-
问题内容： 我正在寻找一种观察窗口内部宽度大小变化的方法。我尝试了以下操作，但没有成功： 有什么建议？ 问题答案： 我们可以使用jQuery来做到这一点： 请注意，将事件处理程序绑定在可以 重新创建的 范围内（例如ng- repeat范围，指令范围等）时，在销毁该范围时应取消绑定事件处理程序。如果不执行此操作，则每次重新创建作用域（重新运行控制器）时，都会再添加1个处理程序，从而导致意外行为和泄漏
-
我有flink stream，我在某个时间窗口上计算一些事情，比如说30秒。 这里发生的事情是，它给我的结果，我以前的窗口聚合以及。 假设前30秒我得到结果10。 接下来的三十秒我想要新的结果，而不是我得到最后一个窗口的结果新的等等。 因此，我的问题是如何为每个窗口获得新的结果。
-
输入： 结果：
-
问题内容： 我有一个奇怪的问题。我正在为窗口使用null布局（= JFrame，并且在窗口上），如果我使用setResizable（false），则窗口大小会变大（左右分别是10像素左右）。我不知道为什么。 两个println返回相同的大小，这很奇怪，也… 有人有主意吗？为什么要调整窗口大小？ 更新：这里是一样的东西（如果有重叠的窗口，则在有和没有setResizable的情况下进行编译，然后您将