kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Matthias J. Sax" <matth...@confluent.io>
Subject Re: map operator on KeyedStream
Date Wed, 10 Jan 2018 19:23:08 GMT
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
> 


Mime
View raw message