最近在项目里面需要从kafka推送的数据读取数据,spark streaming处理,由于推过来的是Json字符串,需要转换成dataFrame做进一步处理,但是Json字符串字段很多,而且还不固定;我想转换代码如下:最近在项目里面需要从kafka推送的数据读取数据,spark streaming处理,由于推过来的是
最近在项目里面需要从kafka推送的数据读取数据,spark streaming处理,由于推过来的是Json字符串,需要转换成dataFrame做进一步处理,但是Json字符串字段很多,而且还不固定;我想转换代码如下:最近在项目里面需要从kafka推送的数据读取数据,spark streaming处理,由于推过来的是