我想将 pyspark.sql.dataframe.DataFrame
转换为 pyspark.rdd.RDD[String]
我将 DataFrame df
转换为 RDD data
:
data = df.rdd
type (data)
## pyspark.rdd.RDD
新的RDD data
包含了 Row
first = data.first()
type(first)
## pyspark.sql.types.Row
data.first()
Row(_c0=u'aaa', _c1=u'bbb', _c2=u'ccc', _c3=u'ddd')
我想把 Row
转换成 String
的列表,例如下面的示例:
u'aaa',u'bbb',u'ccc',u'ddd'
谢谢