@ Override public FSDataInputStream open ( Path path , int bufferSize ) throws IOException { String table = getTableName ( _rootPath , path ) ; String split = getSplitName ( _rootPath , path ) ; split = splitNameWithoutGzipExtension ( split ) ; return new FSDataInputStream ( new EmoSplitInputStream ( table , split ) ) ; }
Opens a split for reading . Note that the preferred and more efficient way to do this is by using an EmoInputFormat . However if using a MapReduce framework which does not support custom input formats such as Presto the splits can be opened directly using this method .