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/

Reply via email to