There are no active discussions or guide on that. But I found this example in the repo :
https://github.com/apache/flink/blob/master/flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/ml/IncrementalLearningSkeleton.java <https://github.com/apache/flink/blob/master/flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/ml/IncrementalLearningSkeleton.java> Which is trying to do the same thing. Although I haven't checked this yet. -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/