pyspark AttributeError：'DataFrame'對象沒有屬性'toDF'

Question

以下代碼在我以前工作過，但現在不再了。我得到的錯誤：

AttributeError: 'DataFrame' object has no attribute 'toDF'

if __name__ == "__main__": 
    sc = SparkContext(appName="test") 
    sqlContext = SQLContext(sc) 

    df = sqlContext.read.format('com.databricks.spark.csv').\ 
    options(header='false',delimiter=',',inferSchema='true').load('test') 

    ### rename columns 
    df = df.toDF('a','b','c') 
    ... 
    sc.stop() 

Answer 1

我想通了。看起來它與我們的火花版本有關。它與1.6