@Test public void open() throws IOException { byte[] bytes = getBytes(); String filepath = PathUtils.concatPath(mLocalUfsRoot, getUniqueFileName()); OutputStream os = mLocalUfs.create(filepath); os.write(bytes); os.close(); InputStream is = mLocalUfs.open(filepath); byte[] bytes1 = new byte[bytes.length]; is.read(bytes1); is.close(); Assert.assertArrayEquals(bytes, bytes1); }
@Override public InputStream open(String path, OpenOptions options) throws IOException { path = stripPath(path); InputStream inputStream = new BufferedInputStream(new FileInputStream(path)); try { ByteStreams.skipFully(inputStream, options.getOffset()); } catch (IOException e) { inputStream.close(); throw e; } return inputStream; }
LocalUnderFileSystem extends ConsistentUnderFileSystem implements AtomicFileOutputStreamCallback { @Override public InputStream open(String path, OpenOptions options) throws IOException { path = stripPath(path); InputStream inputStream = new BufferedInputStream(new FileInputStream(path)); try { ByteStreams.skipFully(inputStream, options.getOffset()); } catch (IOException e) { inputStream.close(); throw e; } return inputStream; } }
LocalUnderFileSystem extends ConsistentUnderFileSystem implements AtomicFileOutputStreamCallback { @Override public InputStream open(String path, OpenOptions options) throws IOException { path = stripPath(path); InputStream inputStream = new BufferedInputStream(new FileInputStream(path)); try { ByteStreams.skipFully(inputStream, options.getOffset()); } catch (IOException e) { inputStream.close(); throw e; } return inputStream; } LocalUnderFileSystem(AlluxioURI uri, UnderFileSystemConfiguration ufsConf); }
LocalUnderFileSystem extends ConsistentUnderFileSystem implements AtomicFileOutputStreamCallback { @Override public InputStream open(String path, OpenOptions options) throws IOException { path = stripPath(path); InputStream inputStream = new BufferedInputStream(new FileInputStream(path)); try { ByteStreams.skipFully(inputStream, options.getOffset()); } catch (IOException e) { inputStream.close(); throw e; } return inputStream; } LocalUnderFileSystem(AlluxioURI uri, UnderFileSystemConfiguration ufsConf); @Override String getUnderFSType(); @Override void cleanup(); @Override void close(); @Override OutputStream create(String path, CreateOptions options); @Override OutputStream createDirect(String path, CreateOptions options); @Override boolean deleteDirectory(String path, DeleteOptions options); @Override boolean deleteFile(String path); @Override boolean exists(String path); @Override long getBlockSizeByte(String path); @Override UfsDirectoryStatus getDirectoryStatus(String path); @Override List<String> getFileLocations(String path); @Override List<String> getFileLocations(String path, FileLocationOptions options); @Override UfsFileStatus getFileStatus(String path); @Override long getSpace(String path, SpaceType type); @Override UfsStatus getStatus(String path); @Override boolean isDirectory(String path); @Override boolean isFile(String path); @Override UfsStatus[] listStatus(String path); @Override boolean mkdirs(String path, MkdirsOptions options); @Override InputStream open(String path, OpenOptions options); @Override boolean renameDirectory(String src, String dst); @Override boolean renameFile(String src, String dst); @Override void setOwner(String path, String user, String group); @Override void setMode(String path, short mode); @Override void connectFromMaster(String hostname); @Override void connectFromWorker(String hostname); @Override boolean supportsFlush(); }
LocalUnderFileSystem extends ConsistentUnderFileSystem implements AtomicFileOutputStreamCallback { @Override public InputStream open(String path, OpenOptions options) throws IOException { path = stripPath(path); InputStream inputStream = new BufferedInputStream(new FileInputStream(path)); try { ByteStreams.skipFully(inputStream, options.getOffset()); } catch (IOException e) { inputStream.close(); throw e; } return inputStream; } LocalUnderFileSystem(AlluxioURI uri, UnderFileSystemConfiguration ufsConf); @Override String getUnderFSType(); @Override void cleanup(); @Override void close(); @Override OutputStream create(String path, CreateOptions options); @Override OutputStream createDirect(String path, CreateOptions options); @Override boolean deleteDirectory(String path, DeleteOptions options); @Override boolean deleteFile(String path); @Override boolean exists(String path); @Override long getBlockSizeByte(String path); @Override UfsDirectoryStatus getDirectoryStatus(String path); @Override List<String> getFileLocations(String path); @Override List<String> getFileLocations(String path, FileLocationOptions options); @Override UfsFileStatus getFileStatus(String path); @Override long getSpace(String path, SpaceType type); @Override UfsStatus getStatus(String path); @Override boolean isDirectory(String path); @Override boolean isFile(String path); @Override UfsStatus[] listStatus(String path); @Override boolean mkdirs(String path, MkdirsOptions options); @Override InputStream open(String path, OpenOptions options); @Override boolean renameDirectory(String src, String dst); @Override boolean renameFile(String src, String dst); @Override void setOwner(String path, String user, String group); @Override void setMode(String path, short mode); @Override void connectFromMaster(String hostname); @Override void connectFromWorker(String hostname); @Override boolean supportsFlush();  }