sqldata = hiveSql.sql("""
SELECT name,age from DB
tabel_df = pd.DataFrame(data=sqldata.collect())
tabel_df.to_csv('resultRDD.csv')
如代码所示,我的CSV如下所示:
tom 16
jack 18
实际上,我需要CSV,如下所示
name age
tom 16
jack 18
发布于 2019-12-21 12:10:48
只需创建一个列名列表:
table_df = pd.Dataframe(data=sqldata.collect())