无法推断类型的架构：<type 'str'>

Question

我有以下使用 Spark 的 Python 代码：

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

我正在创建一个Row 对象，我想将其保存为DataFrame。

但是，我收到此错误：

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

它出现在这一行：

df = sqlContext.createDataFrame(dict)

我做错了什么？

Answer 1

创建单元素数据框是没有意义的。如果您想让它在使用列表中正常工作：df = sqlContext.createDataFrame([dict])