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

Aggregating II

आपको बिल्ट-इन एग्रीगेशन मेथड्स से और परिचित कराने के लिए, यहाँ flights टेबल पर आधारित कुछ और अभ्यास दिए गए हैं!

याद रखिए, आपके वर्कस्पेस में spark नाम का SparkSession पहले से मौजूद है, साथ ही Spark DataFrame flights भी।

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

PySpark की नींव

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

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

  • .avg() मेथड का उपयोग करके Delta Airlines की उन उड़ानों का औसत air time निकालिए (जहाँ carrier कॉलम का मान "DL" है) जो SEA से रवाना हुईं। प्रस्थान स्थान origin कॉलम में स्टोर है। परिणाम को show() कीजिए।
  • .sum() मेथड का उपयोग करके यह निकालिए कि इस डेटासेट में सभी विमानों ने कुल मिलाकर हवा में कितने घंटे बिताए। इसके लिए air_time कॉलम से duration_hrs नाम का एक कॉलम बनाइए। परिणाम को show() कीजिए।

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

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

# Average duration of Delta flights
flights.filter(____.____ == "____").filter(____.____ == "____").groupBy().avg("____").show()

# Total hours in the air
flights.withColumn("____", flights.air_time/60).groupBy().sum("____").show()
कोड संपादित करें और चलाएँ