ALS 实时推荐 Apache Flink

ALS Real-Time Recommendation Apache Flink

我想用ALS算法在Apache Flink上实现实时推荐

模型可以预先使用 Batch 进行训练，然后直接加载到 Flink 中。然后应处理输入数据流并将其用于预测。

自 Flink 1.9 起不再包含库 FlinkMl。除此之外，还有许多专为使用 Apache Flink 进行机器学习而设计的库。

为此我需要一个起点来帮助我实现这个项目。

1、推荐试用Alink.Alink是阿里计算PAI团队开发的基于Flink的Machine Learning算法平台platform.it支持ALS算法。 https://github.com/alibaba/Alink/blob/master/README.en-US.md

您会发现 README 可以更好地解释它。

2、试试Pandas?Pandas UDF/UDAF可以在PyFlink中直接调用

希望对你有所帮助