Hello everybody, I have an elasticsearch sink in my flink topology. My requirement is to write the data in a partitioned fashion to my Sink.
For example I have Tuple which contains a user id. I want to group all events by a user id and partition all events for one particular user to the same Es Sink. Is it possible to achieve something like this in Flink? Thanks!
