From 1a63b204a59601734de986964d09515a0b5ab082 Mon Sep 17 00:00:00 2001 From: Burak Yavuz Date: Tue, 20 Jan 2015 12:45:17 -0800 Subject: [PATCH] [SPARK-3974] Remove setPartition method. Isn't required --- .../spark/mllib/linalg/distributed/BlockMatrix.scala | 10 +--------- 1 file changed, 1 insertion(+), 9 deletions(-) diff --git a/mllib/src/main/scala/org/apache/spark/mllib/linalg/distributed/BlockMatrix.scala b/mllib/src/main/scala/org/apache/spark/mllib/linalg/distributed/BlockMatrix.scala index e8f270754f8b4..4323cc936bf95 100644 --- a/mllib/src/main/scala/org/apache/spark/mllib/linalg/distributed/BlockMatrix.scala +++ b/mllib/src/main/scala/org/apache/spark/mllib/linalg/distributed/BlockMatrix.scala @@ -106,7 +106,7 @@ class BlockMatrix( this(numRowBlocks, numColBlocks, rdd) val part = new GridPartitioner(numRowBlocks, numColBlocks, rowsPerBlock, colsPerBlock, rdd.partitions.length) - setPartitioner(part) + partitioner = part } private[mllib] var partitioner: GridPartitioner = { @@ -115,14 +115,6 @@ class BlockMatrix( firstSubMatrix.numRows, firstSubMatrix.numCols, rdd.partitions.length) } - /** - * Set the partitioner for the matrix. For internal use only. Users should use `repartition`. - * @param part A partitioner that specifies how SubMatrices are stored in the cluster - */ - private def setPartitioner(part: GridPartitioner): Unit = { - partitioner = part - } - private lazy val dims: (Long, Long) = getDim override def numRows(): Long = dims._1