你可以直接用spark实现一个cf的算法,这个最简单了