我怎样从一个自定义访问外部资源(数据库)蜂房的UDF,是什么凭据传递给UDF的最佳方式?
我试图通过设置来设置属性:
SET my.udf.credentials=...;
SELECT myUdf(someColumn) FROM someTable;
并通过HiveConf访问它们在GenericUDAFEvaluator的init方法,但它不能正常工作。 有什么建议么?
我怎样从一个自定义访问外部资源(数据库)蜂房的UDF,是什么凭据传递给UDF的最佳方式?
我试图通过设置来设置属性:
SET my.udf.credentials=...;
SELECT myUdf(someColumn) FROM someTable;
并通过HiveConf访问它们在GenericUDAFEvaluator的init方法,但它不能正常工作。 有什么建议么?
我希望你用蜂房0.11。
GenericUDAFEvaluator
类有该方法配置(MapredContext) 。 引用一位伟人:
与MapredContext另外设置GenericUDAFEvaluator初始化之前。 这仅称为MapRedTask的运行时间。
MapredContext
类有方法getJobConf 。
JobConf
类有方法获取 。
全部放在一起:
public void configure(MapredContext mapredContext) {
String credentials = mapredContext.getJobConf().get("my.udf.credentials");
}