Hive-UDF自定义函数-大小写转换Demo


pom.xml

<dependency>
    <groupId>org.apache.hive</groupId>
    <artifactId>hive-exec</artifactId>
</dependency>

Lower.java

public final class Lower extends UDF {
    public Text evaluate(final Text s){
        if(s==null){return null;}
        return new Text(s.toString().toLowerCase());
    }
}

测试

将代码打成 jar 包上传到服务器

add JAR /path/to/udf.jar

create temporary function tolowercase as 'cn.enjoy.hive.Lower'

select tolowercase("AAA");
select sid,tolowercase(sname),sex from person_p;

文章作者: 钱不寒
版权声明: 本博客所有文章除特別声明外,均采用 CC BY 4.0 许可协议。转载请注明来源 钱不寒 !
  目录