Hi. This is Moein, a newbie in Apache Flink. I got confused when I saw that KeyedStream class extend DataStream without overriding the map method. what is the reason behind it? How is it possible to keep KeyedStream after transformation without lossing the key? something like: newMap(fn): KeyedStream[T]
best regards Moein -- [image: Photograph] *Moein Hosseini* Data Engineer email: moein...@gmail.com mobile: +98 912 468 1859 [image: Twitter icon] <https://twitter.com/moein7tl> [image: LinkedIn icon] <https://www.linkedin.com/in/moeinhm> moein.xyz | nodes.ir/@moein7tl
