不推荐使用DataStream.keyBy()方法的替代方法 [英] Alternative to deprecated method DataStream.keyBy()

问题描述

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

我使用IntelliJ；它警告keyBy()已弃用。这是我能找到的唯一link。

推荐答案

接受整数或字符串参数的keyBy形式已弃用。您应该使用接受KeySelector函数的keyBy形式--例如，REPLACE

stream.keyBy("id")

与

stream.keyBy(event -> event.id)

并替换

streamOfTuples.keyBy(0)

与

streamOfTuples(tuple -> tuple.f0)

这篇关于不推荐使用DataStream.keyBy()方法的替代方法的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持IT屋！