Comments

Impala 添加和使用 UDF

Impala 支持 C++ 和 Java 编写的 UDF, 把对应的 so 或 jar 文件放到 HDFS,再注册一下就能使用。官方推荐使用 C++ 编写 UDF,相比 Java 的实现有 10 倍性能提升。Hive 有丰富的函数,可以添加到 Impala 里。

  • 首先在 HDFS 创建目录保存 UDF 文件,并把 Hive 的 jar 包上传进去
hdfs dfs -mkdir /user/hive/udfs

hdfs dfs -copyFromLocal /opt/cloudera/parcels/CDH/lib/hive/lib/hive-exec-1.1.0-cdh5.14.2.jar /user/hive/udfs/hive-builtins.jar
  • 进入 Impala 注册函数
CREATE DATABASE udfs;

CREATE FUNCTION udfs.f_get_json_object(STRING, STRING) RETURNS STRING LOCATION '/user/hive/udfs/hive-builtins.jar' SYMBOL='org.apache.hadoop.hive.ql.udf.UDFJson';

REFRESH FUNCTIONS udfs;

SHOW FUNCTIONS IN udfs;
  • 使用
SELECT id,
       udfs.f_get_json_object(user_info, '$.city') AS user_city
       user_info
FROM user
LIMIT 100
  • 删除
DROP FUNCTION IF EXISTS udfs.f_get_json_object(STRING, STRING)

References

欢迎关注我的公众号

Comments

getElementsByTagName('BODY')[0]).appendChild(s); }()); getElementsByTagName('BODY')[0]).appendChild(s); }()); getElementsByTagName('BODY')[0]).appendChild(s); }()); comments powered by Disqus ript">comments powered by Disqus.