欧美一区二区三区老妇人-欧美做爰猛烈大尺度电-99久久夜色精品国产亚洲a-亚洲福利视频一区二区

Hive中如何配置與編寫自定義UDF函數(shù)

小編給大家分享一下Hive中如何配置與編寫自定義UDF函數(shù),相信大部分人都還不怎么了解,因此分享這篇文章給大家參考一下,希望大家閱讀完這篇文章后大有收獲,下面讓我們一起去了解一下吧!

創(chuàng)新互聯(lián)建站主營太康網(wǎng)站建設(shè)的網(wǎng)絡(luò)公司,主營網(wǎng)站建設(shè)方案,app軟件定制開發(fā),太康h5成都小程序開發(fā)搭建,太康網(wǎng)站營銷推廣歡迎太康等地區(qū)企業(yè)咨詢

環(huán)境介紹:CentOS7+hive-1.1.0-cdh6.7.0+IntelliJ IDEA+Maven3.3.9
1、創(chuàng)建工程
   打開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

點擊(此處)折疊或打開

  1. <properties>

  2.     <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>

  3.     <!-- hadoop、hive版本信息 -->

  4.     <hadoop.version>2.6.0-cdh6.7.0</hadoop.version>

  5.     <hive.version>1.1.0-cdh6.7.0</hive.version>

  6.   </properties>

  7.     <!-- hadoop依賴 -->

  8.     <dependency>

  9.       <groupId>org.apache.hadoop</groupId>

  10.       <artifactId>hadoop-common</artifactId>

  11.       <version>${hadoop.version}</version>

  12.     </dependency>

  13.     <!-- hive依賴 -->

  14.     <dependency>

  15.       <groupId>org.apache.hive</groupId>

  16.       <artifactId>hive-exec</artifactId>

  17.       <version>${hive.version}</version>

  18.     </dependency>

  19.   </dependencies>

  20.   

  21.   <!-- cdn資源倉庫 -->

  22.   <repositories>

  23.     <repository>

  24.       <id>cloudera</id>

  25.       <url>https://repository.cloudera.com/artifactory/cloudera-repos/</url>

  26.     </repository>

  27.   </repositories>

  2.2、在<repository></repository>中修改內(nèi)容如下:

點擊(此處)折疊或打開

  1. <dependency>

  2.       <groupId>junit</groupId>

  3.       <artifactId>junit</artifactId>

  4.       <version>4.10</version>

  5.       <scope>test</scope>

  6.     </dependency>

3、創(chuàng)建類,并編寫一個UDF HelloUDF.java,代碼如下:

點擊(此處)折疊或打開

  1. package org.apache.hadoop.hive.ql.udf;

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

  3. import org.apache.hadoop.io.Text;

  4. public class HelloUDF extends UDF {

  5.     public Text evaluate(Text input) {

  6.         return new Text("Hello:" + input);

  7.     }

  8.     public static void main(String args[]){

  9.         HelloUDF helloUDF = new HelloUDF();

  10.         Text rs = helloUDF.evaluate(new Text("zhangsan"));

  11.         System.out.println(rs.toString());

  12.     }

  13. }

4、測試UDF類,在上又鍵選擇Run 'HelloUDF.main()'

5、打包:
   在IDEA菜單中選擇view-->Tool Windows-->Maven Projects,然后在Maven Projects窗口中選擇【工程名】-->Lifecycle-->package,在package中右鍵選擇Run Maven Build開始打包
   執(zhí)行成功后在日志中找:
     [INFO] Building jar: D:\software\ruozedata_workspace\basic02-hive\target\hive-1.0.jar

以上是“Hive中如何配置與編寫自定義UDF函數(shù)”這篇文章的所有內(nèi)容,感謝各位的閱讀!相信大家都有了一定的了解,希望分享的內(nèi)容對大家有所幫助,如果還想學習更多知識,歡迎關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道!

網(wǎng)頁題目:Hive中如何配置與編寫自定義UDF函數(shù)
地址分享:http://chinadenli.net/article6/pigiog.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián),為您提供全網(wǎng)營銷推廣網(wǎng)站維護外貿(mào)建站小程序開發(fā)移動網(wǎng)站建設(shè)網(wǎng)站營銷

廣告

聲明:本網(wǎng)站發(fā)布的內(nèi)容(圖片、視頻和文字)以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主,如果涉及侵權(quán)請盡快告知,我們將會在第一時間刪除。文章觀點不代表本網(wǎng)站立場,如需處理請聯(lián)系客服。電話:028-86922220;郵箱:631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載,或轉(zhuǎn)載時需注明來源: 創(chuàng)新互聯(lián)

網(wǎng)站建設(shè)網(wǎng)站維護公司