Я хотел бы отсортировать K/V пары по значениям, а затем взять самые большие пять значений. Мне удалось сделать это с возвратом K/V с первой картой, сортировкой в порядке убывания с FALSE, а затем сменой key.value исходной (вторая карта), а затем взять первые 5, которые являются bigget, код:
RDD.map(lambda x:(x[1],x[0])).sortByKey(False).map(lambda x:(x[1],x[0])).take(5)
Я знаю, что на pySpark есть действие takeOrdered, но мне удалось сортировать значения (а не на клавише), я не знаю, как получить сортировку по убыванию:
RDD.takeOrdered(5,key = lambda x: x[1])
