Как показано в https://ci.apache.org/projects/flink/flink-docs-master/dev/scala_api_extensions.html, мы можем использовать функцию разделения scala на
import org.apache.flink.streaming.api.scala.extensions._
и заменить .map на .mapWith.но сигнатура def mapWith[R: TypeInformation](fun: T => R): DataStream[R] source и def map[R: TypeInformation](fun: T => R): DataStream[R] source абсолютно одинакова.Так как же происходит другое поведение?
.map
.mapWith
def mapWith[R: TypeInformation](fun: T => R): DataStream[R]
def map[R: TypeInformation](fun: T => R): DataStream[R]