public Path getInputFileForWrite ( TaskID mapId , TaskAttemptID reduceTaskId , long size ) throws IOException { // TODO *oom* should use a format here return lDirAlloc . getLocalPathForWrite ( TaskTracker . getIntermediateOutputDir ( jobId . toString ( ) , reduceTaskId . toString ( ) ) + "/map_" + mapId . getId ( ) + ".out" , size , conf ) ; }
Create a local reduce input file name .