Spark程序中使用SQL语句查询创建的临时表的方法是什么?
、注意这里的表不是Hive里面的表,而是一个RDD:
scala> val results = spark.sql("SELECT * FROM yahoo_stocks_temp")
scala> results.map(t => "Stock Entry: " +t.toString).collect().foreach(println)
……
Stock Entry:[1996-05-06,32.50008,32.50008,29.37504,30.12504,8214400,1.25521]
Stock Entry: [1996-05-03,32.25,32.50008,31.24992,31.99992,6116800,1.33333]
Stock Entry:[1996-05-02,31.5,33.25008,31.5,32.87496,9731200,1.36979]
Stock Entry:[1996-05-01,30.25008,31.75008,30.0,31.62504,4881600,1.31771]
Stock Entry: [1996-04-30,31.24992,31.5,29.50008,29.74992,5003200,1.23958]
……
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。