Method openDFSFile

src/org/apache/pig/impl/io/FileLocalizer.java:169–178

This function is meant to be used if the mappers/reducers want to access any HDFS file @param fileName @return InputStream of the open file. @throws IOException

(String fileName)

     * @throws IOException
     */
    public static InputStream openDFSFile(String fileName) throws IOException {
        Configuration conf = PigMapReduce.sJobConfInternal.get();
        if (conf == null) {
            throw new RuntimeException(
                    "can't open DFS file while executing locally");
        }

        return openDFSFile(fileName, ConfigurationUtil.toProperties(conf));

    }

    public static InputStream openDFSFile(String fileName, Properties properties) throws IOException{
        DataStorage dds = new HDataStorage(properties);