微信公众号搜"智元新知"关注
微信扫一扫可直接关注哦!

Spark SQL 里面的SQL外界参数传递

实例1: **spark sql单个参数传递**
```sql
args1=args['demo']

spark.sql("select id,name,'{0}' as args1 from user".format(args1))
```

> 说明:外界调用该脚本传递参数demo,将demo变量传递给args1变量,sql执行中的'{0}'代表着后面参数的第一个参数args1。

实例2:**spark sql多参数传递**
```sql
args1=args['demo1']
args2=args['demo2']

spark.sql("select id,name,'{0}' as args1, '{1}' as args2 from user where args2='{1}'".format(args1,args2))
```

> 说明:同上args1、args2是外界传递参数,sql执行的下标从0开始计数。依次顺序传递参数给前面中的'{}'变量。

版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 [email protected] 举报,一经查实,本站将立刻删除。

相关推荐