<p>在创建数据帧之前,需要将字典包装到列表中:</p>
<pre><code>data = {'masterId': 2, 'name': 'name', 'description': 'xyz', 'signalTypeRefId': 4, 'unitOfMeasureRefId': 1, 'precision': 1, 'min': -125, 'max': 125, 'isDeprecated': False}
df = spark.createDataFrame([data])
df.show()
+-----------+------------+--------+---+----+----+---------+---------------+------------------+
|description|isDeprecated|masterId|max| min|name|precision|signalTypeRefId|unitOfMeasureRefId|
+-----------+------------+--------+---+----+----+---------+---------------+------------------+
| xyz| false| 2|125|-125|name| 1| 4| 1|
+-----------+------------+--------+---+----+----+---------+---------------+------------------+
</code></pre>
<p>或者,您可以将其转换为pandas数据帧,并从中创建Spark数据帧,但仍需要将字典包装到列表中:</p>
<pre><code>data = {'masterId': 2, 'name': 'name', 'description': 'xyz', 'signalTypeRefId': 4, 'unitOfMeasureRefId': 1, 'precision': 1, 'min': -125, 'max': 125, 'isDeprecated': False}
df = spark.createDataFrame(pd.DataFrame([data]))
df.show()
+--------+----+-----------+---------------+------------------+---------+----+---+------------+
|masterId|name|description|signalTypeRefId|unitOfMeasureRefId|precision| min|max|isDeprecated|
+--------+----+-----------+---------------+------------------+---------+----+---+------------+
| 2|name| xyz| 4| 1| 1|-125|125| false|
+--------+----+-----------+---------------+------------------+---------+----+---+------------+
</code></pre>