apache-flink - Apache Flink DataStream API には mapPartition 変換がありません

Question

Spark DStream にはmapPartitionAPI がありますが、Flink DataStreamAPI にはありません。理由を説明できる人はいますか。私がやりたいことはreduceByKey、Flink で Spark に似た API を実装することです。