java - 如何在hadoop WordCount应用程序中获取所有标记词的文件名？

在hadoop的WordCount任务中，如何获取标记词的文件名并在context.write(new Test(filename)，one)中使用它？

最佳答案

可以使用以下Mapper类中的代码片段来检索文件名。

FileSplit fileSplit = (FileSplit)context.getInputSplit();
String filename = fileSplit.getPath().getName();