在 Pail Tap Hadoop 作业中为输入指定多个文件夹

Question

我正在使用 Cascalog API 运行 hadoop mapreduce 作业。我想使用多个输入文件夹来处理 map reduce 作业。

我在 HDFS rooPath/Folder_1 和 rootPath/Folder_2 中有两个文件夹，其中包含要在作业中处理的文件。

我通过 Pail Tap 功能为工作提供输入文件夹：

new PailTap(rootPath + "Folder_1",
            JcascalogUtils.getPailTapOptions());

我可以为同一个工作分配多个文件夹吗？

我可以给一个正则表达式 fodler Path 像 rootPath+*/ 这样它会处理 rootPath 文件夹中的所有文件夹。

感谢您的帮助:)

Answer 1

您可以像这样使用 MultiSourceTap：

dataSource = new MultiSourceTap( 
              new PailTap(rootPath + "Folder_1",JcascalogUtils.getPailTapOptions()),
              new PailTap(rootPath + "Folder_2",JcascalogUtils.getPailTapOptions())
             );

或使用 GlobHfs

dataSource = new GlobHfs(new PailTap(rootPath,JcascalogUtils.getPailTapOptions()).getScheme() , rootPath + "*");