You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user@spark.apache.org by 965 <10...@qq.com> on 2018/11/30 14:39:16 UTC

回复:Java: pass parameters in spark sql query

Hi I think java's native grammer is not  support that ,you should do it by declaring   a  variable  with java ' way like 
int parameter = 100;
 spark.sql(" select * from table where parameter = "+parameter)





------------------ 原始邮件 ------------------
发件人: "Mann Du"<ma...@gmail.com>;
发送时间: 2018年11月29日(星期四) 上午7:55
收件人: "user"<us...@spark.apache.org>;

主题: Java: pass parameters in spark sql query



Hello there,

I am trying to  pass parameters in spark.sql query in Java code, the same as in this link
https://forums.databricks.com/questions/115/how-do-i-pass-parameters-to-my-sql-statements.html



The link suggested to use 's' before 'select' as - 
val param = 100
 spark.sql(s""" select * from table where parameter = $param """)


it works for scala and python, but it doesn't work for Java. I also tried .format() but failed as well. 


Does anyone know how to dynamically pass parameters in sql using Java? Greatly appreciate your help.


Best,


Mann