Ví dụ when()
Mệnh đề when() cho phép bạn thay đổi có điều kiện một DataFrame dựa trên nội dung của nó. Bạn sẽ chỉnh sửa DataFrame voter_df để cộng một số ngẫu nhiên cho bất kỳ cử tri nào có chức danh là "Councilmember".
DataFrame voter_df đã được định nghĩa và sẵn sàng cho bạn. Thư viện pyspark.sql.functions đã được import với bí danh F. Bạn có thể dùng F.rand() để tạo giá trị ngẫu nhiên.
Bài tập này là một phần của khóa học
Làm sạch dữ liệu với PySpark
Hướng dẫn bài tập
- Thêm một cột vào
voter_dftên làrandom_valvới kết quả của phương thứcF.rand()cho mọi cử tri có chức danh Councilmember. - Hiển thị một số hàng của DataFrame, lưu ý xem mệnh đề
.when()có hoạt động hay không.
Bài tập tương tác thực hành trực tiếp
Hãy thử làm bài tập này bằng cách hoàn thành đoạn mã mẫu này.
# 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.____