H i am new here...

I am trying to implement online k-means as here
https://databricks.com/blog/2015/01/28/introducing-streaming-k-means-in-spark-1-2.html
with flink.
I dont see anywhere a withBroadcastSet call to save intermediate results is
this currently supported?

Is intermediate results state saved somewhere like in this example a viable
alternative:

https://github.com/StephanEwen/flink-demos/blob/master/streaming-state-machine/src/main/scala/com/dataartisans/flink/example/eventpattern/StreamingDemo.scala

Thnx,
Stavros

Reply via email to