You are viewing a plain text version of this content. The canonical link for it is here.

Posted to users@kafka.apache.org by Moein Hosseini <mo...@gmail.com> on 2018/01/10 11:45:27 UTC

map operator on KeyedStream

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: moein7tl@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

Re: map operator on KeyedStream

Posted by "Matthias J. Sax" <ma...@confluent.io>.

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
>