首先，在配置单元中创建输出。
然后，使用get_json_object（）函数从单列表中选择数据，并将该数据插入到最终的表中。请参阅get\u json\u object（）。

INSERT INTO table OutputTable 
SELECT 
    get_json_object(event_data,'$.callId') as callId, 
    get_json_object(event_data,'$.correlationId') as correlationId,
    get_json_object(event_data,'$.servicingDetail.offerAttributes.id') as servicingDetail_offerAttributes_id,
    get_json_object(event_data,'$.fulfiller.id') as fulfiller_id,
FROM SingleColumnTable;

第一次编辑-Pypark解决方案

将单列表读入dataframe（假设df name是dfsinglecolumneddata），然后应用下面的逻辑来获取每一列的数据。最后选择所需的列。

from pyspark.sql import Row
from collections import OrderedDict

def convert_to_row(d: dict) -> Row:
    return Row(**OrderedDict(sorted(d.items())))

dfSingleColumnedData.rdd.map(convert_to_row).toDF()