почему я не могу вернуть Dataframe для этого кода Scala

Question

def csvReader(readCsvdf:DataFrame):Dataframe= {

   val readCsvDf= spark.read
      .format("csv")
      .option("header", "true")
      .load("C:\\Users\\1591532\\Downloads\\xyz.csv").toDF()


}

Answer 1

В вашем коде вы присваиваете значение, которое возвращает unit.В scala возвращение - последняя строка, поэтому здесь указан тип единицы, а не df.

def csvReader(path: String)(implicit spark: SparkSession): Dataframe= {
   spark.read
      .format("csv")
      .option("header", "true")
      .load(path)
}