diff options
| author | a1singh <a1singh@ucsd.edu> | 2015-11-05 12:51:10 +0000 |
|---|---|---|
| committer | Sean Owen <sowen@cloudera.com> | 2015-11-05 12:51:10 +0000 |
| commit | a94671a027c29bacea37f56b95eccb115638abff (patch) | |
| tree | d5cee2e6116eb5eae384fce1db11025838985c1f /mllib | |
| parent | 7bdc92197cce0edc0110dc9c2158e6e3f42c72ee (diff) | |
| download | spark-a94671a027c29bacea37f56b95eccb115638abff.tar.gz spark-a94671a027c29bacea37f56b95eccb115638abff.tar.bz2 spark-a94671a027c29bacea37f56b95eccb115638abff.zip | |
[SPARK-11506][MLLIB] Removed redundant operation in Online LDA implementation
In file LDAOptimizer.scala:
line 441: since "idx" was never used, replaced unrequired zipWithIndex.foreach with foreach.
- nonEmptyDocs.zipWithIndex.foreach { case ((_, termCounts: Vector), idx: Int) =>
+ nonEmptyDocs.foreach { case (_, termCounts: Vector) =>
Author: a1singh <a1singh@ucsd.edu>
Closes #9456 from a1singh/master.
Diffstat (limited to 'mllib')
| -rw-r--r-- | mllib/src/main/scala/org/apache/spark/mllib/clustering/LDAOptimizer.scala | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/mllib/src/main/scala/org/apache/spark/mllib/clustering/LDAOptimizer.scala b/mllib/src/main/scala/org/apache/spark/mllib/clustering/LDAOptimizer.scala index 38486e949b..17c0609800 100644 --- a/mllib/src/main/scala/org/apache/spark/mllib/clustering/LDAOptimizer.scala +++ b/mllib/src/main/scala/org/apache/spark/mllib/clustering/LDAOptimizer.scala @@ -438,7 +438,7 @@ final class OnlineLDAOptimizer extends LDAOptimizer { val stat = BDM.zeros[Double](k, vocabSize) var gammaPart = List[BDV[Double]]() - nonEmptyDocs.zipWithIndex.foreach { case ((_, termCounts: Vector), idx: Int) => + nonEmptyDocs.foreach { case (_, termCounts: Vector) => val ids: List[Int] = termCounts match { case v: DenseVector => (0 until v.size).toList case v: SparseVector => v.indices.toList |