是否有可能知道哪些元素得到了从一个窗口被驱逐?

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

在窗口处理功能,才有可能知道哪些元素得到了驱逐?

使用案例:

  • 窗口有很多事件
  • 使用逐出器
  • 减少函数的计算成本高昂

现在,我想要做的是这样的:

  1. 窗口接收事件,把它添加到状态
  2. 驱逐一些元素
  3. “+1”的合计值,根据新的事件
  4. “-1”,以在2驱逐每个事件的聚合值

由于#驱逐元素<<窗口#元素,这将是更有效的。

这是否有意义?可能吗?

apache-flink flink-streaming
1个回答
1
投票

仅供参考,有一个计划,以支持添加到弗林克的窗口API用于优化具有高度重叠的窗口的情况。这里是umbrella ticket in Jira。希望这将涉及您的使用案例。

至于什么现在的问题是可能的,我不相信这是可能共享一个逐出器和ProcessWindowFunction之间的信息。

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