spark-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Xingwei Yang <happy...@gmail.com>
Subject Transfer from RDD to JavaRDD
Date Fri, 05 Dec 2014 23:51:09 GMT
I use Spark in Java.

I want to access the vectors of RowMatrix M, thus I use M.rows(), which is
a RDD<Vector>

I want to transform it to JavaRDD<Vector>, I used the following command;

 JavaRDD<Vector> data = JavaRDD.fromRDD(M.rows(),
scala.reflect.ClassTag$.MODULE$.apply(Vector.class);

However, it shows a error like this:

The method fromRDD(RDD<T>, ClassTag<T>) in the type JavaRDD is not
applicable for the arguments (RDD<Vector>, ClassTag<Object>)

Is there anything wrong with the method? Thanks a lot.


-- 
Sincerely Yours
Xingwei Yang
https://sites.google.com/site/xingweiyang1223/

Mime
View raw message