spark 學習筆記 dataframe注冊生成表


 DataFrame注冊成一張表格,如果通過CreateTempView這種方式來創建,那么該表格Session有效,如果通過CreateGlobalTempView來創建,那么該表格跨Session有效,但是SQL語句訪問該表格的時候需要加上前綴global_temp

 

dataframe 轉換為臨時表,執行sparksql

val df = spark.read.json(Path)
df.show()

 

//將dataframe 注冊成為一張臨時表
df.createOrReplaceTempView("persons")
spark.sql("select * from persons where age > 20 ").show()

 


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM