File tree Expand file tree Collapse file tree 1 file changed +3
-2
lines changed
mllib/src/main/scala/org/apache/spark/mllib/rdd Expand file tree Collapse file tree 1 file changed +3
-2
lines changed Original file line number Diff line number Diff line change @@ -69,7 +69,8 @@ private class VectorRDDStatisticsAggregator(
6969 val deltaMean = currMean
7070 var i = 0
7171 while (i < currM2n.size) {
72- realVariance(i) = currM2n(i) + deltaMean(i) * deltaMean(i) * nnz(i) * (totalCnt - nnz(i)) / totalCnt
72+ realVariance(i) =
73+ currM2n(i) + deltaMean(i) * deltaMean(i) * nnz(i) * (totalCnt - nnz(i)) / totalCnt
7374 realVariance(i) /= totalCnt
7475 i += 1
7576 }
@@ -140,7 +141,7 @@ private class VectorRDDStatisticsAggregator(
140141 // merge m2n together
141142 if (nnz(i) + other.nnz(i) != 0.0 ) {
142143 currM2n(i) += other.currM2n(i) + deltaMean(i) * deltaMean(i) * nnz(i) * other.nnz(i) /
143- (nnz(i)+ other.nnz(i))
144+ (nnz(i) + other.nnz(i))
144145 }
145146
146147 if (currMax(i) < other.currMax(i)) currMax(i) = other.currMax(i)
You can’t perform that action at this time.
0 commit comments