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