सामान्य joins
आपको दो DataFrames दिए गए हैं जिन्हें मिलाकर एक उपयोगी DataFrame बनाना है। आपका पहला काम है DataFrames को सामान्य तरीके से जोड़ना और execution plan देखना.
DataFrames flights_df और airports_df आपके लिए उपलब्ध हैं.
यह अभ्यास पाठ्यक्रम का हिस्सा है
PySpark के साथ डेटा क्लीनिंग
अभ्यास निर्देश
flights_dfकोairports_dfके साथ जॉइन करके एक नया DataFramenormal_dfबनाएँ.- क्वेरी प्लान में कौन-सा join प्रकार उपयोग हुआ है, यह निर्धारित करें.
इंटरैक्टिव व्यावहारिक अभ्यास
इस अभ्यास को इस नमूना कोड को पूरा करके आज़माएँ।
# 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.____()