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
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