sortByKey і collect

Часто корисно відсортувати парний RDD за ключем (наприклад, під час підрахунку слів, який ви побачите далі в розділі). У цій вправі ви відсортуєте парний RDD Rdd_Reduced, який ви створили у попередній вправі, у спадному порядку та виведете підсумковий результат.

Пам'ятайте: у вашому середовищі вже доступні SparkContext sc і Rdd_Reduced.

Ця вправа є частиною курсу

Основи Big Data з PySpark

Переглянути курс

Інструкції до вправи

Відсортуйте RDD Rdd_Reduced за ключем у спадному порядку.
Зберіть вміст і проітератуйте, щоб надрукувати результат.

Інтерактивна практична вправа

Спробуйте виконати цю вправу, доповнивши цей зразок коду.

# Sort the reduced RDD with the key by descending order
Rdd_Reduced_Sort = Rdd_Reduced.____(ascending=False)

# Iterate over the result and retrieve all the elements of the RDD
for num in Rdd_Reduced_Sort.____():
  print("Key {} has {} Counts".format(____, num[1]))

Редагувати та запускати код