大数据 java hive udf函数的示例代码（手机号码脱敏）

<?xml version="1.0" encoding="UTF-8"?>

 4.0.0

 填写自己的组织名称
 udf
 1.0-SNAPSHOT
 
  UTF8
  
  2.6.0-cdh5.13.3
  1.1.0-cdh5.13.3
 

 
  
  
   Apache Hadoop
   Apache Hadoop
   https://repo1.maven.org/maven2/
  
  
  
   cloudera
   cloudera
   https://repository.cloudera.com/artifactory/cloudera-repos/
  
 

 
  
  
   org.apache.hadoop
   hadoop-common
   ${hadoop.version}
  
  
  
   org.apache.hive
   hive-exec
   ${hive.version}
  
 

 
  
   
    org.apache.maven.plugins
    maven-compiler-plugin
    
     1.8
     1.8
    
   
   
    maven-assembly-plugin
    
     
     
      
       
      
     
     
      jar-with-dependencies
     
    
    
     
      make-assembly
      package
      
       single
      
     
    
   
  
 

package 填写自己的组织名称;

import org.apache.hadoop.hive.ql.exec.Description;
import org.apache.hadoop.hive.ql.exec.UDF;

// 上传udf jar到集群 hdfs dfs -put udf-1.0-SNAPSHOT-jar-with-dependencies.jar /data/data_coe/data_asset/prod/db/tmp/udf/
// 修改文件权限 hdfs dfs -chmod -R 777 hdfs://idc-nn/data/data_coe/data_asset/prod/db/tmp/udf/
//注册udf函数 create function tmp.pul as '填写自己的组织名称.PhoneUnlookUdf' using jar 'hdfs://idc-nn/data/data_coe/data_asset/prod/db/tmp/udf/udf-1.0-SNAPSHOT-jar-with-dependencies.jar

public class PhoneUnlookUdf extends UDF {
//重写evaluate方法
 public String evaluate(String phone){
  if (phone.length() == 11){
   String res = phone.substring(0, 3) + "****" + phone.substring(7, phone.length());
   System.out.println(res);
   return res;
  } else {
   return phone;
  }

 }
}