from pyspark import SparkContext, SparkConf, sql from pyspark.sql import Row text_file = sc.textFile('/FileStore/tables/data.txt').show()
sd2nnvve1#
sc.textFile 不返回Dataframerdd没有show（）您可以collect（）或take（10）返回可以打印的列表
sc.textFile
dohp0rv52#
或者，使用 spark.read.text('/FileStore/tables/data.txt').show() ，在哪里 spark.read.text 返回一个可以 .show() 预计起飞时间。
spark.read.text('/FileStore/tables/data.txt').show()
spark.read.text
.show()
2条答案
按热度按时间sd2nnvve1#
sc.textFile不返回Dataframerdd没有show（）
您可以collect（）或take（10）返回可以打印的列表
dohp0rv52#
或者，使用
spark.read.text('/FileStore/tables/data.txt').show()，在哪里spark.read.text返回一个可以.show()预计起飞时间。