将字符串列表转换为Python数据帧pyspark Python sparksq

Question

我有以下Python/Pyspark代码：

sql_command = ''' query ''''
df = spark.sql(sql_command)
ls_colnames = df.schema.names
ls_colnames
     ['id', 'level1', 'level2', 'level3', 'specify_facts']

cSchema = StructType([
    StructField("colname", StringType(), False)
  ])
df_colnames = spark.createDataFrame(dataset_array,schema=cSchema)

File "/opt/mapr/spark/spark-2.1.0/python/pyspark/sql/types.py", line 1366, in _verify_type raise TypeError("StructType can not accept object %r in type %s" % (obj, type(obj))) TypeError: StructType can not accept object 'id' in type class 'str'

我该怎么做才能得到colnames的spark对象？ `在

Answer 1

不知道我是否正确地理解了你的问题。但是如果您正在尝试基于给定列表创建一个数据帧，您可以使用下面的代码进行相同的操作。在

^{1}$

希望有帮助。在

谨致问候

尼拉吉