spark-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From pwend...@apache.org
Subject [9/9] git commit: Merge pull request #328 from falaki/MatrixFactorizationModel-fix
Date Wed, 08 Jan 2014 00:57:27 GMT
Merge pull request #328 from falaki/MatrixFactorizationModel-fix

SPARK-1012: DAGScheduler Exception Fix

Added a predict method to MatrixFactorizationModel to enable bulk prediction. This method
takes and RDD[(Int, Int)] of users and products and return an RDD with a Rating element per
each element in the input RDD.

Also added python bindings to the new bulk prediction methods to address SPARK-1011 issue.

This is ready to be merged now.


Project: http://git-wip-us.apache.org/repos/asf/incubator-spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-spark/commit/b2e690f8
Tree: http://git-wip-us.apache.org/repos/asf/incubator-spark/tree/b2e690f8
Diff: http://git-wip-us.apache.org/repos/asf/incubator-spark/diff/b2e690f8

Branch: refs/heads/master
Commit: b2e690f839e7ee47f405135d35170173386c5d13
Parents: 6ccf8ce 3a8beb4
Author: Patrick Wendell <pwendell@gmail.com>
Authored: Tue Jan 7 16:57:08 2014 -0800
Committer: Patrick Wendell <pwendell@gmail.com>
Committed: Tue Jan 7 16:57:08 2014 -0800

----------------------------------------------------------------------
 .../spark/mllib/api/python/PythonMLLibAPI.scala | 30 ++++++++++++++++
 .../MatrixFactorizationModel.scala              | 38 +++++++++++++++++++-
 .../spark/mllib/recommendation/ALSSuite.scala   | 33 +++++++++++++++--
 python/pyspark/mllib/_common.py                 | 25 +++++++++++++
 python/pyspark/mllib/recommendation.py          | 12 ++++++-
 5 files changed, 134 insertions(+), 4 deletions(-)
----------------------------------------------------------------------



Mime
View raw message