在flink中有没有一种方法可以使用keyby(key1或key2)(oring keys)我不是说keyby(0,1)我需要将带有key1的元素或带有key2的元素转发到同一个节点。
8wtpewkr1#
最简单的方法是编写一个keyselector函数,为所有要一起处理的事件返回相同的键。具有相同密钥的事件将由同一节点处理,并将共享密钥状态和计时器(如果相关的话)。如果您希望事件具有不同的键,但仍由同一节点处理(我承认我很好奇为什么需要这样做),那么您需要将它们安排在同一个键组中。这变得复杂;请参阅此邮件列表线程以获取对此的一些讨论。
1条答案
按热度按时间8wtpewkr1#
最简单的方法是编写一个keyselector函数,为所有要一起处理的事件返回相同的键。具有相同密钥的事件将由同一节点处理,并将共享密钥状态和计时器(如果相关的话)。
如果您希望事件具有不同的键,但仍由同一节点处理(我承认我很好奇为什么需要这样做),那么您需要将它们安排在同一个键组中。这变得复杂;请参阅此邮件列表线程以获取对此的一些讨论。