Re: Flink ML linear regression issue

2015-09-18 Thread Till Rohrmann
Hi Alexey and Hanan, one of FlinkML’s feature is the flexible pipelining mechanism. It allows you to chain multiple transformers with a trailing predictor to form a data analysis pipeline. In order to support multiple input types, the actual program logic (matching for the type) is assembled at

Re: Flink ML linear regression issue

2015-09-18 Thread Theodore Vasiloudis
+1, having the convenient creation of pipelines for Java is more of a long term project, but we should make it possible to manually create pipelines in Java. On Fri, Sep 18, 2015 at 11:15 AM, Till Rohrmann wrote: > Hi Alexey and Hanan, > > one of FlinkML’s feature is

RE: Flink ML linear regression issue

2015-09-18 Thread alexey
Thank you very much for the clarifications. -Original Message- From: Theodore Vasiloudis [mailto:theodoros.vasilou...@gmail.com] Sent: Friday, September 18, 2015 2:33 PM To: dev@flink.apache.org Cc: Hanan Meyer Subject: Re: Flink ML linear regression issue +1, having the convenient

Flink ML linear regression issue

2015-09-17 Thread Hanan Meyer
Hi I'm using Flink ML 9.2.1 in order to perform a multiple linear regression with a csv data file. The Scala sample code for it is pretty straightforward: val mlr = MultipleLinearRegression() val parameters = ParameterMap() parameters.add(MultipleLinearRegression.Stepsize, 2.0)

Re: Flink ML linear regression issue

2015-09-17 Thread Alexey Sapozhnikov
Hello everyone. Do you have a sample in Java how to implement Flink MultipleLinearRegression example? Scala is great, however we would like to see the exact example we could invoke it from Java if it is possible. Thanks and sorry for the interrupt. On Thu, Sep 17, 2015 at 4:27 PM, Hanan Meyer