Documentation & literal expressions.

preaudc · Jan 27, 2015 · ea98ea1 · ea98ea1
1 parent 2b22684
commit ea98ea1
Show file tree

Hide file tree

Showing 8 changed files with 910 additions and 154 deletions.
diff --git a/mllib/src/main/scala/org/apache/spark/ml/recommendation/ALS.scala b/mllib/src/main/scala/org/apache/spark/ml/recommendation/ALS.scala
@@ -137,8 +137,8 @@ class ALSModel private[ml] (
         .as(map(predictionCol))
     val outputColumns = inputColumns.map(f => $"$instanceTable.$f".as(f)) :+ prediction
     instances
-      .join(users, "left", Column(map(userCol)) === $"$userTable.id")
-      .join(items, "left", Column(map(itemCol)) === $"$itemTable.id")
+      .join(users, Column(map(userCol)) === $"$userTable.id", "left")
+      .join(items, Column(map(itemCol)) === $"$itemTable.id", "left")
       .select(outputColumns: _*)
   }