Home | About | Sematext search-lucene.com search-hadoop.com
 Search Hadoop and all its subprojects:

Switch to Threaded View
HDFS >> mail # user >> DFS and the RecordReader


Copy link to this message
-
DFS and the RecordReader
Hi guys:

Where and how does a Hadoop's record reader decide wether or not it needs
to copy a file to local disk ?

Clearly, since the InputSplit (which has meta data about file inputs) is
the input to the RecordReader, the RecordReader would have to implement
some kind of smart decision making ... Im looking for something like

//Psuedocode
if(! file.existsLocally())
   copyFileToDisk(filegetPath());

return new InputStream(file);

I've looked here:

http://grepcode.com/file/repo1.maven.org/maven2/org.jvnet.hudson.hadoop/hadoop-core/0.19.1-hudson-2/org/apache/hadoop/hdfs/DFSClient.java#DFSClient.create%28java.lang.String%2Corg.apache.hadoop.fs.permission.FsPermission%2Cboolean%2Cshort%2Clong%2Corg.apache.hadoop.util.Progressable%2Cint%29

but don't see anything.

--
Jay Vyas
http://jayunit100.blogspot.com