when() उदाहरण
when() क्लॉज़ आपको किसी DataFrame की सामग्री के आधार पर उसे शर्तानुसार बदलने देता है। आपको हमारे voter_df DataFrame में उन सभी voting members के लिए एक रैंडम नंबर जोड़ना है जिनका title "Councilmember" है.
voter_df DataFrame परिभाषित है और आपके लिए उपलब्ध है। pyspark.sql.functions लाइब्रेरी F. के रूप में उपलब्ध है। आप रैंडम वैल्यू बनाने के लिए F.rand() का उपयोग कर सकते हैं.
यह अभ्यास पाठ्यक्रम का हिस्सा है
PySpark के साथ डेटा क्लीनिंग
अभ्यास निर्देश
voter_dfमेंrandom_valनाम का एक कॉलम जोड़ें, जिसमें उन voters के लिएF.rand()मेथड का परिणाम हो जिनका title Councilmember है.- DataFrame की कुछ rows दिखाएँ और देखें कि
.when()क्लॉज़ सही से काम कर रहा है या नहीं.
इंटरैक्टिव व्यावहारिक अभ्यास
इस अभ्यास को इस नमूना कोड को पूरा करके आज़माएँ।
# Add a column to voter_df for any voter with the title **Councilmember**
voter_df = voter_df.____('random_val',
____(____, ____))
# Show some of the DataFrame rows, noting whether the when clause worked
voter_df.____