需要自定义类,然后继承UDF 然后在方法envluate()方法里面实现具体的业务逻辑,打包上传到linux(以免出错打包成RunningJar)
(1)add jar /udf/xxx.jar
(2)Create temporary function mytest as '包名.类名'
(3)显示UDF函数 show functions like mytest
(4)删除临时函数 drop temporaray function mytest;
(1)把jar包上传至hdfs目录 path
(2)Create function mytest as ‘包名.类名’using jar path/xxx.jar
手机扫一扫
移动阅读更方便
你可能感兴趣的文章