大佬教程收集整理的这篇文章主要介绍了调用 o168.showString 时出错。 org.apache.spark.sql.execution.datasources.SchemaColumnConvertNotSupportedException,大佬教程大佬觉得挺不错的,现在分享给大家,也给大家做个参考。
在编写镶木地板文件或在 AWS 胶水中使用 df.show() 时,出现以下错误。当我使用模式读取镶木地板文件时会发生这种情况。我正在使用以下函数读取它
def parquet_to_dataframe(LOCATIOn,scheR_718_11845@a):
csv_df = (
spark.read.option("header",TruE).scheR_718_11845@a(scheR_718_11845@a).parquet(LOCATIOn)
)
return csv_df
任何有关我哪里出错或应该修改什么的帮助将不胜感激。
在读取 parquet 文件时不需要指定架构。
下面的一段代码将显示数据
df = spark.read.parquet(LOCATIOn)
df.show(10,falsE)
如果您想将其转换为 CSV,则只需执行
df.write.csv(path=<LOCATIOn>,header='true')
以上一行将数据保存为 csv 文件。
如果您需要任何帮助,请告诉我。
以上是大佬教程为你收集整理的调用 o168.showString 时出错。 org.apache.spark.sql.execution.datasources.SchemaColumnConvertNotSupportedException全部内容,希望文章能够帮你解决调用 o168.showString 时出错。 org.apache.spark.sql.execution.datasources.SchemaColumnConvertNotSupportedException所遇到的程序开发问题。
如果觉得大佬教程网站内容还不错,欢迎将大佬教程推荐给程序员好友。
本图文内容来源于网友网络收集整理提供,作为学习参考使用,版权属于原作者。
如您有任何意见或建议可联系处理。小编QQ:384754419,请注明来意。