當前位置：首頁 > 编程资源 > 编程问答 >内容正文

编程问答

hive中的UDAF的使用流程记载

發布時間：2023/12/31 编程问答 59 豆豆

生活随笔收集整理的這篇文章主要介紹了 hive中的UDAF的使用流程记载小編覺得挺不錯的,現在分享給大家,幫大家做個參考.

本文是對[1]的整理和復現。

以[2]中的例子三為準

zhong

注冊命令(hive/beeline中進行)	備注
add jar /home/appleyuchi/桌面/Flink_Code/FLINK讀寫各種數據源/Java/target/table_api-1.0-SNAPSHOT.jar;	指明自定義依賴包
create temporary function sum_test as 'UDAFSum_Sample';	依賴包中的類UDAFSum_Sample注冊為sum_test

hive命令

實驗結果

備注

use db1;

select sum_test(sales_info_new.sku_id) from sales_info_new;
?

+---------+
| ? _c0 ? |
+---------+
| 7165.0 ?|
+---------+
?

無

完整代碼:

https://gitee.com/appleyuchi/Flink_Code/blob/master/FLINK讀寫各種數據源/Java/src/main/java/UDAFSum_Sample.java

Reference:

[1]UDAF實現一個自定義的求和函數

[2]hive中操作struct與map三例

以上是生活随笔為你收集整理的hive中的UDAF的使用流程记载的全部內容，希望文章能夠幫你解決所遇到的問題。

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