是否有可能配置一个蜂房的UDF?(Is it possible to configure a Hiv

2019-09-29 15:40发布

我怎样从一个自定义访问外部资源(数据库)蜂房的UDF,是什么凭据传递给UDF的最佳方式?

我试图通过设置来设置属性:

SET my.udf.credentials=...;
SELECT myUdf(someColumn) FROM someTable;

并通过HiveConf访问它们在GenericUDAFEvaluator的init方法,但它不能正常工作。 有什么建议么?

Answer 1:

我希望你用蜂房0.11。

GenericUDAFEvaluator类有该方法配置(MapredContext) 。 引用一位伟人:

与MapredContext另外设置GenericUDAFEvaluator初始化之前。 这仅称为MapRedTask的运行时间。

MapredContext类有方法getJobConf 。

JobConf类有方法获取 。

全部放在一起:

public void configure(MapredContext mapredContext) {
  String credentials = mapredContext.getJobConf().get("my.udf.credentials");
}


文章来源: Is it possible to configure a Hive's UDF?
标签: hive