When / Otherwise
यह आवश्यकता पिछली के जैसी है, लेकिन अब आप वोटर की पोज़िशन के आधार पर कई मान जोड़ना चाहते हैं। अपने voter_df DataFrame को इस तरह बदलें कि किसी भी वोटिंग मेंबर जो Councilmember के रूप में परिभाषित है, में एक रैंडम नंबर जोड़ा जाए। Mayor के लिए 2 का उपयोग करें और किसी भी अन्य पोज़िशन के लिए 0 का।
voter_df Data Frame परिभाषित है और आपके लिए उपलब्ध है। pyspark.sql.functions लाइब्रेरी F. के रूप में उपलब्ध है। आप रैंडम वैल्यू बनाने के लिए F.rand() इस्तेमाल कर सकते हैं.
यह अभ्यास पाठ्यक्रम का हिस्सा है
PySpark के साथ डेटा क्लीनिंग
अभ्यास निर्देश
voter_dfमेंrandom_valनाम का एक कॉलम जोड़ें, और जिन भी वोटर का टाइटल Councilmember है, उनके लिएF.rand()मेथड का परिणाम सेट करें। Mayor के लिएrandom_valको 2 सेट करें। किसी अन्य टाइटल के लिए मान 0 रखें.- कुछ Data Frame की रो दिखाएँ और जाँचें कि क्लॉज़ सही तरह काम कर रहे हैं या नहीं.
random_valमें 0 ढूँढ़ने के लिए.filterक्लॉज़ का उपयोग करें.
इंटरैक्टिव व्यावहारिक अभ्यास
इस अभ्यास को इस नमूना कोड को पूरा करके आज़माएँ।
# Add a column to voter_df for a voter based on their position
voter_df = voter_df.____('random_val',
when(voter_df.TITLE == 'Councilmember', ____)
.____(____, 2)
____
# Show some of the DataFrame rows
voter_df.show()
# Use the .filter() clause with random_val
voter_df.____(____).show()