python - 类型错误 : 'DataFrameReader' object is not callable

Question

我正在使用 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:\M\Facebook_metrics_data\dataset_Facebook.csv')
    dataframe.printSchema()
    dataframe.show(False)

if __name__=='__main__':
    predict_metrics()

执行上面的代码后，我得到以下错误:

TypeError: 'DataFrameReader' 对象不可调用

这个错误的解决方案是什么？

Answer 1

正如评论中所建议的，它应该是 session.read.format 而不是 session.read().format

傻我!