hive使用hadoop的分布式文件系统(hive是基于hadoop的一个)

maven坐标2.自定义函数3.导出jar包4.上传到服务器hive/lib下并且重命名5.使用函数

    4.0.0

    cn.itcast
    day08_hive_udf
    1.0-SNAPSHOT
    jar
    
        
            org.apache.hadoop
            hadoop-common
            3.3.0
        
        
            org.apache.hive
            hive-exec
            3.0.0
        
    
    
        
            
            
                org.apache.maven.plugins
                maven-compiler-plugin
                3.1
                
                    1.8
                    1.8
                    UTF-8
                
            
            
                org.apache.maven.plugins
                maven-shade-plugin
                3.1.1
                
                    
                        package
                        
                            shade
                        
                        
                            
                                true
                            
                        
                    
                
            
        
    

package cn.itcast.udf;

import org.apache.hadoop.hive.ql.exec.UDF;
import org.apache.hadoop.io.Text;

public class MyUdf extends UDF {
    public Text evaluate(final Text line){
        if(line.toString()!=null&& !line.toString().equals("")){
            String str = line.toString().substring(0, 1).toUpperCase()+ line.toString().substring(1);
            return new Text(str);

        }
        return new Text("");
    }
}

/export/servers/apache-hive-3.0.0-bin/lib

# 添加jar包
hive> add jar /export/servers/apache-hive-3.0.0-bin/lib/my_upper.jar;
# 创建临时函数
hive> create temporary function my_upper as 'cn.itcast.udf.MyUdf';
#执行函数
hive> my_upper('abc');