将RDD转换为DataFrame,再换回RDD再查询几行看看

sparkContext是针对RDD的读写,后面DataFrame用sparkSession
转换先得变成Row,Row是数据框的行对象,然后创建dataframe就行了
如果要查询,通过spark.sql,必须得注册成临时表才行
from pyspark.sql import Row
people = spark.sparkContext.textFile(“file:///文件目录”).map(lambda x:x.split(",")).map(lambda p:Row(name=p[0],age=int(p[1])))
schemap=spark.createDataFrame(people)
schemap.createOrReplace(TempView(“people”))#注意这里对象引用加引号了
peopleDF=spark.sql(“select name,age from people where age>20”)
peopleRDD=peopleDF.rdd.map(lambda p:“name:”+p.name+","+“age:”+str(p.age))
peopleRDD.foreach(print)

发布了25 篇原创文章 · 获赞 0 · 访问量 381

猜你喜欢

转载自blog.csdn.net/qq_45371603/article/details/104603909