使用 Apache Flink，我如何插入流以便在空 windows 时发出值
With Apache Flink, how can i intersperce a stream so values are emitted on empty windows
我正在汇总一个多小时的数据 windows。当一小时内没有事件到达时，不调用聚合函数，从不计算零聚合。因此，我的输出遗漏了空的 windows 条目。有没有一种简单的方法可以确保空的 windows 也被计算出来，以便我能够发出零聚合？
Events -> A - - B - C - - - - - - E - F -
Desired output -> [ 2][ 1][ 0][ 2]
Observed pr now -> [ 2][ 1] [ 2]
目前Flink不支持空windows。在内部，必须至少有一个元素属于 window 才能创建它。
我正在汇总一个多小时的数据 windows。当一小时内没有事件到达时，不调用聚合函数，从不计算零聚合。因此，我的输出遗漏了空的 windows 条目。有没有一种简单的方法可以确保空的 windows 也被计算出来，以便我能够发出零聚合？
Events -> A - - B - C - - - - - - E - F -
Desired output -> [ 2][ 1][ 0][ 2]
Observed pr now -> [ 2][ 1] [ 2]
目前Flink不支持空windows。在内部，必须至少有一个元素属于 window 才能创建它。