Re: Streaming Linear Regression problem

2015-04-21 Thread Xiangrui Meng
ache() >> > val testData = >> > >> ssc.textFileStream("/home/barisakgu/Desktop/Spark/test").map(LabeledPoint.parse) >> > >> > val model = new >> > >> StreamingLinearRegressionWithSGD().setInitialWeights(Vectors.zeros(numFeatures)) >>

Re: Streaming Linear Regression problem

2015-04-20 Thread Xiangrui Meng
) > > val model = new > StreamingLinearRegressionWithSGD().setInitialWeights(Vectors.zeros(numFeatures)) > > model.trainOn(trainingData) > model.predictOnValues(testData.map(lp => (lp.label, > lp.features))).print() > > ssc.start() > ssc.awaitTermination

Streaming Linear Regression problem

2015-04-17 Thread barisak
in context: http://apache-spark-user-list.1001560.n3.nabble.com/Streaming-Linear-Regression-problem-tp22539.html Sent from the Apache Spark User List mailing list archive at Nabble.com. - To unsubscribe, e-mail: user-unsubscr...@