kafka-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Moein Hosseini <moein...@gmail.com>
Subject map operator on KeyedStream
Date Wed, 10 Jan 2018 11:45:27 GMT
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

[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

  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message