You might want to ask at the Flink mailing list. Or use Kafka Streams instead of Flink :D
-Matthias On 1/10/18 3:45 AM, Moein Hosseini wrote: > 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 >
signature.asc
Description: OpenPGP digital signature
