如何把json格式的DataSet<String>转换成Map格式的DataSet<Map>

Question

使用StructuredStream从kafka获取实施流数据，每个数据都是json格式的String，得到DataSet<String>，现在要把这个数据存入到elasticsearch，使用   DataSet<Map> mapSet = stringSet.map（line ->jsonToMap（line）, Encoder.bean(Map.class))这种方式会报错，有没有其它更好的方式？

Answer 1

直接用fastjson的parseObject，然后得到map，岂不美哉

Answer 2

同意楼上说法，你完全可以在接收到数据之后，在进行map函数操作的时候直接把数据转换出来也可以