-
结果为:
指定列名:
rdd = sc.parallelize([('Alice', 1)])
spark_session.createDataFrame(rdd, ['name', 'age']).collect()
结果为:
[Row(name=u'Alice', age=1)]
-
结果为:
[Row(name=u'Alice', age=1)]
-
结果为:
[Row(name=u'Alice', age=1)]
如果只有一列,则字符串
schema
为:rdd = sc.parallelize([1])
spark_session.createDataFrame(rdd, "int").collect()
结果为:
[Row(value=1)]