代码之家  ›  专栏  ›  技术社区  ›  wittyameta

触发器和逐出器之间的状态共享

  •  2
  • wittyameta  · 技术社区  · 6 年前

    我用的是 GlobalWindow 有一个习惯 CountTrigger 计数触发器 flink ).
    我还使用逐出器从窗口中删除一些元素。是否可以在逐出元素时更新计数?例如:我可以访问 ReducingState 计数触发器 从我的 Evictor 类,以便计数始终反映窗口中的元素数?

    http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/State-sharing-across-trigger-and-evictor-td21328.html

    编辑(更多细节):我想要一个计数窗口,但增加了一个条件,即计数必须在一个时间段内。如果它们在允许的时间范围内,我就发射它们,否则我就必须滑动窗口。我打算如何实现这一点是使用一个逐出器来删除旧事件。但我不知道如何更新触发器中的计数。

    0 回复  |  直到 6 年前