Mulai sekarangMulai gratis

Memberi id bilangan bulat untuk film

Mari lakukan hal yang sama pada film. Lalu gabungkan ID pengguna baru dan ID film ke dalam satu dataframe.

Latihan ini merupakan bagian dari kursus

Membangun Recommendation Engine dengan PySpark

Lihat Kursus

Instruksi latihan

  • Gunakan metode .select() dan .distinct() untuk mengekstrak semua Movie unik dari dataframe ratings.
  • Bagi ulang dataframe movies menjadi satu partisi menggunakan coalesce().
  • Lengkapi potongan kode yang disediakan untuk memberikan ID bilangan bulat unik ke setiap film. Beri nama kolom baru movieId dan panggil metode .persist() pada dataframe hasilnya.
  • Lakukan join dataframe ratings ke dataframe users dan selanjutnya ke dataframe movies. Beri nama hasilnya movie_ratings.

Latihan interaktif langsung praktik

Cobalah latihan ini dengan melengkapi kode contoh ini.

# Extract the distinct movie id's
movies = ratings.select("____").distinct() 

# Repartition the data to have only one partition.
movies = movies.coalesce(____) 

# Create a new column of movieId integers. 
movies = movies.withColumn("____", monotonically_increasing_id()).____() 

# Join the ratings, users and movies dataframes
movie_ratings = ratings.join(____, "User", "left").join(____, "Movie", "left")
movie_ratings.show()
Edit dan Jalankan Kode