<p>您可以将订单拆分添加为</p>
<pre><code>df4 = final_df.withColumn('orderSplits',f.array(f.struct(*final_df.columns)))
df4.printSchema()
root
| aggregatedOrderId: string (nullable = true)
| totalOrderQuantity: string (nullable = true)
| ETA: string (nullable = true)
| Quantity: string (nullable = true)
| orderSplits: array (nullable = false)
| | element: struct (containsNull = false)
| | | aggregatedOrderId: string (nullable = true)
| | | totalOrderQuantity: string (nullable = true)
| | | ETA: string (nullable = true)
| | | Quantity: string (nullable = true)
df4.show()
+ -+ + -+ + -+
|aggregatedOrderId|totalOrderQuantity|ETA |Quantity|orderSplits |
+ -+ + -+ + -+
|abc |10 | |10 |[[abc, 10, , 10]] |
|xyz |20 | | |[[xyz, 20, , ]] |
|xyz.1 |null |08/01|10 |[[xyz.1,, 08/01, 10]]|
|xyz.2 |null |08/25|10 |[[xyz.2,, 08/25, 10]]|
+ -+ + -+ + -+
</code></pre>
<p>希望能有帮助</p>