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(
69
69
val deltaMean = currMean
70
70
var i = 0
71
71
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
73
74
realVariance(i) /= totalCnt
74
75
i += 1
75
76
}
@@ -140,7 +141,7 @@ private class VectorRDDStatisticsAggregator(
140
141
// merge m2n together
141
142
if (nnz(i) + other.nnz(i) != 0.0 ) {
142
143
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))
144
145
}
145
146
146
147
if (currMax(i) < other.currMax(i)) currMax(i) = other.currMax(i)
You can’t perform that action at this time.
0 commit comments