[ 
https://issues.apache.org/jira/browse/FLINK-1421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14289486#comment-14289486
 ] 

Gianmarco De Francisci Morales commented on FLINK-1421:
-------------------------------------------------------

Indeed, having some form of feedback between Processors is quite common is many 
algorithms, unless they are embarrassingly parallel (e.g., ensemble methods 
such as Bagging).
We are also trying to simplify the API and remove a lot of legacy code. 
Hopefully, you'll find it easier to test new datasets from real streams very 
soon.

> Implement a SAMOA Adapter for Flink Streaming
> ---------------------------------------------
>
>                 Key: FLINK-1421
>                 URL: https://issues.apache.org/jira/browse/FLINK-1421
>             Project: Flink
>          Issue Type: New Feature
>          Components: Streaming
>            Reporter: Paris Carbone
>            Assignee: Paris Carbone
>   Original Estimate: 336h
>  Remaining Estimate: 336h
>
> Yahoo's Samoa is an experimental incremental machine learning library that 
> builds on an abstract compositional data streaming model to write streaming 
> algorithms. The task is to provide an adapter from SAMOA topologies to 
> Flink-streaming job graphs in order to support Flink as a backend engine for 
> SAMOA tasks.
> A statup guide can be viewed here :
> https://docs.google.com/document/d/18glDJDYmnFGT1UGtZimaxZpGeeg1Ch14NgDoymhPk2A/pub
> The main working branch of the adapter :
> https://github.com/senorcarbone/samoa/tree/flink



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

Reply via email to