?

概述

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

環境

組件	版本
Hadoop	3.1.2
Zookeeper	3.6.0
Mysql	8.0.22-0ubuntu0.20.04.2
Hive	2.3.7

Hive準備工作

以[2]中的例子三為準

?

zhong

注冊UDAF流程

注冊命令(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

?

使用GenericUDF流程

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的使用流程记载的全部內容，希望文章能夠幫你解決所遇到的問題。

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