revert some code

yinxusen · yinxusen · commit c28fdb8f0adc · 2016-07-08T11:54:34.000-07:00
diff --git a/examples/src/main/java/org/apache/spark/examples/mllib/JavaDataTypesExamples.java b/examples/src/main/java/org/apache/spark/examples/mllib/JavaDataTypesExamples.java
@@ -118,7 +118,7 @@ private static void rowMatrixExample() {
     Vector v3 = Vectors.dense(3.0, 30.0, 300.0);
 
     // a JavaRDD of local vectors
-    JavaRDD<Vector> rows = jsc.parallelize(Arrays.asList(v1, v2, v3), 1);
+    JavaRDD<Vector> rows = jsc.parallelize(Arrays.asList(v1, v2, v3));
 
     // Create a RowMatrix from an JavaRDD<Vector>.
     RowMatrix mat = new RowMatrix(rows.rdd());
@@ -189,7 +189,7 @@ private static void blockMatrixExample() {
     MatrixEntry me2 = new MatrixEntry(1, 0, 2.1);
     MatrixEntry me3 = new MatrixEntry(6, 1, 3.7);
 
-    // a JavaRDD of (i, j, v) Matrix Entries
+    // A JavaRDD of (i, j, v) Matrix Entries
     JavaRDD<MatrixEntry> entries = jsc.parallelize(Arrays.asList(me1, me2, me3));
 
     // Create a CoordinateMatrix from a JavaRDD<MatrixEntry>.
diff --git a/examples/src/main/scala/org/apache/spark/examples/mllib/DataTypesExamples.scala b/examples/src/main/scala/org/apache/spark/examples/mllib/DataTypesExamples.scala
@@ -85,7 +85,7 @@ object DataTypesExamples {
     val v2 = Vectors.dense(2.0, 20.0, 200.0)
     val v3 = Vectors.dense(3.0, 30.0, 300.0)
 
-    val rows: RDD[Vector] = sc.parallelize(Seq(v1, v2, v3), 1) // an RDD of local vectors
+    val rows: RDD[Vector] = sc.parallelize(Seq(v1, v2, v3)) // an RDD of local vectors
     // Create a RowMatrix from an RDD[Vector].
     val mat: RowMatrix = new RowMatrix(rows)
 
diff --git a/mllib/src/main/scala/org/apache/spark/mllib/linalg/distributed/RowMatrix.scala b/mllib/src/main/scala/org/apache/spark/mllib/linalg/distributed/RowMatrix.scala
@@ -50,7 +50,7 @@ class RowMatrix @Since("1.0.0") (
 
   /** Alternative constructor leaving matrix dimensions to be determined automatically. */
   @Since("1.0.0")
-  def this(rows: RDD[Vector]) = this(rows.retag(classOf[Vector]), 0L, 0)
+  def this(rows: RDD[Vector]) = this(rows, 0L, 0)
 
   /** Gets or computes the number of columns. */
   @Since("1.0.0")
