Currently I am not aware of streaming learners support, you would need to implement that yourself at this point.
As for streaming predictors for batch learners I have some preview code that you might like. [1] [1] https://github.com/streamline-eu/ML-Pipelines/blob/314e3d940f1f1ac7b762ba96067e13d806476f57/flink-libraries/flink-stream-ml/src/main/scala/org/apache/flink/stream/ml/examples/MLRExample.scala On Wed, May 11, 2016 at 3:52 PM, Piyush Shrivastava <piyush...@yahoo.co.in> wrote: > Hi Márton, > > I want to train and get the residuals. > > Thanks and Regards, > Piyush Shrivastava <piy...@webograffiti.com> > [image: WeboGraffiti] > http://webograffiti.com > > > On Wednesday, 11 May 2016 7:19 PM, Márton Balassi < > balassi.mar...@gmail.com> wrote: > > > Hey Piyush, > > Would you like to train or predict on the streaming data? > > Best, > > Marton > > On Wed, May 11, 2016 at 3:44 PM, Piyush Shrivastava <piyush...@yahoo.co.in > > wrote: > > Hello all, > > I want to perform linear regression using FlinkML's > MultipleLinearRegression() function on streaming data. > > This function takes a DataSet as an input and I cannot create a DataSet > inside the MapFunction of a DataStream. How can I use this function on my > DataStream? > > Thanks and Regards, > Piyush Shrivastava <piy...@webograffiti.com> > [image: WeboGraffiti] > http://webograffiti.com > > > > >
