我想模拟window（）.reduce（）操作的行为，但在任务管理器级别没有键。有点像.windowall（）.reduce（）对流所做的，但我希望从每个任务管理器中获得单独的结果。我试图搜索“flink processfunction示例”，但没有找到任何有用的东西。
x6yk4ghg1#
对于processfunction示例，我建议使用flink文档和flink培训材料中的示例。另一种方法是使用带有随机键选择器的窗口。这并不像听起来那么简单：您不能仅仅通过随机数进行选择，因为对于每个流元素，键的值必须是确定的。所以可以添加一个设置为随机值的字段，然后按该字段键控。与processfunction方法相比，这将强制执行洗牌，但更简单。
1条答案
按热度按时间x6yk4ghg1#
对于processfunction示例，我建议使用flink文档和flink培训材料中的示例。
另一种方法是使用带有随机键选择器的窗口。这并不像听起来那么简单：您不能仅仅通过随机数进行选择，因为对于每个流元素，键的值必须是确定的。所以可以添加一个设置为随机值的字段，然后按该字段键控。与processfunction方法相比，这将强制执行洗牌，但更简单。