类型错误: 'DataFrameReader'对象不可调用



我正在使用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

愚蠢的我!

相关内容

  • 没有找到相关文章

最新更新