标签:efault 引擎 并且 对象 数据 查询 注意 分布式 pat
{"name":"Michael"} {"name":"Andy", "age":30} {"name":"Justin", "age":19}
val path ="/root/temp/people.json"
val peopleDF = spark.read.json(path)
peopleDF.printSchema()
peopleDF.createOrReplaceTempView("people")
spark.sql("SELECT name FROM people WHERE age=19").show
标签:efault 引擎 并且 对象 数据 查询 注意 分布式 pat
原文地址:https://www.cnblogs.com/collen7788/p/12636672.html