rename RDDMatrixRow to IndexedRDDMatrixRow

Author: mengxr

mllib/src/main/scala/org/apache/spark/mllib/linalg/rdd/CoordinateRDDMatrix.scala

@@ -66,7 +66,7 @@ class CoordinateRDDMatrix(
     val indexedRows = entries.map(entry => (entry.i, (entry.j.toInt, entry.value)))
       .groupByKey()
       .map { case (i, vectorEntries) =>
-      RDDMatrixRow(i, Vectors.sparse(n, vectorEntries))
+      IndexedRDDMatrixRow(i, Vectors.sparse(n, vectorEntries))
     }
     new IndexedRowRDDMatrix(indexedRows, numRows(), numCols())
   }

…park/mllib/linalg/rdd/RDDMatrixRow.scala …lib/linalg/rdd/IndexedRDDMatrixRow.scalamllib/src/main/scala/org/apache/spark/mllib/linalg/rdd/RDDMatrixRow.scala renamed to mllib/src/main/scala/org/apache/spark/mllib/linalg/rdd/IndexedRDDMatrixRow.scala mllib/src/main/scala/org/apache/spark/mllib/linalg/rdd/RDDMatrixRow.scala renamed to mllib/src/main/scala/org/apache/spark/mllib/linalg/rdd/IndexedRDDMatrixRow.scala

@@ -20,4 +20,4 @@ package org.apache.spark.mllib.linalg.rdd
 import org.apache.spark.mllib.linalg.Vector
 
 /** Represents a row of RowRDDMatrix. */
-case class RDDMatrixRow(index: Long, vector: Vector)
+case class IndexedRDDMatrixRow(index: Long, vector: Vector)

mllib/src/main/scala/org/apache/spark/mllib/linalg/rdd/IndexedRowRDDMatrix.scala

@@ -27,7 +27,7 @@ import org.apache.spark.rdd.RDD
  * @param n number of cols, where a negative number means unknown
  */
 class IndexedRowRDDMatrix(
-    val rows: RDD[RDDMatrixRow],
+    val rows: RDD[IndexedRDDMatrixRow],
     m: Long = -1L,
     n: Long = -1L) extends RDDMatrix {
 
@@ -49,8 +49,8 @@ class IndexedRowRDDMatrix(
     _m
   }
 
-  /** Drops row indices and converts this to a RowRDDMatrix. */
-  def compressRows(): RowRDDMatrix = {
+  /** Drops row indices and converts this matrix to a RowRDDMatrix. */
+  def toRowRDDMatrix(): RowRDDMatrix = {
     new RowRDDMatrix(rows.map(_.vector), -1, _n)
   }
 }