不推荐使用的方法DataStream.keyBy()的替代方法

Question

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

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

Answer 1

采用Integer或String参数的keyBy形式已被弃用。您应该使用keyBy的形式，它具有KeySelector功能——例如，替换

stream.keyBy("id")

带有

stream.keyBy(event -> event.id)

并替换

streamOfTuples.keyBy(0)

带有

streamOfTuples(tuple -> tuple.f0)