博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
自定义udf添加一列
阅读量:6958 次
发布时间:2019-06-27

本文共 638 字,大约阅读时间需要 2 分钟。

//创建得分窗口字典    var dict= new mutable.HashMap[Double, Int]()    for (i <- 0 to result_Score.length-1 ){      dict.put(result_Score(i),i+1)    }    //自定义Udf函数 添加一列    sparkHiveSession.udf.register("getWindow", (ss11: Double) => {      val winno:Int = dict(ss11)      winno    })    map (k -> v)    map类型传进来一个k,获取v  如果这个k本身的值,与一个表中的值相等,就可以获得这个map的v表ss33445566map33->144->255->377->4                                               k本身的值sparkHiveSession.udf.register("getWindow", (ss11: Double) => {      val winno:Int = dict(ss11)      winno   返回v的值    })select getWindow(ss)from 表show:1234

 

转载于:https://www.cnblogs.com/Bread-Wang/p/9929065.html

你可能感兴趣的文章
排除网络故障的十大真理
查看>>
辉瑞健康药物部联手易传媒 打造大数据管理平台
查看>>
CIO们从云中学到的那些经验教训
查看>>
混合云和多云管理不再难:基础架构即代码来帮忙
查看>>
大数据能否解决城市所面临的环境问题
查看>>
数据库安全需要遵循的8项最佳实践
查看>>
关于HTTP推送的一些问题
查看>>
Spring IoC 学习(2)
查看>>
综合布线系统的设计分析
查看>>
论金融机构采用CDP容灾备份的意义
查看>>
Java性能调优工程的几点建议
查看>>
DI的力量,2017 UBDC全域大数据峰会即将开启
查看>>
数据中心的那些未来技术
查看>>
如何善用产品设计的三个层级
查看>>
如何在Amazon AWS上设置一台Linux服务器
查看>>
网站优化遇到死链怎么合理的处理?
查看>>
全球智慧城市进入快速发展阶段
查看>>
AI 黑客会大规模进军网络安全领域吗?为时尚早,因为太贵了
查看>>
科通芯城康敬伟:不照抄别人美国也没这模式
查看>>
每个平安城市的背后,都需要一个默默付出的“她”!
查看>>