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 meth
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): KeyedStr
