是否有人有一个很好的示例，可以以某种频率汇总或汇总数据

Question

我正在寻找模仿窗口（）。delide（）操作的行为，但在任务管理器级别没有键。有点像一个.windowall（）。redion（）为流提供，但我希望从每个任务管理器中获得单独的结果。

我尝试搜索" Flink ProcessFunction示例"，但找不到任何有用的查看。

Answer 1

对于过程输入示例，我建议弗林克文档和弗林克训练材料中的示例。

另一种方法是将Windows与随机键选择器一起使用。这并不像听起来那样容易：您不能仅通过一个随机数选择，因为键的值必须确定每个流元素。因此，您可以将设置的字段添加到一个随机值中，然后将其键入该字段。与过程输入方法相比，这将迫使洗牌，但要简单。