apache-flink - windowByTime 和 triggerByCount 的 Flink 组合

Question

source.keyBy(0)
    .window(TumblingEventTimeWindows.of(Time.seconds(5)))
    .trigger(PurgingTrigger.of(CountTrigger.of[TimeWindow](2)))
    .process(new TestFun())

解释：

假设我有 3 个事件[E1，E2，E3]，应该按计数触发，也应该按时间触发。我正在使用 countTrigger 仅触发 2 个事件（E1 和 E2），但未触发剩余的 E3 事件。

预期：E3 事件应在 5 秒后触发，但实际上它仅触发 E1 和 E2 事件

Answer 1

CountTrigger您提供的是替换通常EventTimeTrigger用 a 使用的TumblingEventTimeWindow，而不是以某种方式扩展或扩充它。要获得您想要的行为，您必须实现一个自定义触发器，该触发器可以基于计数和超时触发一个窗口。

谷歌搜索会找到一些例子和讨论。