January 2018
Intermediate to advanced
470 pages
11h 9m
English
We will load, parse, and do some exploratory analysis. However, before that, let's import the necessary packages and libraries:
package com.packt.ScalaML.MovieRecommendation import org.apache.spark.sql.SparkSession import org.apache.spark.mllib.recommendation.ALS import org.apache.spark.mllib.recommendation.MatrixFactorizationModel import org.apache.spark.mllib.recommendation.Rating import scala.Tuple2 import org.apache.spark.rdd.RDD
This code segment should return you the DataFrame of the ratings:
val ratigsFile = "data/ratings.csv"val df1 = spark.read.format("com.databricks.spark.csv").option("header", true).load(ratigsFile) val ratingsDF = df1.select(df1.col("userId"), ...Read now
Unlock full access