我正在使用pyspark读取CSV文件。以下是我的简单代码。
from pyspark.sql.session import SparkSession
def predict_metrics():
session = SparkSession.builder.master('local').appName("PredictFacebookMetrics").getOrCreate()
dataframe = session.read().format('com.databricks.spark.csv')
.option('header', True)
.option('delimiter', ';')
.option('inferSchema', True)
.load(r'D:MFacebook_metrics_datadataset_Facebook.csv')
dataframe.printSchema()
dataframe.show(False)
if __name__=='__main__':
predict_metrics()
执行上述代码时,我会收到以下错误:
TypeError: 'DataFrameReader' object is not callable
该错误的解决方案是什么?
,如评论中所建议的它应该是session.read.format
而不是session.read().format
愚蠢的我!