You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@mahout.apache.org by ap...@apache.org on 2016/03/15 17:51:44 UTC
mahout git commit: MAHOUT-1807: Distributed second norm doesn't take
sqrt closes apache/mahout#189
Repository: mahout
Updated Branches:
refs/heads/master 5d56be7f3 -> 401c8e8b4
MAHOUT-1807: Distributed second norm doesn't take sqrt closes apache/mahout#189
Project: http://git-wip-us.apache.org/repos/asf/mahout/repo
Commit: http://git-wip-us.apache.org/repos/asf/mahout/commit/401c8e8b
Tree: http://git-wip-us.apache.org/repos/asf/mahout/tree/401c8e8b
Diff: http://git-wip-us.apache.org/repos/asf/mahout/diff/401c8e8b
Branch: refs/heads/master
Commit: 401c8e8b4a40accc0d41fe8f3c4ee55dfba0040d
Parents: 5d56be7
Author: Andrew Palumbo <ap...@apache.org>
Authored: Tue Mar 15 12:44:10 2016 -0400
Committer: Andrew Palumbo <ap...@apache.org>
Committed: Tue Mar 15 12:44:52 2016 -0400
----------------------------------------------------------------------
.../main/scala/org/apache/mahout/sparkbindings/SparkEngine.scala | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/mahout/blob/401c8e8b/spark/src/main/scala/org/apache/mahout/sparkbindings/SparkEngine.scala
----------------------------------------------------------------------
diff --git a/spark/src/main/scala/org/apache/mahout/sparkbindings/SparkEngine.scala b/spark/src/main/scala/org/apache/mahout/sparkbindings/SparkEngine.scala
index 3200288..6b08c1f 100644
--- a/spark/src/main/scala/org/apache/mahout/sparkbindings/SparkEngine.scala
+++ b/spark/src/main/scala/org/apache/mahout/sparkbindings/SparkEngine.scala
@@ -86,12 +86,12 @@ object SparkEngine extends DistributedEngine {
if (drm.nrow == 0) drm.colSums() else drm.colSums() /= drm.nrow
override def norm[K](drm: CheckpointedDrm[K]): Double =
- drm.rdd
+ math.sqrt(drm.rdd
// Compute sum of squares of each vector
.map {
case (key, v) ⇒ v dot v
}
- .reduce(_ + _)
+ .reduce(_ + _))
/** Optional engine-specific all reduce tensor operation. */