欢迎投稿

今日深度:

Hive自定义函数,

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上,如下所示



www.htsjk.Com true http://www.htsjk.com/hive/34033.html NewsArticle 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 e...
相关文章
    暂无相关文章
评论暂时关闭