Hi all!,
I have a RDD[(int,int,double,double)] where the first two int values are id
and product, respectively. I trained an implicit ALS algorithm and want to
make predictions from this RDD. I make two things but I think both ways are
same.
1- Convert this RDD to RDD[(int,int)] and use
model.predict(RDD(int,int)), this works to me!
2- Make a map and apply model.predict(int,int), for example:
val ratings = RDD[(int,int,double,double)].map{ case (id, rubro, rating,
resp)=>
model.predict(id,rubro)
}
Where ratings is a RDD[Double].
Now, the second way when I apply a ratings.first() I get the follow error:
Why this happend? I need to use this second way.
Thanks in advance,
Franco Barrientos
Data Scientist
Málaga #115, Of. 1003, Las Condes.
Santiago, Chile.
(+562)-29699649
(+569)-76347893
<mailto:franco.barrien...@exalitica.com> franco.barrien...@exalitica.com
<http://www.exalitica.com/> www.exalitica.com
<http://exalitica.com/web/img/frim.png>
