Answering to myself if someone is having similar problems. So already saved
matrices can be read and used in als like this:
// Setup the ALS learnerd
val als = ALS()
val users = env.readFile(new
TypeSerializerInputFormat[Factors](createTypeInformation[Factors]),"path")
val items = env.readFile(new
TypeSerializerInputFormat[Factors](createTypeInformation[Factors]),"path")
als.factorsOption = Option(users,items)
After this, one can use als for prediction.
--
View this message in context:
http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Flink-ML-1-0-0-Saving-and-Loading-Models-to-Score-a-Single-Feature-Vector-tp5766p6167.html
Sent from the Apache Flink User Mailing List archive. mailing list archive at
Nabble.com.
