Hi all.
I'm willing to serialize and later load a model trained using mllib's
ALS.
I've tried usign Java serialization with something like:
val model = ALS.trainImplicit(training, rank, numIter, lambda, 1)
val fos = new FileOutputStream("model.bin")
val oos = new ObjectOutputStream(fos)
oos.writeObject(bestModel.get)
But when I try to deserialize it using:
val fos = new FileInputStream("model.bin")
val oos = new ObjectInputStream(fos)
val model = oos.readObject().asInstanceOf[MatrixFactorizationModel]
I get the error:
Exception in thread "main" java.io.IOException: PARSING_ERROR(2)
I've also tried to serialize MatrixFactorizationModel's both RDDs
(products and users) and later create the MatrixFactorizationModel by
hand passing the RDDs by constructor but I get an error cause its
private:
Error:(58, 17) constructor MatrixFactorizationModel in class
MatrixFactorizationModel cannot be accessed in object RecommendALS
val model = new MatrixFactorizationModel (8, userFeatures,
productFeatures)
Any ideas?
Thanks!
--
Albert Manyà
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
