pyspark：使用对象属性

Question

排序PyhonRDD我有一个result RDD，这是使用pyspark.mllib.fpm

的result RDD看起来创建：

print(result) 
result.take(5) 

PythonRDD[32] at RDD at PythonRDD.scala:48 
Out[18]: 
[FreqSequence(sequence=[['John']], freq=18980), 
FreqSequence(sequence=[['Mary']], freq=106), 
FreqSequence(sequence=[['John-Mary']], freq=381), 
FreqSequence(sequence=[['John-Ann']], freq=158), 
FreqSequence(sequence=[['Ann']], freq=433)] 

我怎么排序上述result RDD基于freq属性？谢谢！

Answer 1

您可以使用keyfunc说法：

rdd.sortBy(lambda x: x.frequency)