privacy preserving on streaming Kmeans in Flink

classic Classic list List threaded Threaded
2 messages Options
Reply | Threaded
Open this post in threaded view
|

privacy preserving on streaming Kmeans in Flink

alaa
*I try to make a research in privacy preserving data on streaming k-means
clustering and to develop an implementation on Flink.

My questions are :

    If there a library for K means in Flink? Because I didn't see it on
FlinkML?

    How we can I implement streaming kmeans clustering on Flink?

If anybody know , can you please explain some of the key steps that I have
to follow?*



--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
Reply | Threaded
Open this post in threaded view
|

Re: privacy preserving on streaming Kmeans in Flink

Ken Krugler
Hi Alaa,

You could look at https://github.com/ScaleUnlimited/flink-streaming-kmeans for an example of this.

Though note that there are non-iterative versions to k-means clustering that are much more efficient.

This code was a way of exploring iterations in streaming data….

— Ken

On Jun 14, 2019, at 6:06 AM, alaa <[hidden email]> wrote:

*I try to make a research in privacy preserving data on streaming k-means
clustering and to develop an implementation on Flink.

My questions are :

   If there a library for K means in Flink? Because I didn't see it on
FlinkML?

   How we can I implement streaming kmeans clustering on Flink?

If anybody know , can you please explain some of the key steps that I have
to follow?*

--------------------------
Ken Krugler
+1 530-210-6378
http://www.scaleunlimited.com
Custom big data solutions & training
Flink, Solr, Hadoop, Cascading & Cassandra