Hive自定义函数,
首先在上一节创建的工程中添加如下类
package com.txr.udf;
import org.apache.hadoop.hive.ql.exec.UDF;
import org.apache.hadoop.io.Text;
/**
* Created by zj-db0236 on 2017/6/27.
*/
public class ConcatString extends UDF{
public Text evaluate(Text a, Text b){
return new Text(a.toString()+"*****"+b.toString());
}
}
然后将此包进行打打成jar包,上传到hive上,如下所示
本站文章为和通数据库网友分享或者投稿,欢迎任何形式的转载,但请务必注明出处.
同时文章内容如有侵犯了您的权益,请联系QQ:970679559,我们会在尽快处理。