flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Timo Walther <twal...@apache.org>
Subject Re: .keyBy() on ConnectedStream
Date Fri, 27 Jan 2017 09:35:20 GMT
Hi Matt,

the keyBy() on ConnectedStream has two parameters to specify the key of 
the left and of the right stream. Same keys end up in the same 
CoMapFunction/CoFlatMapFunction. If you want to group both streams on a 
common key, then you can use .union() instead of .connect().

I hope that helps.


Am 27/01/17 um 07:21 schrieb Matt:
> Hi all,
> What's the purpose of .keyBy() on ConnectedStream? How does it affect 
> .map() and .flatMap()?
> I'm not finding a way to group stream elements based on a key, 
> something like a Window on a normal Stream, but for a ConnectedStream.
> Regards,
> Matt

View raw message