Join normal
Anda diberikan dua DataFrame untuk digabungkan menjadi satu DataFrame yang berguna. Tugas pertama Anda adalah menggabungkan DataFrame secara normal dan melihat rencana eksekusinya.
DataFrame flights_df dan airports_df tersedia untuk Anda.
Latihan ini merupakan bagian dari kursus
Membersihkan Data dengan PySpark
Instruksi latihan
- Buat DataFrame baru
normal_dfdengan melakukan joinflights_dfdenganairports_df. - Tentukan jenis join yang digunakan dalam rencana kueri.
Latihan interaktif langsung praktik
Cobalah latihan ini dengan melengkapi kode contoh ini.
# Join the flights_df and aiports_df DataFrames
normal_df = flights_df.____(____, \
flights_df["Destination Airport"] == airports_df["IATA"] )
# Show the query plan
normal_df.____()