基于 Spark ALS 实现了增量式更新 userFactors, itemFacotors,支持加入新的 user 和 item,源码在https://github.com/itsliupeng/incremental_spark_als_mf

基于论文 Large-scale matrix factorization with distributed stochastic gradient descent 使用 Scala 和 Spark 实现了 DSGD,源码在https://github.com/itsliupeng/DSGD_spark

具体场景可参考下面 pdf

Matrix factoration and DSGD in Spark from peng liu