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)
我在做什麼錯?