3.1 从列表创建
未指定列名:
l = [('Alice', 1)]
spark_session.createDataFrame(l).collect()
结果为:
[Row(_1=u'Alice', _2=1)] #自动分配列名
指定列名:
l = [('Alice', 1)]
spark_session.createDataFrame(l, ['name', 'age']).collect()
结果为:
[Row(name=u'Alice', age=1)]
通过字典指定列名:
d = [{'name': 'Alice', 'age': 1}]
spark_session.createDataFrame(d).collect()
结果为:
[Row(age=1, name=u'Alice')]