#1.获取DataFrame中数据的行数
print("1.利用SQL查询输出DataFrame中数据的行数:\n")
spark.sql("select count(1) as num from swimmers").show()
#2.利用where子句获取age=21的id,age
print("2.利用where子句获取age=21的id,age:\n")
spark.sql("select id,age from swimmers where age = 21").show()
#3.利用where子句获取DataFrame中eyeColor like 'b%'的所有字段信息
print("3.利用where子句获取DataFrame中eyeColor like 'b%'的所有字段信息:\n")
spark.sql("select * from swimmers where eyeColor like 'b%'").show()
sparksql查询_筛选_过滤
猜你喜欢
转载自blog.csdn.net/wj1298250240/article/details/103940318
今日推荐
周排行