使用java中的数据集/Dataframe流作为als建议的输入？

wydwbb8l 于 2021-07-13 发布在 Spark

关注(0)|答案(0)|浏览(190)

我想用apachespark结构化流媒体创建一个实时推荐。
我已经和一个现成的alsmodel一起工作了，它已经接受了movielens收视率的培训(定位于：https://databricks-prod-cloudfront.cloud.databricks.com/public/4027ec902e239c93eaaa8714f173bcfc/1457916220563996/3123150065672593/1920439544921018/latest.html)
现在我想创建一个userid的输入流。输出流应该是用户ID和建议。
我可以使用一个输入流作为我的模型的输入，还是这个机器学习模型只与静态数据兼容？谢谢。

streaming apache-spark apache-spark-mllib als

来源：https://stackoverflow.com/questions/66184392/use-dataset-dataframe-stream-in-java-as-input-for-als-recommendation