flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From neo21 zerro <neo21_ze...@yahoo.com>
Subject Sink partitioning
Date Wed, 13 Apr 2016 23:22:48 GMT
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?


View raw message