r-r Hipe mapreduce获取正在处理的文件名



我正在用RHipe将一个目录发送到我的mapreduce作业中。有没有办法在映射器中获取正在处理的当前文件?我想把它作为我的密钥输出。非常感谢。

map <- expression({
   fileName <- "testing123" // ?????
     .....
    rhcollect(fileName, value)
})
z <- rhmr(map=map,reduce=NULL, inout=c("text", "text")
      ,ifolder=directoryName
      ,ofolder=outDirectory)

filename<-Sys.getenv("mapred.input.file")

是解决方案

相关内容

  • 没有找到相关文章

最新更新