将PipelinedRDD转换为datafram我正在尝试将pyspark中的pipelinedRDD转换为数据帧。这是代码片段: newRDD = rdd.map(lambda row: Row(row.__fields__ + ["tag"]) ...2024-06-26 已阅读: n次