使用StructuredStream從kafka獲取實施流資料,每個資料都是json格式的String,得到DataSet<String>,現在要把這個資料存入到elasticsearch,使用 DataSet<Map> mapSet = stringSet.map(line ->jsonToMap(line), Encoder.bean(Map.class))這種方式會報錯,有沒有其它更好的方式?
uj5u.com熱心網友回復:
直接用fastjson的parseObject,然后得到map,豈不美哉uj5u.com熱心網友回復:
同意樓上說法,你完全可以在接收到資料之后,在進行map函式操作的時候直接把資料轉換出來也可以轉載請註明出處,本文鏈接:https://www.uj5u.com/qita/45829.html
標籤:Spark
