我正在使用flinkkafkaconsumer（…）使用一个有50多个分区的kafka主题。我想为这些分区创建窗口。但是，我不期望任何洗牌，所以我不能使用datastream.keyby（…）。如果我调用datastream.windowall（…），并行度将是1，这也不是我所期望的。那么，有没有什么方法可以保持并行性的高值，同时不进行数据洗牌呢？谢谢
yftpprvb1#
如果不使用keyby，您的选项将变得相当有限。您可以使用（非键控）实现某种类型的并行窗口 ProcessFunction ，但您不能访问计时器或键控状态，只能访问操作员状态。
ProcessFunction
1条答案
按热度按时间yftpprvb1#
如果不使用keyby，您的选项将变得相当有限。您可以使用（非键控）实现某种类型的并行窗口
ProcessFunction，但您不能访问计时器或键控状态，只能访问操作员状态。