如何在已经存在的数据帧中添加json(dict数组)中的行?嗨,我已经有了一个数据帧: 包含所有列的df\u init: A|B|C|D 我收到一个json,比如: json=[{"A":"1","B":"2","C":"3"}, {"A":"1","B": ...2024-04-28 已阅读: n次
在spark执行器中使用配置单元SQLContext我通过卡夫卡得到了一个复杂的json消息。我需要从json中提取所需的字段并将它们存储在配置单元表中。我知道我不能在executors中使用spark驱动程序sqlContext。我想知道如何在执行者 ...2024-04-28 已阅读: n次