Альтернатива устаревшему методу DataStream.keyBy ()

Question

На странице Flink 1.11 DataStream API есть программа WindowWordCount , которая использует keyBy () , однако этот метод устарел, я не мог найдите примеры того, как его переписать без использования keyBy () . Мы будем очень благодарны за любые предложения.

Я использую Intellij; он предупреждает, что keyBy () устарел. Это единственная ссылка , которую я смог найти.

Answer 1

Формы keyBy, которые принимают параметр Integer или String, устарели. Вы должны использовать форму keyBy, которая принимает функцию KeySelector - например, замените

stream.keyBy("id")

на

stream.keyBy(event -> event.id)

и замените

streamOfTuples.keyBy(0)

на

streamOfTuples(tuple -> tuple.f0)