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")
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")
Sie sind fast da gerade verpasst s
:)
sqlContext.sql(s"SELECT count from mytable WHERE id=$id")
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)
Können Sie nur [string Interpolation] (http: //docs.scala-lang.org/overviews/core/string-interpolation.html)? – chrisaycock