本文介绍了不推荐使用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()方法的替代方法的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持！