Impala 中運行 Hive UDF

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

• 1.簡單的UDF函數過濾，判斷是否包含“好”字，返回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.創建函數

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

• 4.查看是否創建成功

[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.查詢結果

?

?

總結

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

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。