mapreduce Main方法中如何能读取到资源文件?
用job.getConfResourceAsInputStream(file); 报这个异常Configuration - x1.xml not found
现在需要在进入Mapper之前就能把资源文件内容就给读出来
MR 代码的运行分两部分,Main 函数运行在本地,用于向 ODPS 提交作业;Mapper/Reducer 运行在 ODPS 集群内。Job 上的这些接口是集群内的时候才有效。
要在 Main 函数里访问 Resource,直接用 odps-sdk-core 里面的 api 就好了。大概是这样:
Odps odps = SessionState.get().getOdps();
InputStream is = odps.resources().getResourceAsStream(resourceName);
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。