我正在传递一个文件模式:
FileInputFormat.addInputPath(job, new Path("/path/to/file*"));
我想知道在作业运行完成后,如果成功的话,哪些文件与之匹配。
我试过:
job.getConfiguration().get("mapreduce.input.fileinputformat.inputdir")
但它的回报是一样的:
"/path/to/file*"
我想知道是否有一种方法可以获得匹配的路径,而不必创建另一个例程来扫描目录。
非常感谢你的启迪。
1条答案
按热度按时间bjp0bcyl1#
试试这个链接,它有几种方法可以在Map器中获得路径。但是,我相信这是在谈论更多的方法
如何在hadoop程序的Map器中获取输入文件名?