有什么办法可以扁平化电光流媒体中的嵌套JSON吗？

本文介绍了有什么办法可以扁平化电光流媒体中的嵌套JSON吗？的处理方法，对大家解决问题具有一定的参考价值，需要的朋友们下面随着小编来一起学习吧！,我已经编写了一个数据集火花作业(批处理)代码来扁平化数据，运行正常，但当我尝试在火花流作业中使用相同的代码片段时，它抛出以下错误
必须使用WriteStream.start()；,执行具有流来源的查询
那么，有什么方法可以在流作业中展平嵌套的JSON吗？
样本输入嵌套JSON-,预期输出。
output after falttening,下面是代码片段。,Note代码位于scala&amp；我已使用Spark Structured Streaming 。,可以使用org.apache.spark.sql.functions.explode函数展平数组列。请检查以下代码。,这篇关于有什么办法可以扁平化电光流媒体中的嵌套JSON吗？的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，