Re: Machine Learning on Flink - Next steps

2017-03-20 Thread Ventura Del Monte
Hello everyone, Here at DFKI, we are currently working on project that involves developing open-source Online Machine Learning algorithms on top of Flink. So far, we have simple moments, sampling (e.g.: simple reservoir sampling) and sketches (e.g., Frequent Directions) built on top of scikit-like

Re: [DISCUSS] FLIP-17 Side Inputs

2017-03-17 Thread Ventura Del Monte
gt;>>>>>> also what I prefer. >>>>>>>> >>>>>>>> Regarding semantics: yes, we simply wait for anything to be >>>>>>>> available. >>>>>>>> For GlobalWindows, i.e. side inputs on a normal function wher

Re: [DISCUSS] FLIP-17 Side Inputs

2017-03-07 Thread Ventura Del Monte
Hi Aljoscha, Thank you for the proposal and for bringing up again this discussion. Regarding the implementation aspect,I would say the first way could be easier/faster to implement but it could add some overhead when dealing with multiple side inputs through the current 2-streams union transform.

[jira] [Created] (FLINK-5157) Extending AllWindow Function Metadata

2016-11-24 Thread Ventura Del Monte (JIRA)
Ventura Del Monte created FLINK-5157: Summary: Extending AllWindow Function Metadata Key: FLINK-5157 URL: https://issues.apache.org/jira/browse/FLINK-5157 Project: Flink Issue Type: New

[jira] [Created] (FLINK-4997) Extending Window Function Metadata

2016-11-02 Thread Ventura Del Monte (JIRA)
Ventura Del Monte created FLINK-4997: Summary: Extending Window Function Metadata Key: FLINK-4997 URL: https://issues.apache.org/jira/browse/FLINK-4997 Project: Flink Issue Type: New