账号密码登录
微信安全登录
微信扫描二维码登录

登录后绑定QQ、微信即可实现信息互通

手机验证码登录
找回密码返回
邮箱找回 手机找回
注册账号返回
其他登录方式
分享
  • 收藏
    X
    sparkSQL中的UDF是否可以使用查询语句传参
    42
    0

    使用sparkSQL写过一个UDF,根据业绩计算提成,但是现在需求变了,根据职位和部门确定提成比例,下面举个例子

    spark.udf.register("mmyjtc", (yj: Float) => {
      (yj) match {
        case v if (v <= 6000) => {
          v * 0.10
        }
        case v if (v > 6000 && v <= 10000) => {
          v * 0.13
        }
        case v if (v > 10000 && v <= 20000) => {
          v * 0.20
        }
        case v => -1.0
      }
    })

    这是以前的UDF,现在里面的(0,6000],(6000,10000],(10000,20000]这几个区间的上下界都需要通过SQL查询才能得到,而且提成比例0.10,0.13,0.20也需要通过SQL查询才能得到,UDF还能用吗?或者说有没有什么替代方案?

    0
    打赏
    收藏
    点击回答
        全部回答
    • 0
    更多回答
    扫一扫访问手机版
    • 回到顶部
    • 回到顶部