Method open

src/org/apache/pig/impl/io/FileLocalizer.java:304–316

This function returns an input stream to a local file system file or a file residing on Hadoop's DFS @param fileName The filename to open @param execType execType indicating whether executing in local mode or MapReduce mode (Hadoop) @param storage The DataStorage object used to open the fileSpec @re

(String fileName, ExecType execType, DataStorage storage)

     * @deprecated Use {@link #open(String, PigContext)} instead
     */
    @Deprecated
    static public InputStream open(String fileName, ExecType execType, DataStorage storage) throws IOException {
        fileName = checkDefaultPrefix(execType, fileName);
        if (!fileName.startsWith(LOCAL_PREFIX)) {
            ElementDescriptor elem = storage.asElement(fullPath(fileName, storage));
            return openDFSFile(elem);
        }
        else {
            fileName = fileName.substring(LOCAL_PREFIX.length());
            ElementDescriptor elem = storage.asElement(fullPath(fileName, storage));
            return openLFSFile(elem);
        }
    }

    /**
     * @deprecated Use {@link #fullPath(String, PigContext)} instead