for(FileStatus status : status_list) { FileInputFormat.addInputPath(job5, status.getPath()); }
我想知道我在输入路径中添加了目录文件。现在，如何在hadoopMap中使用？
brjng4g31#
你需要使用 MultipleInputs 类而不是 FileInputFormat . 框架工作将负责为Map器的每个文件生成键、值对。
MultipleInputs
FileInputFormat
1条答案
按热度按时间brjng4g31#
你需要使用
MultipleInputs类而不是FileInputFormat. 框架工作将负责为Map器的每个文件生成键、值对。