获取错误: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发布于 2020-03-13 09:41:05
更改了对sc.read.schema(final_schema).text('/path')的调用,因为text(...)将返回一个dataframe实例,并需要在此之前设置模式。
https://stackoverflow.com/questions/60666735
复制相似问题