FlinkML

[Szymon Szczypiński]

Hi,

i wonder if there are possibility to build FlinkML streaming job not a
batch job. Examples on
https://ci.apache.org/projects/flink/flink-docs-release-1.4/dev/libs/ml/ 
are only batch examples.

Is there any possibility?


Best regards.

[Christophe Jolif]

Szymon,

The short answer is no. See: http://mail-archives.apache.org/mod_mbox/flink-user/201802.mbox/%3CCAAdrtT39CiiEc1UzwthzgNBkJXS-_H5yFzowhzPh_ZBiduXYtg@...%3E

On Mon, Apr 16, 2018 at 11:25 PM, Szymon Szczypiński <[hidden email]> wrote:

Hi,

i wonder if there are possibility to build FlinkML streaming job not a batch job. Examples on https://ci.apache.org/projects/flink/flink-docs-release-1.4/dev/libs/ml/ are only batch examples.

Is there any possibility?


Best regards.

--

[shashank734]

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/

[Christophe Salperwyck]

Hi,

You could try to plug MOA/Weka library too. I did some preliminary work with that:

https://moa.cms.waikato.ac.nz/moa-with-apache-flink/

but then it is not anymore FlinkML algorithms.

Best regards,

Christophe

2018-04-18 21:13 GMT+02:00 shashank734 <[hidden email]>:

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/