शुरू करेंमुफ़्त में शुरू करें

Flights को उनके destination airports से जोड़ना

आपको एक ग्लोबल ट्रैवल कंपनी में डेटा इंजीनियर के रूप में नियुक्त किया गया है. आपका पहला काम है कंपनी को फ्लाइट डेटा का विश्लेषण करके अपने ऑपरेशंस बेहतर करने में मदद करना. आपके वर्कस्पेस में दो डेटासेट हैं: एक में फ्लाइट्स का विवरण (flights) है और दूसरे में डेस्टिनेशन एयरपोर्ट्स की जानकारी (airports) है. ये दोनों आपके वर्कस्पेस में पहले से मौजूद हैं.

आपका लक्ष्य? इन डेटासेट्स को मिलाकर ऐसा सशक्त डेटासेट बनाना जो हर फ्लाइट को उसके डेस्टिनेशन एयरपोर्ट से जोड़ दे.

यह अभ्यास पाठ्यक्रम का हिस्सा है

PySpark परिचय

पाठ्यक्रम देखें

अभ्यास निर्देश

  • airports DataFrame को जाँचें. नोट करें कि कौन-सा key कॉलम airports को flights टेबल से जोड़ने देगा.
  • flights को "dest" कॉलम पर airports DataFrame के साथ जॉइन करें. नतीजा flights_with_airports के रूप में सेव करें.
  • flights_with_airports को फिर से जाँचें. ध्यान दें कि कौन-सी नई जानकारी जोड़ी गई है.

इंटरैक्टिव व्यावहारिक अभ्यास

इस अभ्यास को इस नमूना कोड को पूरा करके आज़माएँ।

# Examine the data
airports.____()

# .withColumnRenamed() renames the "faa" column to "dest"
airports = airports.withColumnRenamed("faa", "dest")

# Join the DataFrames
flights_with_airports = ____

# Examine the new DataFrame
flights_with_airports.____
कोड संपादित करें और चलाएँ