rename RDDMatrixRow to IndexedRDDMatrixRow

witgo · Apr 2, 2014 · a85262a · a85262a
1 parent b8b6ac3
commit a85262a
Show file tree

Hide file tree

Showing 3 changed files with 5 additions and 5 deletions.
diff --git a/mllib/src/main/scala/org/apache/spark/mllib/linalg/rdd/CoordinateRDDMatrix.scala b/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())
   }

diff --git a/...spark/mllib/linalg/rdd/RDDMatrixRow.scala → ...llib/linalg/rdd/IndexedRDDMatrixRow.scala b/...spark/mllib/linalg/rdd/RDDMatrixRow.scala → ...llib/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)
diff --git a/mllib/src/main/scala/org/apache/spark/mllib/linalg/rdd/IndexedRowRDDMatrix.scala b/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)
   }
 }