flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From TechnoMage <mla...@technomage.com>
Subject KeyedSream question
Date Thu, 05 Apr 2018 02:50:55 GMT
I am new to Flink and trying to understand the keyBy and KeyedStream.  From the short doc description
I expected it to partition the data such that the following flatMap would only see elements
with the same key.  That events with different keys would be presented to different instances
of FlatMapFunction.  But, I am seeing it present all events in the stream to the same FlatMapFunction.

Michael
Mime
View raw message