如何编写hive udf

qgelzfjb  于 2021-05-29  发布在  Hadoop
关注(0)|答案(1)|浏览(413)

我对如何使用自定义项感到困惑。有没有可能用自定义项替换bash脚本下面的功能?


# !/bin/bash

 src_count_q="use db;select count(*) from config_table where table_nm="test_source";"
 src_count=$(hive -e $src_count_q)

 trg_count_q="use db;select count(*) from config_table where table_nm="test_target";"
 trg_count=$(hive -e $trg_count_q)

 if ["$src_count" = "trg_count"];
 then
   $(hive -e "use db;select * from test_target;")
 fi

请帮忙!!我见过如何反转字符串或更改大小写的自定义项,但我不知道如何为这种重用查询结果的条件情况编写配置单元自定义项。
有没有其他更好的方法来处理此类查询流?

lo8azlld

lo8azlld1#

根据我的说法,你可以使用hiveudfs在hive中启用一些sql函数,但是你不能用它们来放置plsql之类的东西。所以对于您的问题,您可以使用sparksql,这是我使用的一种更好的方法。

相关问题