是否可以使用结构化流解析/读取spark发布到kafka主题的多行json?
laawzig21#
如果您使用的是大于2.2的spark版本,那么下面的方法就可以了。
spark.read .option("multiLine", true).option("mode", "PERMISSIVE") .json("/path/to/user.json")
1条答案
按热度按时间laawzig21#
如果您使用的是大于2.2的spark版本,那么下面的方法就可以了。