Flink 是否有"分发者"命令(类似于 spark)



我想按键打乱数据,并将数据写入sink。

我不使用分组,因为它对我来说没有必要做任何聚合。

所以我想知道flink-sql在spark中是否有类似"distributeby"这样的关键字。

这对我来说就像是一个黑客,但你可以用MATCH_RECOGNIZE和PARTITION BY来实现这一点。希望有一种我没有看到的更干净的方法。

最新更新