2016-07-26 16 views
2

次のコードは以前は私のために働いていましたが、もはや機能しませんでした。私はエラーを得た:pyspark AttributeError: 'DataFrame'オブジェクトに 'toDF'属性がありません

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() 
+0

あなたは何を達成しようとしていますか? – David

+0

データフレームに列名を割り当てます – user3610141

+0

[pysparkのデータフレーム列名を変更する方法](http://stackoverflow.com/questions/34077353/how-to-change-dataframe-column-names-in) -pyspark) – David

答えて

1

私はそれを考え出しました。スパークバージョンと関係があるように見えます。それは1.6と働いた

関連する問題