Wie konvertiert man MapPartitionsRDD in einen Datenrahmen?

Question

Ich habe ein MapPartitionsRDD zurückgekehrt aus:

from pyspark.mllib.feature import Normalizer 
normalizer = Normalizer() 
rating = normalizer.transform(ratingRDD) 
print(rating) 

> MapPartitionsRDD[239] at mapPartitions at PythonMLLibAPI.scala:1522 

Wie kann ich dies zu einem Datenrahmen konvertieren?

Answer 1

Versuchen:

rating.map(lambda x: (x,)).toDF()