私はスパークのデータフレームを作成する標準的な "hello world"と思われるものを使用してデータフレームを作成しようとしています。助けて!上記のコードcreateDataFrame()が失敗した理由を理解できません
from pyspark.sql.types import *
schema = StructType([StructField("product", StringType(), True)])
l = [('foo')]
rdd = sc.parallelize(l)
df = sqlContext.createDataFrame(rdd, schema)
df.show()
エラー
ValueError: Unexpected tuple 'foo' with StructType`
下のコードをスロー基本的に私は完全に困惑していますストレートpyspark.sql moduleから持ち上げています。
[作成の可能性の重複Spark DataFrame。スキーマタイプを推論できません:](http://stackoverflow.com/questions/32742004/create-spark-dataframe-can-not-infer-schema-for-type-type-float) –