Spark SQLのwhere節を変数としてクエリに渡すにはどうすればいいですか？

Question

サンプル表：

+---------------------------------------------------------++------+ 
    |     Name_Age        || ID | 
    +---------------------------------------------------------++------+ 
    |"SUBHAJIT SEN":28,"BINOY MONDAL":26,"SHANTANU DUTTA":35 || 15 | 
    |"GOBINATHAN SP":35,"HARSH GUPTA":27,"RAHUL ANAND":26  || 16 | 
    +---------------------------------------------------------++------+ 

クエリに変数としてWHERE句を渡す方法は？

希望のクエリはSelect Name_Age from table where ID=15です。ここで変数はID = 15です。

Answer 1

データがすでに（ハイブテーブルまたはDataFrameにregisterTempTableを呼び出した後）テーブルとして登録されている場合は、SQLContext.sqlを使用することができます。

val whereClause: String = "ID=15" 
sqlContext.sql("Select Name_Age from table where " + whereClause) 

あなたが照会するdf: DataFrameオブジェクトがある場合：

を

// using a string filter: 
df.filter(whereClause).select("Name_Age") 

Answer 2

次のコードは、あなたの答えを得ることができます。

spark.sql("""Select Name_Age from table where ID='15'""")