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