将StructType传递给架构的Pyspark错误

问题描述 投票:0回答:1

获取错误:TypeError:'StructType'对象不可调用,同时将StructType传递给架构方法。下面是代码:

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

数据是如下字符串类型:

id
AO_01
AO_02
AO_03
pyspark pyspark-sql pyspark-dataframes
1个回答
0
投票

将调用更改为sc.read.schema(final_schema).text('/path'),因为text(...)将返回数据框实例,并且需要在此之前设置架构。

© www.soinside.com 2019 - 2024. All rights reserved.