Oozie中的MapReduce作业可以从文件中读取吗？

Question

当在Oozie中创建工作流时，我有了第一个java步骤，它生成一个文件，其中包含下一步所需的文件列表(映射-约简)。我怎样才能用那个文件给地图减少作业呢？

我知道我可以在java步骤的捕获输出框中打勾，然后在map中使用mapred.input.dir -还原步骤来使用捕获的输出作为输入。但我想把自己从这件事中解脱出来。

为了记录在案，我的文件的内容看起来如下：

/data/kafka/4/camus/DATA.TRADE.ORDERHISTORY/daily/2015/07/18，/data/kafka/4/camus/DATA.TRADE.ORDERHISTORY/daily/2015/07/19，/data/kafka/4/camus/DATA.TRADE.ORDERHISTORY/daily/2015/07/20，/data/kafka/4/camus/DATA.TRADE.ORDERHISTORY/daily/2015/07/21，/data/kafka/4/camus/DATA.TRADE.ORDERHISTORY/daily/2015/07/22，/data/kafka/4/camus/DATA.TRADE.ORDERHISTORY/daily/2015/07/23，/data/kafka/4/camus/DATA.TRADE.ORDERHISTORY/daily/2015/07/24，/data/kafka/4/camus/DATA.TRADE.ORDERHISTORY/daily/2015/07/25，/data/kafka/4/camus/DATA.TRADE.ORDERHISTORY/daily/2015/07/26，/data/kafka/4/camus/DATA.TRADE.ORDERHISTORY/daily/2015/07/27，/data/kafka/4/camus/DATA.TRADE.ORDERHISTORY/daily/2015/07/28

Answer 1

要将该文件用作输入文件还是参数文件？？

在第二个案例中，

• 激活初始操作的选项
• 输出类似于“medi.file=/a/b/c/z.txt”的内容
• 在下一个操作中，使用适当的EL函数检索文件名，并将其作为或传递 ${wf:actionData("InitialActionName")"param.file"}
• 然后使用几行Java打开HDFS文件，并在执行实际的Map或减少工作之前，对内容做任何应该做的事情