DataFrames को जॉइन करें
अगले दो अध्यायों में, आप एक ऐसा मॉडल बनाएँगे जो यह भविष्यवाणी करेगा कि कोई फ्लाइट डिले होगी या नहीं, उसी flights डेटा के आधार पर जिस पर हम काम कर रहे हैं। इस मॉडल में उस विमान (plane) की जानकारी भी शामिल होगी जिसने वह रूट उड़ा, इसलिए पहला कदम है इन दो टेबल्स को जॉइन करना: flights और planes!
यह अभ्यास पाठ्यक्रम का हिस्सा है
PySpark की नींव
अभ्यास निर्देश
- पहले,
planesकीyearकॉलम का नाम बदलकरplane_yearरखें ताकि डुप्लिकेट कॉलम नाम न हों. tailnumकॉलम को की के रूप में उपयोग करकेflightsटेबल कोplanesसे जॉइन कर केmodel_dataनाम का एक नया DataFrame बनाएँ.
इंटरैक्टिव व्यावहारिक अभ्यास
इस अभ्यास को इस नमूना कोड को पूरा करके आज़माएँ।
# Rename year column
planes = planes.withColumnRenamed(____)
# Join the DataFrames
model_data = flights.join(____, on=____, how="leftouter")