0
而不是给一个文件作为输入，我想给一个目录，其中可以包含任何没有文件。我想写成的方式我需要通过给出一个目录作为输入来修改地图中的常规wordcount程序
输入输出：
文件1个文件2文件3
输出：
文件1个文件2文件3
，而每个文件应该有它的字数在相应的文件中。要确定地图中使用哪个文件，我可以使用context.getInputSplit（）。但我怎么能让它以我想要的方式写输出。
A
回答
0
您可以使用映射器中的输入拆分来识别它们来自的文件，并将其与MultipleOutputs结合使用来写出来从您的reducer中分离文件。
但是，您需要将它来自的文件传递给reducer，因此您可能需要制作复合关键对象并编写自定义文件名和原始文件夹Partitioner和WritableComparator。参见：Hadoop - composite key
相关问题
- 1. 我需要一个wordcount的程序
- 2. 需要修改一个Groovy地图
- 3. 汇编程序给我不需要的字符作为输出?? asm
- 4. PHP的输出脚本需要修改
- 5. 程序为何跳过我需要输入
- 6. c程序的输出为零，但它需要来自用户的输入
- 7. rsync打印“跳过非常规文件”，看起来是一个常规目录
- 8. Maven - 你需要一个主要的项目来作为一个图书馆吗？
- 9. 控制台中的Tkinter“输入验证程序”需要通过输入
- 10. 我需要帮助来编写一个程序，该程序需要用户输入并使用堆栈反转。
- 11. 需要拼合一个目录，修改文件名。用bash？
- 12. 我需要创建一个程序，将通过文件目录来查找重复项
- 13. 我需要修改
- 14. 我需要一个JavaScript过程来颠倒下面的过程
- 15. 为什么需要通过getErrorStream（）来运行一个进程？
- 16. 需要脚本通过输入更改div背景..不工作
- 17. 把输入作为一个字符串，帮助修复主要，所以它只需要一个输入
- 18. 在一个webpack应用程序中，我需要问IntelliJ添加./app目录作为basePath进行导入
- 19. 我需要一个特定的输出
- 20. MapReduce WordCount程序 - 输出与输入文件相同
- 21. MasterPage稍作修改。我需要创建一个新的吗？
- 22. 修改LS输出到目录
- 23. 我需要使输出成为一行
- 24. 需要帮助修复我的项目输出
- 25. 程序未给出所需的输出
- 26. 另一个Linux命令输出（管道）作为我的C程序的输入
- 27. 需要帮助修改一个Shell脚本来改变CentOS上的IP地址
- 28. 我需要一个.bat来搜索特定文本的目录
- 29. 我如何修改主要方法来获取输入和从命令输出？
- 30. 需要修改KDEInit条目