可以在flink中使用keyby(key1或key2)吗?

nzkunb0c  于 2021-06-21  发布在  Flink
关注(0)|答案(1)|浏览(436)

在flink中有没有一种方法可以使用keyby(key1或key2)(oring keys)我不是说keyby(0,1)我需要将带有key1的元素或带有key2的元素转发到同一个节点。

8wtpewkr

8wtpewkr1#

最简单的方法是编写一个keyselector函数,为所有要一起处理的事件返回相同的键。具有相同密钥的事件将由同一节点处理,并将共享密钥状态和计时器(如果相关的话)。
如果您希望事件具有不同的键,但仍由同一节点处理(我承认我很好奇为什么需要这样做),那么您需要将它们安排在同一个键组中。这变得复杂;请参阅此邮件列表线程以获取对此的一些讨论。

相关问题