Impala 中運行 Hive UDF

場景：部分查詢需要快速返回，使用Impala進行快速、復(fù)雜的查詢

• 1.簡單的UDF函數(shù)過濾，判斷是否包含“好”字，返回boolean類型

import org.apache.hadoop.hive.ql.exec.UDF;/*** @ClassName: UdfTest* @Description: TODO * @author: Jast* @date: 2019年3月10日 上午11:30:20 */ public class UdfTest extends UDF {public boolean evaluate(String text){if(text.contains("好")) {return true;}else {return false;}} }

• 2.將jar包上傳到HDFS中

hdfs dfs -put /home/xxx/hive-udf.jar /user/hive/lib

• 3.創(chuàng)建函數(shù)

create function if not exists udftest(String) returns boolean location "/user/hive/lib/hive-udf.jar" SYMBOL="com.xxx.udftest";

• 4.查看是否創(chuàng)建成功

[hostname:21000] dw_xxxx> show functions; Query: show functions +-------------+----------------------+-------------+---------------+ | return type | signature | binary type | is persistent | +-------------+----------------------+-------------+---------------+ | BOOLEAN | udftest(STRING) | JAVA | false | +-------------+----------------------+-------------+---------------+ Fetched 1 row(s) in 0.01s

• 5.查詢結(jié)果

?

?

總結(jié)

以上是生活随笔為你收集整理的Impala UDF - Impala调用Hive UDF函数的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。