Я создаю систему рекомендаций для фильмов, используя наборы данных MovieLens, доступные здесь: http://grouplens.org/datasets/movielens/ Чтобы вычислить эту систему рекомендаций, я использую библиотеку ML Flink в scala и, в частности, алгоритм ALS...

Версия Flink: 1.2.0 Версия Scala: 2.11.8 Я хочу использовать DataStream для прогнозирования использования модели во флинке с использованием scala. У меня есть DataStream [String] в flink с использованием scala, который содержит данные в формате...