磚

和pyspark相同- df = spark.table df = df(“訂單”)。withColumn(“項目”,from_json (df (“item_order_details”),“itemid字符串,itemname字符串”))df = df。選擇(“order_id”、“項目。itemid”、“items.itemname”)

嗨,你必須從單一列提取itemID和itemName item_order_detail——你可以利用from_json函數。我希望代碼幫助,選擇order_id, from_json (item_order_details itemid字符串,itemname字符串”)項目…

當你談論的是不同的模式,或許schemaevolutionmode, infercolumntypes,或者schemahints可能幫助嗎? ?看看這個https://youtu——32分鍾開始。/ 8 a38fv9cpd8希望它幫助,讓知道你如果你能解決它。