運行從一個文件通過代碼通過sparkcontext或hivecontext（而不是通過命令行）蜂房查詢

運行該文件使用命令行我可以做到這一點hive -f 'filepath/filename' 但我必須通過代碼運行它（hivecontext或sparkcontext）任何人都可以幫助嗎？

單個查詢，我可以使用：

sparkContext.SQL('query')

但我不得不運行由具有查詢的文件。

2016-11-19 Siva kumar

加載文件作爲字符串？ – 2016-11-19 15:55:08

[Spark：如何從火狐外殼運行火花文件]的可能重複（http://stackoverflow.com/questions/27717379/spark-how-to-run-spark-file-from-spark-shell） –

可以使用星火/斯卡拉做到這一點：

queryFile = "path_of_your_file_queries" 
Source.fromFile(queryFile, "utf-8").getLines().foreach(query => sparksql.sql(query))

2017-09-07 09:45:34

回答