| 
259
 | 
     1  | 
  | 
| 
 | 
     2  | 
// first test 
  | 
| 
 | 
     3  | 
  | 
| 
 | 
     4  | 
  | 
| 
 | 
     5  | 
def urban_groupById(ratings: List[(String, String)]) = 
  | 
| 
 | 
     6  | 
  ratings.groupBy(_._1).mapValues(_.map(_._2)) 
  | 
| 
 | 
     7  | 
  | 
| 
 | 
     8  | 
def urban_get_csv_file(name: String) : List[String] = {
 | 
| 
 | 
     9  | 
  import io.Source
  | 
| 
 | 
    10  | 
  import scala.util._
  | 
| 
 | 
    11  | 
  val csv = Source.fromFile(name)
  | 
| 
 | 
    12  | 
  csv.mkString.split("\n").toList.drop(1)
 | 
| 
 | 
    13  | 
}
  | 
| 
 | 
    14  | 
  | 
| 
 | 
    15  | 
def urban_process_ratings(lines: List[String]) : List[(String, String)] = {
 | 
| 
 | 
    16  | 
  for (cols <- lines.map(_.split(",").toList); 
 | 
| 
 | 
    17  | 
       if (cols(2).toFloat >= 4)) yield (cols(0), cols(1))  
  | 
| 
 | 
    18  | 
}
  | 
| 
 | 
    19  | 
  | 
| 
 | 
    20  | 
def urban_process_movies(lines: List[String]) : List[(String, String)] = {
 | 
| 
 | 
    21  | 
  for (cols <- lines.map(_.split(",").toList)) yield (cols(0), cols(1))  
 | 
| 
 | 
    22  | 
}
  | 
| 
 | 
    23  | 
  | 
| 
 | 
    24  | 
  | 
| 
 | 
    25  | 
val urban_good_ratings = process_ratings(urban_get_csv_file("ratings.csv"))
 | 
| 
 | 
    26  | 
val urban_movie_names = process_movies(urban_get_csv_file("movies.csv")).toMap
 | 
| 
 | 
    27  | 
  | 
| 
 | 
    28  | 
val urban_ratings_map = urban_groupById(urban_good_ratings)
  | 
| 
 | 
    29  | 
  | 
| 
 | 
    30  | 
assert((for (n <- List("1", "2", "3", "4", "5")) yield {
 | 
| 
 | 
    31  | 
  recommendations(urban_ratings_map, urban_movie_names, n).length
  | 
| 
 | 
    32  | 
}) == List(2, 2, 2, 0, 2))
  | 
| 
 | 
    33  | 
  |