Apache Flink: карта против плоской карты

Question

В режиме flink, flatMap также может излучать одну запись.Кажется, flatMap может заменить карту.Может кто-нибудь сказать мне разницу в этой ситуации?Спасибо.

Answer 1

Использование map() также упрощает использование лямбд.Например, чтобы преобразовать Tuple2<Integer, String> в String, вы можете сделать:

.map(value -> value.f1)

Answer 2

Если вы думаете, что карта лишняя, вы правы.Flatmap может делать все, что может сделать карта, и даже больше.

Тем не менее, я использую карту в ситуациях, когда существует строго однозначное соответствие между входом и выходом.Это служит четким указанием для читателя, что, например, нет ситуаций, когда ошибки или неправильный ввод могли бы привести к сбою операции для создания выходной записи.