小编ish*_*sha的帖子

Pyspark 将 StructType 传递给 Schema 时出错

传递给架构方法时出现错误:类型错误:“StructType”对象不可调用。StructType下面是代码:

final_schema = StructType([StructField("id", StringType(), True)])
dataframe = sc.read.text('/path').schema(final_schema)
Run Code Online (Sandbox Code Playgroud)

数据为字符串类型,如下:

id
AO_01
AO_02
AO_03
Run Code Online (Sandbox Code Playgroud)

apache-spark-sql pyspark

4
推荐指数
1
解决办法
1万
查看次数

标签 统计

apache-spark-sql ×1

pyspark ×1