Created
June 24, 2016 14:47
-
-
Save danared/0412235cb3de98ce7d734923ce78092f to your computer and use it in GitHub Desktop.
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| // Combine the datasets | |
| val userRatings = MongoSpark.load(sc, readConfig.copy(collectionName = "personal_ratings")).toDF[UserMovieRating] | |
| val combinedRatings = movieRatings.unionAll(userRatings) | |
| // Retrain using the combinedRatings | |
| val combinedModel = als.fit(combinedRatings, bestModel.extractParamMap()) |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment