小編給大家分享一下Hive中如何配置與編寫(xiě)自定義UDF函數(shù),相信大部分人都還不怎么了解,因此分享這篇文章給大家參考一下,希望大家閱讀完這篇文章后大有收獲,下面讓我們一起去了解一下吧!
創(chuàng)新互聯(lián)建站主營(yíng)太康網(wǎng)站建設(shè)的網(wǎng)絡(luò)公司,主營(yíng)網(wǎng)站建設(shè)方案,app軟件定制開(kāi)發(fā),太康h5成都小程序開(kāi)發(fā)搭建,太康網(wǎng)站營(yíng)銷推廣歡迎太康等地區(qū)企業(yè)咨詢
環(huán)境介紹:CentOS7+hive-1.1.0-cdh6.7.0+IntelliJ IDEA+Maven3.3.9
1、創(chuàng)建工程
打開(kāi)IntelliJ IDEA
File-->New-->Project...-->Maven選擇Create from archetye-->org.apache.maven.archety:maven-archetype-quitkstart
2、配置
2.1、增加內(nèi)容如下:
在工程中找到pom.xml文件中hadoop-common 、hive-exec 、hive-jdbc
點(diǎn)擊(此處)折疊或打開(kāi)
2.2、在
點(diǎn)擊(此處)折疊或打開(kāi)
3、創(chuàng)建類,并編寫(xiě)一個(gè)UDF HelloUDF.java,代碼如下:
點(diǎn)擊(此處)折疊或打開(kāi)
package org.apache.hadoop.hive.ql.udf;
import org.apache.hadoop.hive.ql.exec.UDF;
import org.apache.hadoop.io.Text;
public class HelloUDF extends UDF {
public Text evaluate(Text input) {
return new Text("Hello:" + input);
}
public static void main(String args[]){
HelloUDF helloUDF = new HelloUDF();
Text rs = helloUDF.evaluate(new Text("zhangsan"));
System.out.println(rs.toString());
}
}
4、測(cè)試UDF類,在上又鍵選擇Run 'HelloUDF.main()'
5、打包:
在IDEA菜單中選擇view-->Tool Windows-->Maven Projects,然后在Maven Projects窗口中選擇【工程名】-->Lifecycle-->package,在package中右鍵選擇Run Maven Build開(kāi)始打包
執(zhí)行成功后在日志中找:
[INFO] Building jar: D:\software\ruozedata_workspace\basic02-hive\target\hive-1.0.jar
以上是“Hive中如何配置與編寫(xiě)自定義UDF函數(shù)”這篇文章的所有內(nèi)容,感謝各位的閱讀!相信大家都有了一定的了解,希望分享的內(nèi)容對(duì)大家有所幫助,如果還想學(xué)習(xí)更多知識(shí),歡迎關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道!