ALS 实时推荐 Apache Flink

问题描述

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

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

从 Flink 1.9 开始不再包含 FlinkMl 库。 除此之外，还有许多用于使用 Apache Flink 进行机器学习的库。

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

解决方法

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

你会发现可以更好地解释它的自述文件。

2、试试Pandas？PyFlink可以直接调用Pandas的UDF/UDAF。

希望能帮到你。