2016-07-05 62 views
2

我有一個使用星火以下Python代碼:無法爲類型推斷模式:<type 'str'>

from pyspark.sql import Row 

def simulate(a, b, c): 
    dict = Row(a=a, b=b, c=c) 
    df = sqlContext.createDataFrame(dict) 
    return df 

df = simulate("a","b",10) 
df.collect() 

我創建一個對象,我想將它保存爲DataFrame

不過,我得到這個錯誤:

TypeError: Can not infer schema for type: <type 'str'> 

它發生在這條線:

df = sqlContext.createDataFrame(dict) 

我在做什麼錯?

回答

2

創建單個元素數據框是沒有意義的。如果你想讓它工作,儘管使用清單:df = sqlContext.createDataFrame([dict])