java - 从 Pig UDF 访问 HDFS

Question

我有一个 Pig Java UDF，我正在尝试访问文件系统以将一组文件读入 HashMap。但是，当我UDFContext.getUDFContext().getJobConf()在构造函数或稍后执行的方法体中调用时，我会得到null输出。从 EvalFunc 中获取作业配置的正确格式是什么？

Answer 1

你@MonitoredUDF有机会使用吗？就我而言，我能够通过从课堂上删除注释来解决这个问题。