Apache Flink 0.9 ALS API

2015-06-12 Thread Ronny Bräunlich
Hello everybody, for a university project we use the current implementation of ALS in Flink 0.9 and we were wondering about the API of predict() and fit() requiring a DataSet[(Int, Int)] or DataSet[(Int, Int, Double]) respectively, because the range of Int is quite limited. That is why we wante

Apache Flink 0.9 ALS API

2015-06-14 Thread Ronny Bräunlich
Hello everybody, for a university project we use the current implementation of ALS in Flink 0.9 and we were wondering about the API of predict() and fit() requiring a DataSet[(Int, Int)] or DataSet[(Int, Int, Double]) respectively, because the range of Int is quite limited. That is why we wante