开发者社区> 问答> 正文

Spark程序中使用SQL语句查询创建的临时表的方法是什么?

Spark程序中使用SQL语句查询创建的临时表的方法是什么?

展开
收起
游客qzzytmszf3zhq 2021-12-09 20:15:58 732 0
1 条回答
写回答
取消 提交回答
  • 、注意这里的表不是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]
    
    ……
    
    
    
    2021-12-09 20:16:19
    赞同 展开评论 打赏
问答排行榜
最热
最新

相关电子书

更多
SQL Server 2017 立即下载
GeoMesa on Spark SQL 立即下载
原生SQL on Hadoop引擎- Apache HAWQ 2.x最新技术解密malili 立即下载