2016-05-17 4 views
2

Ich habe folgende Spark SQL und ich möchte Variable übergeben. Wie geht das? Ich habe den folgenden Weg versucht.Spark SQL eine Variable übergeben

sqlContext.sql("SELECT count from mytable WHERE id=$id") 
+1

Können Sie nur [string Interpolation] (http: //docs.scala-lang.org/overviews/core/string-interpolation.html)? – chrisaycock

Antwort

4

Sie sind fast da gerade verpasst s :)

sqlContext.sql(s"SELECT count from mytable WHERE id=$id") 
0

Sie können wie eine Zeichenfolge in SQL-Anweisung übergeben unten

id = "1" 
query = "SELECT count from mytable WHERE id='{}'".format(id) 
sqlContext.sql(query) 
Verwandte Themen