在evalfunc中，您可以通过以下方式从hdfs获取文件：

FileSystem fs = FileSystem.get(UDFContext.getUDFContext().getJobConf());
in = fs.open(new Path(fileName));
BufferedReader br = new BufferedReader(new InputStreamReader(in));
....

您还可以考虑将文件放入分布式缓存，在这种情况下，您必须重写evalfunc类中的getcachefiles（）。
例如：

@Override
public List<String> getCacheFiles() {
  List<String> list = new ArrayList<String>(2);
  list.add("/cache/pig/wordlist1.txt#w1");
  list.add("/cache/pig/wordlist2.txt#w2");
  return list;
}

然后只需传递文件（w1和w2）的符号链接，就可以从每个工作节点的本地文件系统获取它们：

BufferedReader br = new BufferedReader(new FileReader(fileName));