SQL文で使用されるパラメータを使用してSpark SQLアプリケーションを送信するにはどうすればよいですか？

Question

複数のSQL文を持つScalaファイルを作成したいと思います。各文にはパラメータがほとんどありません。シェルファイルを使ってプログラムで実行/実行したいと思います。

import org.apache.spark.sql.hive.HiveContext; 
val sqlContext = new HiveContext(sc); 
val total=sqlContext.sql(s"select sum(amount) from table1 where location=$loc_var"); 

Answer 1

scoptをコマンドライン引数の処理に使用して、Scalaアプリケーションで使用します。 loc_var。

Answer 2

あなたの質問が正しく理解できれば、文字列連結を使用して入力引数を追加できます。

//Capture input argument inside scala file 
val loc_var = args(0) 

val total=sqlContext.sql("select sum(amount) from table1 where location='"+loc_var+"'");