已弃用方法 DataStream.keyBy() 的替代方法

Question

在 Flink 1.11 DataStream API 页面上，有一个使用keyBy()的WindowWordCount程序，但是，此方法已被弃用，我找不到任何关于如何在不使用keyBy()的情况下重写它的示例。任何建议将不胜感激。

我使用Intellij；它警告 keyBy() 已被弃用。这是我能找到的唯一链接。

Answer 1

采用 Integer 或 String 参数的 keyBy 形式已被弃用。您应该使用采用 KeySelector 函数的 keyBy 形式 - 例如，替换

stream.keyBy("id")

和

stream.keyBy(event -> event.id)

并替换

streamOfTuples.keyBy(0)

和

streamOfTuples(tuple -> tuple.f0)